cache

Documentation

Index

• type CacheMap
• type CacheMapClient
• type CacheSetup
• type ConfigMapCache
  • func (a *ConfigMapCache) GetInformer() cache.SharedIndexInformer
• type CustomCache
• type CustomCacheConfig
  • func (cacheConfig *CustomCacheConfig) NewSharedCaches() *SharedCustomCaches
• type NamespaceCache
  • func (a *NamespaceCache) GetInformer() cache.SharedIndexInformer
• type ServicesCache
  • func (a *ServicesCache) GetInformer() cache.SharedIndexInformer
• type SharedCustomCaches
  • func (sc *SharedCustomCaches) GetConfigMapByKey(key string) (configMap *corev1.ConfigMap, err error)
  • func (sc *SharedCustomCaches) GetNamespaceByKey(key string) (namespace *corev1.Namespace, err error)
  • func (sc *SharedCustomCaches) GetServiceByKey(key string) (service *corev1.Service, err error)
  • func (sc *SharedCustomCaches) SetupWithManager(mgr ctrl.Manager, log loggerutil.OSOKLogger)

Types

type CacheMap

type CacheMap interface {
	NewSharedCaches() map[commons.InformerCacheType]cache.SharedIndexInformer
}

type CacheMapClient

type CacheMapClient interface {
	GetConfigMapByKey(key string) (item *corev1.ConfigMap, err error)
	GetNamespaceByKey(key string) (item *corev1.Namespace, err error)
	GetServiceByKey(key string) (item *corev1.Service, err error)
}

type CacheSetup

type CacheSetup interface {
	SetupWithManager(mgr ctrl.Manager, cache cache.SharedInformer)
}

type ConfigMapCache

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

func (*ConfigMapCache) GetInformer

func (a *ConfigMapCache) GetInformer() cache.SharedIndexInformer

type CustomCache

type CustomCache interface {
	GetInformer() cache.SharedIndexInformer
}

This abstraction will enable to create caches which can be bundles together and passed around

type CustomCacheConfig

type CustomCacheConfig struct {
	ResyncPeriod time.Duration
	ClientSet    kubernetes.Interface
	Log          loggerutil.OSOKLogger
}

func (*CustomCacheConfig) NewSharedCaches

func (cacheConfig *CustomCacheConfig) NewSharedCaches() *SharedCustomCaches

type NamespaceCache

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

func (*NamespaceCache) GetInformer

func (a *NamespaceCache) GetInformer() cache.SharedIndexInformer

type ServicesCache

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

func (*ServicesCache) GetInformer

func (a *ServicesCache) GetInformer() cache.SharedIndexInformer

type SharedCustomCaches

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

func (*SharedCustomCaches) GetConfigMapByKey

func (sc *SharedCustomCaches) GetConfigMapByKey(key string) (configMap *corev1.ConfigMap, err error)

func (*SharedCustomCaches) GetNamespaceByKey

func (sc *SharedCustomCaches) GetNamespaceByKey(key string) (namespace *corev1.Namespace, err error)

func (*SharedCustomCaches) GetServiceByKey

func (sc *SharedCustomCaches) GetServiceByKey(key string) (service *corev1.Service, err error)

func (*SharedCustomCaches) SetupWithManager

func (sc *SharedCustomCaches) SetupWithManager(mgr ctrl.Manager, log loggerutil.OSOKLogger)