watcher

Documentation

Index

• func NewFactory(clientSet kubernetes.Interface, resyncPeriod time.Duration) informers.SharedInformerFactory
• type Error
• type EventHandler
• type ResourceWatcher
  • func (rw *ResourceWatcher) NewDefaultGroupVersionResources() []schema.GroupVersionResource
  • func (rw *ResourceWatcher) NewEventHandlerFuncs() *cache.ResourceEventHandlerFuncs
  • func (rw *ResourceWatcher) Watch(ctx context.Context, i informers.GenericInformer, h cache.ResourceEventHandler) error

Functions

func NewFactory

func NewFactory(clientSet kubernetes.Interface, resyncPeriod time.Duration) informers.SharedInformerFactory

Types

type Error

type Error struct {
	Resource schema.GroupVersionResource
	Error    error
}

type EventHandler

type EventHandler interface {
	HandleAdd(obj interface{}) error
	HandleDelete(obj interface{}) error
	HandleUpdate(oldObj interface{}, newObj interface{}) error
}

type ResourceWatcher

type ResourceWatcher struct {
	Handler EventHandler
}

func (*ResourceWatcher) NewDefaultGroupVersionResources

func (rw *ResourceWatcher) NewDefaultGroupVersionResources() []schema.GroupVersionResource

func (*ResourceWatcher) NewEventHandlerFuncs

func (rw *ResourceWatcher) NewEventHandlerFuncs() *cache.ResourceEventHandlerFuncs

func (*ResourceWatcher) Watch

func (rw *ResourceWatcher) Watch(ctx context.Context, i informers.GenericInformer, h cache.ResourceEventHandler) error