Versions in this module Expand all Collapse all v2 v2.0.0 Aug 5, 2022 Changes in this version + const WorkqueueAddEvent + const WorkqueueDeleteEvent + const WorkqueueUpdateEvent + type DefaultHandler struct + Informer cache.SharedInformer + Name string + Synced cache.InformerSynced + func (handler *DefaultHandler) AddFunc(ctx context.Context, namespace, name string) error + func (handler *DefaultHandler) DeleteFunc(ctx context.Context, namespace, name string) error + func (handler *DefaultHandler) GetInformer() cache.SharedInformer + func (handler *DefaultHandler) GetName() string + func (handler *DefaultHandler) GetSynced() cache.InformerSynced + func (handler *DefaultHandler) UpdateFunc(ctx context.Context, namespace, name string) error + type EventHandler interface + AddFunc func(ctx context.Context, namespace, name string) error + DeleteFunc func(ctx context.Context, namespace, name string) error + GetInformer func() cache.SharedInformer + GetName func() string + GetSynced func() cache.InformerSynced + UpdateFunc func(ctx context.Context, namespace, name string) error + type EventLoop interface + Register func(handler EventHandler) + Run func(ctx context.Context, threadiness int) error + func NewEventLoop(name string) EventLoop + type WorkQueue interface + AddSynced func(cache.InformerSynced) + EnqueueAdd func(kind string, obj interface{}) + EnqueueDelete func(kind string, obj interface{}) + EnqueueUpdate func(kind string, obj interface{}) + Length func() int + RegisterAddHandler func(kind string, handler WorkQueueHandler) + RegisterDeleteHandler func(kind string, handler WorkQueueHandler) + RegisterUpdateHandler func(kind string, handler WorkQueueHandler) + Run func(ctx context.Context, threadiness int) error + func NewWorkQueue(name string) WorkQueue + type WorkQueueHandler func(ctx context.Context, namespace, name string) error
Go to main page