multicluster

Documentation

Index

• Constants
• func WatchKubeConfigs(ctx context.Context, kube kubernetes.Interface, cache cache.KubeCoreCache) (<-chan v1.KubeConfigList, <-chan error, error)
• type ClusterHandler
• type KubeConfigWatcher
  • func NewKubeConfigWatcher() KubeConfigWatcher
• type RestConfigHandler
  • func NewRestConfigHandler(kcWatcher KubeConfigWatcher, handlers ...ClusterHandler) *RestConfigHandler
  • func (h *RestConfigHandler) Run(ctx context.Context, local *rest.Config, kubeClient kubernetes.Interface, ...) (<-chan error, error)
• type RestConfigs

Constants

const LocalCluster = ""

empty ClusterId refers to local

Functions

func WatchKubeConfigs

func WatchKubeConfigs(ctx context.Context, kube kubernetes.Interface, cache cache.KubeCoreCache) (<-chan v1.KubeConfigList, <-chan error, error)

Types

type ClusterHandler

type ClusterHandler interface {
	ClusterAdded(cluster string, restConfig *rest.Config)
	ClusterRemoved(cluster string, restConfig *rest.Config)
}

type KubeConfigWatcher

type KubeConfigWatcher interface {
	WatchKubeConfigs(ctx context.Context, kube kubernetes.Interface, cache cache.KubeCoreCache) (<-chan v1.KubeConfigList, <-chan error, error)
}

func NewKubeConfigWatcher

func NewKubeConfigWatcher() KubeConfigWatcher

type RestConfigHandler

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

func NewRestConfigHandler

func NewRestConfigHandler(kcWatcher KubeConfigWatcher, handlers ...ClusterHandler) *RestConfigHandler

func (*RestConfigHandler) Run

func (h *RestConfigHandler) Run(ctx context.Context, local *rest.Config, kubeClient kubernetes.Interface, kubeCache cache.KubeCoreCache) (<-chan error, error)

type RestConfigs

type RestConfigs map[string]*rest.Config