Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
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.
Functions ¶
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.
Types ¶
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 ...
Source Files
Click to show internal directories.
Click to hide internal directories.