source

Aug 13, 2024

Changes in this version

+ type TypedFunc func(context.Context, workqueue.TypedRateLimitingInterface[request]) error

+ func (f TypedFunc[request]) Start(ctx context.Context, queue workqueue.TypedRateLimitingInterface[request]) error

+ func (f TypedFunc[request]) String() string

+ type TypedSource interface

+ Start func(context.Context, workqueue.TypedRateLimitingInterface[request]) error

+ func TypedChannel[object any, request comparable](source <-chan event.TypedGenericEvent[object], ...) TypedSource[request]

+ type TypedSyncingSource interface

+ WaitForSync func(ctx context.Context) error

+ func TypedKind[object client.Object, request comparable](cache cache.Cache, obj object, ...) TypedSyncingSource[request]

Apr 23, 2024

Changes in this version

+ type ChannelOpt func(*channel[T])

+ func WithBufferSize[T any](bufferSize int) ChannelOpt[T]

+ func WithPredicates[T any](p ...predicate.TypedPredicate[T]) ChannelOpt[T]

type Informer

+ Handler handler.EventHandler

+ Predicates []predicate.Predicate

May 22, 2020

Changes in this version

type Kind

+ func (ks *Kind) WaitForSync(stop <-chan struct{}) error

+ type SyncingSource interface

+ WaitForSync func(stop <-chan struct{}) error

Mar 10, 2020

Changes in this version

type Source

+ func NewKindWithCache(object runtime.Object, cache cache.Cache) Source

Oct 24, 2018

Changes in this version

type Channel

+ func (cs *Channel) String() string

type Func

+ func (f Func) String() string

+ type Informer struct

+ Informer toolscache.SharedIndexInformer

+ func (is *Informer) Start(handler handler.EventHandler, queue workqueue.RateLimitingInterface, ...) error

+ func (is *Informer) String() string

type Kind

+ func (ks *Kind) String() string

Aug 24, 2018

Changes in this version

+ type Channel struct

+ DestBufferSize int

+ Source <-chan event.GenericEvent

+ func (cs *Channel) InjectStopChannel(stop <-chan struct{}) error

+ func (cs *Channel) Start(handler handler.EventHandler, queue workqueue.RateLimitingInterface, ...) error

+ type Func func(handler.EventHandler, workqueue.RateLimitingInterface, ...predicate.Predicate) error

+ func (f Func) Start(evt handler.EventHandler, queue workqueue.RateLimitingInterface, ...) error

+ type Kind struct

+ Type runtime.Object

+ func (ks *Kind) InjectCache(c cache.Cache) error

+ func (ks *Kind) Start(handler handler.EventHandler, queue workqueue.RateLimitingInterface, ...) error

+ type Source interface

+ Start func(handler.EventHandler, workqueue.RateLimitingInterface, ...predicate.Predicate) error