cache

Documentation

Index

• func CreateSharedInformerCache(mgr manager.Manager) error
• func SetTestInstance(s SharedInformerCache)
• type SharedInformerCache
  • func Instance() SharedInformerCache

Functions

func CreateSharedInformerCache

func CreateSharedInformerCache(mgr manager.Manager) error

func SetTestInstance

func SetTestInstance(s SharedInformerCache)

Only used for UTs

Types

type SharedInformerCache

type SharedInformerCache interface {
	// block added by flant.com
	// GetNode returns the node info if present in the cache.
	GetNode(nodeName string) (*corev1.Node, error)

	// WatchPods registers the pod event handlers with the informer cache
	WatchPods(fn func(object interface{})) error

	// GetPersistentVolumeClaim returns the PersistentVolumeClaim in a namespace from the cache after applying TransformFunc
	GetPersistentVolumeClaim(pvcName string, namespace string) (*corev1.PersistentVolumeClaim, error)
}

SharedInformerCache is an eventually consistent cache. The cache interface provides APIs to fetch specific k8s objects from the cache. Only a subset of k8s objects are currently managed by this cache. DO NOT USE it when you need the latest and accurate copy of a CR.

func Instance

func Instance() SharedInformerCache