Versions in this module Expand all Collapse all v0 v0.15.0 Oct 14, 2024 v0.14.0 Jun 18, 2024 Changes in this version + const DefaultQueueKey + func DefaultQueueKeysFunc(_ runtime.Object) []string + type Controller interface + Name func() string + Run func(ctx context.Context, workers int) + Sync func(ctx context.Context, controllerContext SyncContext, key string) error + SyncContext func() SyncContext + type EventFilterFunc func(obj interface{}) bool + type Factory struct + func New() *Factory + func (f *Factory) ResyncEvery(interval time.Duration) *Factory + func (f *Factory) ToController(name string) Controller + func (f *Factory) WithBareInformers(informers ...Informer) *Factory + func (f *Factory) WithFilteredEventsInformers(filter EventFilterFunc, informers ...Informer) *Factory + func (f *Factory) WithFilteredEventsInformersQueueKeysFunc(queueKeyFn ObjectQueueKeysFunc, filter EventFilterFunc, informers ...Informer) *Factory + func (f *Factory) WithInformers(informers ...Informer) *Factory + func (f *Factory) WithInformersQueueKeysFunc(queueKeyFn ObjectQueueKeysFunc, informers ...Informer) *Factory + func (f *Factory) WithSync(syncFn SyncFunc) *Factory + func (f *Factory) WithSyncContext(ctx SyncContext) *Factory + type Informer interface + AddEventHandler func(handler cache.ResourceEventHandler) (cache.ResourceEventHandlerRegistration, error) + HasSynced func() bool + type ObjectQueueKeysFunc func(runtime.Object) []string + type SyncContext interface + Queue func() workqueue.RateLimitingInterface + func NewSyncContext(name string) SyncContext + type SyncFunc func(ctx context.Context, controllerContext SyncContext, key string) error
Go to main page