clusterregistry

Documentation

Index

• type Multicluster
  • func NewMulticluster(kc kubernetes.Interface, secretNamespace string, watchedNamespaces string, ...) (*Multicluster, error)
  • func (m *Multicluster) AddMemberCluster(clientset kubernetes.Interface, clusterID string) error
  • func (m *Multicluster) DeleteMemberCluster(clusterID string) error

Types

type Multicluster

type Multicluster struct {
	WatchedNamespaces string
	DomainSuffix      string
	ResyncPeriod      time.Duration

	XDSUpdater model.XDSUpdater
	// contains filtered or unexported fields
}

Multicluster structure holds the remote kube Controllers and multicluster specific attributes.

func NewMulticluster

func NewMulticluster(kc kubernetes.Interface, secretNamespace string,
	watchedNamespaces string, domainSuffix string, resycnPeriod time.Duration,
	serviceController *aggregate.Controller, xds model.XDSUpdater, meshNetworks *meshconfig.MeshNetworks) (*Multicluster, error)

NewMulticluster initializes data structure to store multicluster information It also starts the secret controller

func (*Multicluster) AddMemberCluster

func (m *Multicluster) AddMemberCluster(clientset kubernetes.Interface, clusterID string) error

AddMemberCluster is passed to the secret controller as a callback to be called when a remote cluster is added. This function needs to set up all the handlers to watch for resources being added, deleted or changed on remote clusters.

func (*Multicluster) DeleteMemberCluster

func (m *Multicluster) DeleteMemberCluster(clusterID string) error

DeleteMemberCluster is passed to the secret controller as a callback to be called when a remote cluster is deleted. Also must clear the cache so remote resources are removed.