informer

Documentation

Index

• func NewGlobalMapClusterNamespace() map[string]map[string]bool
• type K8sInformerFactory
• type K8sInformerFactoryImpl
  • func NewK8sInformerFactoryImpl(logger *zap.SugaredLogger, ...) *K8sInformerFactoryImpl
  • func (impl *K8sInformerFactoryImpl) BuildInformer(clusterInfo []*bean.ClusterInfo)
  • func (impl *K8sInformerFactoryImpl) CleanNamespaceInformer(clusterName string)
  • func (impl *K8sInformerFactoryImpl) GetLatestNamespaceListGroupByCLuster() map[string]map[string]bool

Functions

func NewGlobalMapClusterNamespace

func NewGlobalMapClusterNamespace() map[string]map[string]bool

Types

type K8sInformerFactory

type K8sInformerFactory interface {
	GetLatestNamespaceListGroupByCLuster() map[string]map[string]bool
	BuildInformer(clusterInfo []*bean.ClusterInfo)
	CleanNamespaceInformer(clusterName string)
}

type K8sInformerFactoryImpl

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

func NewK8sInformerFactoryImpl

func NewK8sInformerFactoryImpl(logger *zap.SugaredLogger, globalMapClusterNamespace map[string]map[string]bool, runtimeConfig *client.RuntimeConfig) *K8sInformerFactoryImpl

func (*K8sInformerFactoryImpl) BuildInformer

func (impl *K8sInformerFactoryImpl) BuildInformer(clusterInfo []*bean.ClusterInfo)

func (*K8sInformerFactoryImpl) CleanNamespaceInformer

func (impl *K8sInformerFactoryImpl) CleanNamespaceInformer(clusterName string)

func (*K8sInformerFactoryImpl) GetLatestNamespaceListGroupByCLuster

func (impl *K8sInformerFactoryImpl) GetLatestNamespaceListGroupByCLuster() map[string]map[string]bool