Version: v1.2.0 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jan 28, 2021 License: Apache-2.0 Imports: 6 Imported by: 0




This section is empty.


View Source
var ControllerRegistry map[string]*ClusterController

ControllerRegistry manages all controllers created for each cluster. When a new Cluster found, create controller for it and add its stop channel to this registry if not exist. When a Cluster removed, close the channel in this map, and delete the key.

View Source
var NewClusterChan chan *ClusterController

NewClusterChan is channels for clusters that got created.


func GetClusterClient

func GetClusterClient(name string) kubernetes.Interface

GetClusterClient gets cluster client with the given cluster name

func RegisterClusterController

func RegisterClusterController(cluster *v1alpha1.ExecutionCluster) error

RegisterClusterController register a cluster to this registry.

func RemoveClusterController

func RemoveClusterController(cluster *v1alpha1.ExecutionCluster) error

RemoveClusterController stop and remove cluster from this registry.


type ClusterController

type ClusterController struct {
	// Cluster ...
	Cluster *v1alpha1.ExecutionCluster
	// Cluster client
	Client kubernetes.Interface
	// Channel that can be used to stop the controller
	StopCh chan struct{}

ClusterController ...

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL