factory

Oct 20, 2022

Changes in this version

type Controller

+ SyncContext func() SyncContext

Jul 11, 2022

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

+ 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)

+ 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