informer

Documentation

Index

• func NewNamedController(name string, config *cache.Config) cache.Controller
• type DynamicListerWatcherFactory
  • func NewDynamicListWatcherFactory(client dynamic.Interface) DynamicListerWatcherFactory
• type FilteringResourceEventHandler
  • func (r FilteringResourceEventHandler) OnAdd(obj interface{})
  • func (r FilteringResourceEventHandler) OnDelete(obj interface{})
  • func (r FilteringResourceEventHandler) OnSync(obj interface{})
  • func (r FilteringResourceEventHandler) OnUpdate(oldObj, newObj interface{})
• type ResourceEventHandler
• type ResourceEventHandlerFuncs
  • func (r ResourceEventHandlerFuncs) OnAdd(obj interface{})
  • func (r ResourceEventHandlerFuncs) OnDelete(obj interface{})
  • func (r ResourceEventHandlerFuncs) OnSync(obj interface{})
  • func (r ResourceEventHandlerFuncs) OnUpdate(oldObj, newObj interface{})
• type ResourceVersionInformer
  • func NewResourceVersionInformer(name string, lw cache.ListerWatcher, storage *ResourceVersionStorage, ...) ResourceVersionInformer
• type ResourceVersionStorage
  • func NewResourceVersionStorage(keyFunc cache.KeyFunc) *ResourceVersionStorage
  • func (c *ResourceVersionStorage) Add(obj interface{}) error
  • func (c *ResourceVersionStorage) Delete(obj interface{}) error
  • func (c *ResourceVersionStorage) Get(obj interface{}) (string, bool, error)
  • func (c *ResourceVersionStorage) GetByKey(key string) (item interface{}, exists bool, err error)
  • func (c *ResourceVersionStorage) ListKeys() []string
  • func (c *ResourceVersionStorage) Replace(versions map[string]interface{}) error
  • func (c *ResourceVersionStorage) Update(obj interface{}) error
• type TweakListOptionsFunc

Functions

func NewNamedController

func NewNamedController(name string, config *cache.Config) cache.Controller

Types

type DynamicListerWatcherFactory

type DynamicListerWatcherFactory interface {
	ForResource(namespace string, gvr schema.GroupVersionResource) cache.ListerWatcher
	ForResourceWithOptions(namespace string, gvr schema.GroupVersionResource, optionsFunc TweakListOptionsFunc) cache.ListerWatcher
}

func NewDynamicListWatcherFactory

func NewDynamicListWatcherFactory(client dynamic.Interface) DynamicListerWatcherFactory

type FilteringResourceEventHandler

type FilteringResourceEventHandler struct {
	FilterFunc func(obj interface{}) bool
	Handler    ResourceEventHandler
}

func (FilteringResourceEventHandler) OnAdd

func (r FilteringResourceEventHandler) OnAdd(obj interface{})

func (FilteringResourceEventHandler) OnDelete

func (r FilteringResourceEventHandler) OnDelete(obj interface{})

func (FilteringResourceEventHandler) OnSync

func (r FilteringResourceEventHandler) OnSync(obj interface{})

func (FilteringResourceEventHandler) OnUpdate

func (r FilteringResourceEventHandler) OnUpdate(oldObj, newObj interface{})

type ResourceEventHandler

type ResourceEventHandler interface {
	cache.ResourceEventHandler
	OnSync(obj interface{})
}

type ResourceEventHandlerFuncs

type ResourceEventHandlerFuncs struct {
	AddFunc    func(obj interface{})
	UpdateFunc func(oldObj, newObj interface{})
	DeleteFunc func(obj interface{})
	SyncFunc   func(obj interface{})
}

func (ResourceEventHandlerFuncs) OnAdd

func (r ResourceEventHandlerFuncs) OnAdd(obj interface{})

func (ResourceEventHandlerFuncs) OnDelete

func (r ResourceEventHandlerFuncs) OnDelete(obj interface{})

func (ResourceEventHandlerFuncs) OnSync

func (r ResourceEventHandlerFuncs) OnSync(obj interface{})

func (ResourceEventHandlerFuncs) OnUpdate

func (r ResourceEventHandlerFuncs) OnUpdate(oldObj, newObj interface{})

type ResourceVersionInformer

type ResourceVersionInformer interface {
	Run(stopCh <-chan struct{})
	HasSynced() bool
}

func NewResourceVersionInformer

func NewResourceVersionInformer(name string, lw cache.ListerWatcher, storage *ResourceVersionStorage, exampleObject runtime.Object, handler ResourceEventHandler) ResourceVersionInformer

type ResourceVersionStorage

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

func NewResourceVersionStorage

func NewResourceVersionStorage(keyFunc cache.KeyFunc) *ResourceVersionStorage

func (*ResourceVersionStorage) Add

func (c *ResourceVersionStorage) Add(obj interface{}) error

func (*ResourceVersionStorage) Delete

func (c *ResourceVersionStorage) Delete(obj interface{}) error

func (*ResourceVersionStorage) Get

func (c *ResourceVersionStorage) Get(obj interface{}) (string, bool, error)

func (*ResourceVersionStorage) GetByKey

func (c *ResourceVersionStorage) GetByKey(key string) (item interface{}, exists bool, err error)

func (*ResourceVersionStorage) ListKeys

func (c *ResourceVersionStorage) ListKeys() []string

func (*ResourceVersionStorage) Replace

func (c *ResourceVersionStorage) Replace(versions map[string]interface{}) error

func (*ResourceVersionStorage) Update

func (c *ResourceVersionStorage) Update(obj interface{}) error

type TweakListOptionsFunc

type TweakListOptionsFunc func(*metav1.ListOptions)