storage

Documentation

Index

• Variables
• type APICacheInterface
• type APICaches
• type CacheManagerAdder
• type CacheManagerReader
• type CacheManagerReaderAdder
• type Manager
  • func NewManager(homeClient, foreignClient kubernetes.Interface) *Manager
  • func (cm *Manager) AddForeignEventHandlers(api apimgmt.ApiType, namespace string, ...) error
  • func (cm *Manager) AddForeignNamespace(namespace string) error
  • func (cm *Manager) AddHomeEventHandlers(api apimgmt.ApiType, namespace string, ...) error
  • func (cm *Manager) AddHomeNamespace(namespace string) error
  • func (cm *Manager) GetForeignApiByIndex(api apimgmt.ApiType, namespace, index string) (interface{}, error)
  • func (cm *Manager) GetForeignNamespacedObject(api apimgmt.ApiType, namespace, name string) (interface{}, error)
  • func (cm *Manager) GetHomeApiByIndex(api apimgmt.ApiType, namespace, index string) (interface{}, error)
  • func (cm *Manager) GetHomeNamespacedObject(api apimgmt.ApiType, namespace, name string) (interface{}, error)
  • func (cm *Manager) ListForeignNamespacedObject(api apimgmt.ApiType, namespace string) ([]interface{}, error)
  • func (cm *Manager) ListHomeNamespacedObject(api apimgmt.ApiType, namespace string) ([]interface{}, error)
  • func (cm *Manager) RemoveNamespace(namespace string)
  • func (cm *Manager) StartForeignNamespace(foreignNamespace string, stop chan struct{}) error
  • func (cm *Manager) StartHomeNamespace(homeNamespace string, stop chan struct{}) error
• type NamespacedAPICaches
  • func (ac *NamespacedAPICaches) AddNamespace(namespace string) error
  • func (ac *NamespacedAPICaches) Namespace(namespace string) *APICaches

Variables

var InformerBuilders = map[apimgmt.ApiType]func(informers.SharedInformerFactory) cache.SharedIndexInformer{
	apimgmt.Configmaps:     configmapsInformerBuilder,
	apimgmt.EndpointSlices: endpointSlicesInformerBuilder,
	apimgmt.Pods:           podsInformerBuilder,
	apimgmt.ReplicaSets:    replicaSetsInformerBuilder,
	apimgmt.Services:       servicesInformerBuilder,
	apimgmt.Secrets:        secretsInformerBuilder,
}

var InformerIndexers = map[apimgmt.ApiType]func() cache.Indexers{
	apimgmt.Configmaps:     configmapsIndexers,
	apimgmt.EndpointSlices: endpointSlicesIndexers,
	apimgmt.Pods:           podsIndexers,
	apimgmt.ReplicaSets:    replicasetsIndexers,
	apimgmt.Secrets:        secretsIndexers,
	apimgmt.Services:       servicesIndexers,
}

Types

type APICacheInterface

type APICacheInterface interface {
	// contains filtered or unexported methods
}

type APICaches

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

APICaches represents a set of informers for a set of APIs

type CacheManagerAdder

type CacheManagerAdder interface {
	AddHomeNamespace(string) error
	AddForeignNamespace(string) error
	StartHomeNamespace(string, chan struct{}) error
	StartForeignNamespace(string, chan struct{}) error
	RemoveNamespace(string)
	AddHomeEventHandlers(apimgmt.ApiType, string, *cache.ResourceEventHandlerFuncs) error
	AddForeignEventHandlers(apimgmt.ApiType, string, *cache.ResourceEventHandlerFuncs) error
}

type CacheManagerReader

type CacheManagerReader interface {
	GetHomeNamespacedObject(apimgmt.ApiType, string, string) (interface{}, error)
	GetForeignNamespacedObject(apimgmt.ApiType, string, string) (interface{}, error)
	ListHomeNamespacedObject(apimgmt.ApiType, string) ([]interface{}, error)
	ListForeignNamespacedObject(apimgmt.ApiType, string) ([]interface{}, error)
	GetHomeApiByIndex(apimgmt.ApiType, string, string) (interface{}, error)
	GetForeignApiByIndex(apimgmt.ApiType, string, string) (interface{}, error)
}

type CacheManagerReaderAdder

type CacheManagerReaderAdder interface {
	CacheManagerAdder
	CacheManagerReader
}

type Manager

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

func NewManager

func NewManager(homeClient, foreignClient kubernetes.Interface) *Manager

func (*Manager) AddForeignEventHandlers

func (cm *Manager) AddForeignEventHandlers(api apimgmt.ApiType, namespace string, handlers *cache.ResourceEventHandlerFuncs) error

func (*Manager) AddForeignNamespace

func (cm *Manager) AddForeignNamespace(namespace string) error

func (*Manager) AddHomeEventHandlers

func (cm *Manager) AddHomeEventHandlers(api apimgmt.ApiType, namespace string, handlers *cache.ResourceEventHandlerFuncs) error

func (*Manager) AddHomeNamespace

func (cm *Manager) AddHomeNamespace(namespace string) error

func (*Manager) GetForeignApiByIndex

func (cm *Manager) GetForeignApiByIndex(api apimgmt.ApiType, namespace, index string) (interface{}, error)

func (*Manager) GetForeignNamespacedObject

func (cm *Manager) GetForeignNamespacedObject(api apimgmt.ApiType, namespace, name string) (interface{}, error)

func (*Manager) GetHomeApiByIndex

func (cm *Manager) GetHomeApiByIndex(api apimgmt.ApiType, namespace, index string) (interface{}, error)

func (*Manager) GetHomeNamespacedObject

func (cm *Manager) GetHomeNamespacedObject(api apimgmt.ApiType, namespace, name string) (interface{}, error)

func (*Manager) ListForeignNamespacedObject

func (cm *Manager) ListForeignNamespacedObject(api apimgmt.ApiType, namespace string) ([]interface{}, error)

func (*Manager) ListHomeNamespacedObject

func (cm *Manager) ListHomeNamespacedObject(api apimgmt.ApiType, namespace string) ([]interface{}, error)

func (*Manager) RemoveNamespace

func (cm *Manager) RemoveNamespace(namespace string)

func (*Manager) StartForeignNamespace

func (cm *Manager) StartForeignNamespace(foreignNamespace string, stop chan struct{}) error

func (*Manager) StartHomeNamespace

func (cm *Manager) StartHomeNamespace(homeNamespace string, stop chan struct{}) error

type NamespacedAPICaches

type NamespacedAPICaches struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*NamespacedAPICaches) AddNamespace

func (ac *NamespacedAPICaches) AddNamespace(namespace string) error

func (*NamespacedAPICaches) Namespace

func (ac *NamespacedAPICaches) Namespace(namespace string) *APICaches