watcher

package
v0.0.0-...-318ac54 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 12, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const CACHE_PATH string = "/opt/ats/etc/trafficserver/cache.config"

Variables

This section is empty.

Functions

This section is empty.

Types

type AtsCacheHandler

type AtsCacheHandler struct {
	ResourceName string
	Ep           *endpoint.Endpoint
	CachePath    string
}

AtsCacheHandler handles ATSCachingPolicy events

func NewAtsCacheHandler

func NewAtsCacheHandler(resource string, ep *endpoint.Endpoint, path string) *AtsCacheHandler

Constructor

func (*AtsCacheHandler) Add

func (h *AtsCacheHandler) Add(obj interface{})

Add handles creation of ATSCachingPolicy resources

func (*AtsCacheHandler) Delete

func (h *AtsCacheHandler) Delete(obj interface{})

Delete handles deletion of ATSCachingPolicy resources

func (*AtsCacheHandler) Update

func (h *AtsCacheHandler) Update(oldObj, newObj interface{})

Update handles updates to ATSCachingPolicy resources

func (*AtsCacheHandler) UpdateAts

func (h *AtsCacheHandler) UpdateAts()

Update ATS config

type CMHandler

type CMHandler struct {
	ResourceName string
	Ep           *endpoint.Endpoint
}

CMHandler handles Add Update Delete methods on Configmaps

func (*CMHandler) Add

func (c *CMHandler) Add(obj interface{})

Add for EventHandler

func (*CMHandler) Delete

func (c *CMHandler) Delete(obj interface{})

Delete for EventHandler

func (*CMHandler) GetResourceName

func (c *CMHandler) GetResourceName() string

GetResourceName returns the resource name

func (*CMHandler) Update

func (c *CMHandler) Update(obj, newObj interface{})

Update for EventHandler

type EpHandler

type EpHandler struct {
	ResourceName string
	Ep           *endpoint.Endpoint
}

EpHandler implements EventHandler

func (*EpHandler) Add

func (e *EpHandler) Add(obj interface{})

func (*EpHandler) Delete

func (e *EpHandler) Delete(obj interface{})

Delete for EventHandler

func (*EpHandler) GetResourceName

func (e *EpHandler) GetResourceName() string

GetResourceName returns the resource name

func (*EpHandler) Update

func (e *EpHandler) Update(obj, newObj interface{})

Update for EventHandler

type EventHandler

type EventHandler interface {
	Add(obj interface{})
	Update(obj, newObj interface{})
	Delete(obj interface{})
	GetResourceName() string // EventHandler should store the ResourceName e.g. ingresses, endpoints...
}

EventHandler interface defines the 3 required methods to implement for watchers

type IgHandler

type IgHandler struct {
	ResourceName string
	Ep           *endpoint.Endpoint
}

IgHandler implements EventHandler

func (*IgHandler) Add

func (g *IgHandler) Add(obj interface{})

func (*IgHandler) Delete

func (g *IgHandler) Delete(obj interface{})

Delete for EventHandler

func (*IgHandler) GetResourceName

func (g *IgHandler) GetResourceName() string

GetResourceName returns the resource name

func (*IgHandler) Update

func (g *IgHandler) Update(obj, newObj interface{})

Update for EventHandler

type Watcher

type Watcher struct {
	Cs            kubernetes.Interface
	DynamicClient dynamic.Interface
	ATSNamespace  string
	ResyncPeriod  time.Duration
	Ep            *endpoint.Endpoint
	StopChan      chan struct{}
}

Watcher stores all essential information to act on HostGroups

func (*Watcher) Watch

func (w *Watcher) Watch() error

Watch creates necessary threads to watch over resources

func (*Watcher) WatchAtsCachingPolicy

func (w *Watcher) WatchAtsCachingPolicy(path string) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL