informer

Feb 2, 2024

Changes in this version

type Informer

+ func (i *Informer[T, L]) WatchWithLazyCache(ctx context.Context, opt Option, events chan<- Event[T]) (Getter[T], error)

Aug 23, 2023

Changes in this version

+ type Event struct

+ Object T

+ Type EventType

+ type EventType string

+ const Added

+ const Deleted

+ const Modified

+ const Sync

+ type Getter interface

+ Get func(name string) (T, bool)

+ GetWithNamespace func(name, namespace string) (T, bool)

+ List func() []T

+ type Informer struct

+ ListFunc func(ctx context.Context, opts metav1.ListOptions) (L, error)

+ WatchFunc func(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)

+ func NewInformer(lw Watcher[T, L]) *Informer[T, L]

+ func (i *Informer[T, L]) Sync(ctx context.Context, opt Option, events chan<- Event[T]) error

+ func (i *Informer[T, L]) Watch(ctx context.Context, opt Option, events chan<- Event[T]) error

+ func (i *Informer[T, L]) WatchWithCache(ctx context.Context, opt Option, events chan<- Event[T]) (Getter[T], error)

+ type Option struct

+ AnnotationSelector string

+ FieldSelector string

+ LabelSelector string

+ type Watcher interface

+ List func(ctx context.Context, opts metav1.ListOptions) (L, error)

+ Watch func(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)