watch

Documentation

Index

• type ClusterEvent
• type ClusterEventType
• type MultiClusterInformers
  • func NewMultiClusterInformers(kubeconfig *rest.Config) *MultiClusterInformers
  • func (w *MultiClusterInformers) ClusterClients(clusterName string) (*klient.ClusterClients, error)
  • func (w *MultiClusterInformers) ClusterEvent(eventType ClusterEventType, cluster *cluster.Cluster)
  • func (w *MultiClusterInformers) Pods(ns string, matchLabels map[string]string) ([]*corev1.Pod, error)
  • func (w *MultiClusterInformers) SetupPodsEventHandler(h cache.ResourceEventHandler)
  • func (w *MultiClusterInformers) SetupStockClusterFetcher(fetchStockCluster func(ctx context.Context) []*cluster.Cluster)
  • func (w *MultiClusterInformers) Start(ctx context.Context)
• type Watcher
  • func NewWatcher(kcs *klient.LocalClients, mci *MultiClusterInformers) (*Watcher, error)
  • func (w *Watcher) SetupApplicationsEventHandler(h cache.ResourceEventHandler)
  • func (w *Watcher) SetupImagesEventHandler(h cache.ResourceEventHandler)
  • func (w *Watcher) SetupPodsEventHandler(h cache.ResourceEventHandler)
  • func (w *Watcher) Start(ctx context.Context)

Types

type ClusterEvent

type ClusterEvent struct {
	Type        ClusterEventType
	ClusterName string
}

type ClusterEventType

type ClusterEventType string

const (
	ClusterEventAddon   ClusterEventType = "addon"
	ClusterEventRemoved ClusterEventType = "removed"
)

type MultiClusterInformers

type MultiClusterInformers struct {
	sync.Map
	// contains filtered or unexported fields
}

func NewMultiClusterInformers

func NewMultiClusterInformers(kubeconfig *rest.Config) *MultiClusterInformers

func (*MultiClusterInformers) ClusterClients

func (w *MultiClusterInformers) ClusterClients(clusterName string) (*klient.ClusterClients, error)

func (*MultiClusterInformers) ClusterEvent

func (w *MultiClusterInformers) ClusterEvent(eventType ClusterEventType, cluster *cluster.Cluster)

func (*MultiClusterInformers) Pods

func (w *MultiClusterInformers) Pods(ns string, matchLabels map[string]string) ([]*corev1.Pod, error)

func (*MultiClusterInformers) SetupPodsEventHandler

func (w *MultiClusterInformers) SetupPodsEventHandler(h cache.ResourceEventHandler)

func (*MultiClusterInformers) SetupStockClusterFetcher

func (w *MultiClusterInformers) SetupStockClusterFetcher(fetchStockCluster func(ctx context.Context) []*cluster.Cluster)

func (*MultiClusterInformers) Start

func (w *MultiClusterInformers) Start(ctx context.Context)

type Watcher

type Watcher struct {
	*MultiClusterInformers
	// contains filtered or unexported fields
}

func NewWatcher

func NewWatcher(kcs *klient.LocalClients, mci *MultiClusterInformers) (*Watcher, error)

func (*Watcher) SetupApplicationsEventHandler

func (w *Watcher) SetupApplicationsEventHandler(h cache.ResourceEventHandler)

func (*Watcher) SetupImagesEventHandler

func (w *Watcher) SetupImagesEventHandler(h cache.ResourceEventHandler)

func (*Watcher) SetupPodsEventHandler

func (w *Watcher) SetupPodsEventHandler(h cache.ResourceEventHandler)

func (*Watcher) Start

func (w *Watcher) Start(ctx context.Context)