informer

Documentation

Index

• func CastInformerEvent[typ any](obj interface{}) *typ
• func NewIndexerInformer(lw cache.ListerWatcher, objType k8sRuntime.Object, resyncPeriod time.Duration, ...) (cache.Indexer, cache.Controller)
• func NewInformer(lw cache.ListerWatcher, objType k8sRuntime.Object, resyncPeriod time.Duration, ...) (cache.Store, cache.Controller)
• func NewInformerWithStore(lw cache.ListerWatcher, objType k8sRuntime.Object, resyncPeriod time.Duration, ...) cache.Controller

Functions

func CastInformerEvent

func CastInformerEvent[typ any](obj interface{}) *typ

CastInformerEvent tries to cast obj to type typ, directly or by DeletedFinalStateUnknown type. It returns nil and logs an error if obj doesn't contain type typ.

func NewIndexerInformer

func NewIndexerInformer(
	lw cache.ListerWatcher,
	objType k8sRuntime.Object,
	resyncPeriod time.Duration,
	h cache.ResourceEventHandler,
	transformer cache.TransformFunc,
	indexers cache.Indexers,
) (cache.Indexer, cache.Controller)

NewIndexerInformer is a copy of k8s.io/client-go/tools/cache/NewIndexerInformer but includes the default cache MutationDetector.

func NewInformer

func NewInformer(
	lw cache.ListerWatcher,
	objType k8sRuntime.Object,
	resyncPeriod time.Duration,
	h cache.ResourceEventHandler,
	transformer cache.TransformFunc,
) (cache.Store, cache.Controller)

NewInformer is a copy of k8s.io/client-go/tools/cache/NewInformer includes the default cache MutationDetector.

func NewInformerWithStore

func NewInformerWithStore(
	lw cache.ListerWatcher,
	objType k8sRuntime.Object,
	resyncPeriod time.Duration,
	h cache.ResourceEventHandler,
	transformer cache.TransformFunc,
	clientState cache.Store,
) cache.Controller

NewInformerWithStore uses the same arguments as NewInformer for which a caller can also set a cache.Store and includes the default cache MutationDetector.