informer

Documentation

Index

• 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
• type ConvertFunc

Functions

func NewIndexerInformer

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

NewIndexerInformer is a copy of k8s.io/client-go/tools/cache/NewIndexerInformer with a new argument which converts an object into another object that can be stored in the local cache.

func NewInformer

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

NewInformer is a copy of k8s.io/client-go/tools/cache/NewInformer with a new argument which converts an object into another object that can be stored in the local cache.

func NewInformerWithStore

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

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

Types

type ConvertFunc

type ConvertFunc func(obj interface{}) interface{}