watcher

Documentation

Index

• func NewSimpleWatcher(cgu *clientgoutils.ClientGoUtils, resource string, ...)
• type Controller
  • func NewController(watcher Watcher, lw cache.ListerWatcher, objType rt.Object) *Controller
  • func (c *Controller) Run(threadiness int, stopCh chan struct{})
• type SimpleWatcher
• type Watcher

Functions

func NewSimpleWatcher

func NewSimpleWatcher(
	cgu *clientgoutils.ClientGoUtils, resource string, listOptions metav1.ListOptions, stopChan <-chan struct{},
	createOrUpdateFun func(key string, object interface{}, quitChan <-chan struct{}),
	deleteFun func(key string, quitChan <-chan struct{}),
)

NewSimpleWatcher returns the chan control the informer's live cycle you can stop the informer by calling quitChan <- whatever or block the thread by this quitChan

the quitChan in createOrUpdateFunc, deleteFunc and returns is the same

Types

type Controller

type Controller struct {
	// contains filtered or unexported fields
}

func NewController

func NewController(watcher Watcher, lw cache.ListerWatcher, objType rt.Object) *Controller

func (*Controller) Run

func (c *Controller) Run(threadiness int, stopCh chan struct{})

Run begins watching and syncing.

type SimpleWatcher

type SimpleWatcher struct {
	// contains filtered or unexported fields
}

type Watcher

type Watcher interface {
	CreateOrUpdate(key string, item interface{}) error
	Delete(key string) error
	WatcherInfo() string
}