informers

Documentation

Index

• type Manager
  • func NewManager(config *v1alpha1.KubeAPIConfig) (*Manager, error)
  • func (mgr *Manager) GetIstioClient() istio.Interface
  • func (mgr *Manager) GetIstioFactory() istioinformers.SharedInformerFactory
  • func (mgr *Manager) GetKubeClient() kubernetes.Interface
  • func (mgr *Manager) GetKubeFactory() k8sinformers.SharedInformerFactory
  • func (mgr *Manager) RegisterInformer(informer cache.SharedIndexInformer)
  • func (mgr *Manager) RegisterSyncedFunc(fn syncedFunc)
  • func (mgr *Manager) Start(stopCh <-chan struct{})

Types

type Manager

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

Manager is an informer factories manager

func NewManager

func NewManager(config *v1alpha1.KubeAPIConfig) (*Manager, error)

func (*Manager) GetIstioClient

func (mgr *Manager) GetIstioClient() istio.Interface

func (*Manager) GetIstioFactory

func (mgr *Manager) GetIstioFactory() istioinformers.SharedInformerFactory

func (*Manager) GetKubeClient

func (mgr *Manager) GetKubeClient() kubernetes.Interface

func (*Manager) GetKubeFactory

func (mgr *Manager) GetKubeFactory() k8sinformers.SharedInformerFactory

func (*Manager) RegisterInformer

func (mgr *Manager) RegisterInformer(informer cache.SharedIndexInformer)

RegisterInformer add a informer to Manager. It is important to note that the Informer constructed for each resource type will be cached, and repeated calls to Informer() on the same resource will return the same Informer instance.

func (*Manager) RegisterSyncedFunc

func (mgr *Manager) RegisterSyncedFunc(fn syncedFunc)

RegisterSyncedFunc add a syncedFunc

func (*Manager) Start

func (mgr *Manager) Start(stopCh <-chan struct{})

Start starts all factories and run all informers