multinsinformer

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 29, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DynamicMultiNamespaceInformer

type DynamicMultiNamespaceInformer struct {
	// contains filtered or unexported fields
}

DynamicMultiNamespaceInformer is a dynamic informer that spans multiple namespaces by starting individual informers per namespace and aggregating all of these.

func NewDynamicMultiNamespaceInformer

func NewDynamicMultiNamespaceInformer(
	gvr schema.GroupVersionResource,
	providerNamespace string,
	providerConfig *rest.Config,
	serviceNamespaceInformer dynamic.Informer[bindlisters.APIServiceNamespaceLister],
) (*DynamicMultiNamespaceInformer, error)

func (*DynamicMultiNamespaceInformer) AddEventHandler

func (inf *DynamicMultiNamespaceInformer) AddEventHandler(handler cache.ResourceEventHandler)

func (*DynamicMultiNamespaceInformer) Get

func (*DynamicMultiNamespaceInformer) List

func (*DynamicMultiNamespaceInformer) Start

func (*DynamicMultiNamespaceInformer) WaitForCacheSync

func (inf *DynamicMultiNamespaceInformer) WaitForCacheSync(stopCh <-chan struct{}) map[schema.GroupVersionResource]bool

type GetterInformer

type GetterInformer interface {
	Get(ns, name string) (runtime.Object, error)
	List(ns string) ([]runtime.Object, error)
	AddEventHandler(handler cache.ResourceEventHandler)

	Start(ctx context.Context)
	WaitForCacheSync(stopCh <-chan struct{}) map[schema.GroupVersionResource]bool
}

type GetterInformerWrapper

type GetterInformerWrapper struct {
	GVR      schema.GroupVersionResource
	Delegate dynamicinformer.DynamicSharedInformerFactory
}

func (GetterInformerWrapper) AddEventHandler

func (w GetterInformerWrapper) AddEventHandler(handler cache.ResourceEventHandler)

func (GetterInformerWrapper) Get

func (w GetterInformerWrapper) Get(ns, name string) (runtime.Object, error)

func (GetterInformerWrapper) List

func (GetterInformerWrapper) Start

func (w GetterInformerWrapper) Start(ctx context.Context)

func (GetterInformerWrapper) WaitForCacheSync

func (w GetterInformerWrapper) WaitForCacheSync(stopCh <-chan struct{}) map[schema.GroupVersionResource]bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL