framework

Jan 14, 2016

Changes in this version

type Controller

+ func (c *Controller) Requeue(obj interface{}) error

Sep 15, 2015

Changes in this version

+ func DeletionHandlingMetaNamespaceKeyFunc(obj interface{}) (string, error)

+ type Config struct

+ FullResyncPeriod time.Duration

+ ObjectType runtime.Object

+ Process ProcessFunc

+ RetryOnError bool

+ type Controller struct

+ func New(c *Config) *Controller

+ func NewIndexerInformer(lw cache.ListerWatcher, objType runtime.Object, resyncPeriod time.Duration, ...) (cache.Indexer, *Controller)

+ func NewInformer(lw cache.ListerWatcher, objType runtime.Object, resyncPeriod time.Duration, ...) (cache.Store, *Controller)

+ func (c *Controller) HasSynced() bool

+ func (c *Controller) Run(stopCh <-chan struct{})

+ type FakeControllerSource struct

+ func NewFakeControllerSource() *FakeControllerSource

+ func (f *FakeControllerSource) Add(obj runtime.Object)

+ func (f *FakeControllerSource) AddDropWatch(obj runtime.Object)

+ func (f *FakeControllerSource) Change(e watch.Event, watchProbability float64)

+ func (f *FakeControllerSource) Delete(lastValue runtime.Object)

+ func (f *FakeControllerSource) DeleteDropWatch(lastValue runtime.Object)

+ func (f *FakeControllerSource) List() (runtime.Object, error)

+ func (f *FakeControllerSource) Modify(obj runtime.Object)

+ func (f *FakeControllerSource) ModifyDropWatch(obj runtime.Object)

+ func (f *FakeControllerSource) Watch(resourceVersion string) (watch.Interface, error)

+ type ProcessFunc func(obj interface{}) error

+ type ResourceEventHandler interface

+ OnAdd func(obj interface{})

+ OnDelete func(obj interface{})

+ OnUpdate func(oldObj, newObj interface{})

+ type ResourceEventHandlerFuncs struct

+ AddFunc func(obj interface{})

+ DeleteFunc func(obj interface{})

+ UpdateFunc func(oldObj, newObj interface{})

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

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

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