Documentation ¶
Index ¶
Constants ¶
View Source
const ( MemberServiceAccountName = "kubeadmiral-member" FederatedClusterUID = common.DefaultPrefix + "federated-cluster-uid" ServiceAccountTokenKey = "service-account-token-data" )
View Source
const ( ClusterJoinedReason = "ClusterJoined" ClusterJoinedMessage = "cluster has joined the federation" TokenNotObtainedReason = "TokenNotObtained" TokenNotObtainedMessage = "Service account token has not been obtained from the cluster" JoinTimeoutExceededReason = "JoinTimeoutExceeded" JoinTimeoutExceededMessageTemplate = "Timeout exceeded when joining the federation, message from last attempt: %v" ClusterUnjoinableReason = "ClusterUnjoinable" ClusterUnjoinableMessage = "Cluster is already managed by a KubeAdmiral control plane" )
View Source
const ( EventReasonJoinClusterTimeoutExceeded = "JoinClusterTimeoutExceeded" EventReasonJoinClusterError = "JoinClusterError" EventReasonJoinClusterSuccess = "JoinClusterSuccess" EventReasonClusterUnjoinable = "ClusterUnjoinable" )
View Source
const ( ClusterReadyReason = "ClusterReady" ClusterReadyMessage = "Cluster is ready" ClusterHealthzNotOKReason = "HealthzNotOK" ClusterHealthzNotOKMessage = "/healthz responded without ok" ClusterResourceCollectionFailedReason = "ClusterResourceCollectionFailed" ClusterResourceCollectionFailedMessageTemplate = "Failed to collect cluster resources: %v" ClusterAPIDiscoveryFailedReason = "ClusterAPIDiscoveryFailed" ClusterAPIDiscoveryFailedMessageTemplate = "Failed to discover cluster API resources: %v" ClusterReachableReason = "ClusterReachable" ClusterReachableMsg = "Cluster is reachable" ClusterNotReachableReason = "ClusterNotReachable" ClusterNotReachableMsg = "Cluster is not reachable" )
View Source
const ( FederatedClusterControllerName = "federated-cluster-controller" FinalizerFederatedClusterController = common.DefaultPrefix + "federated-cluster-controller" EventReasonHandleTerminatingClusterFailed = "HandleTerminatingClusterFailed" EventReasonHandleTerminatingClusterBlocked = "HandleTerminatingClusterBlocked" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterHealthCheckConfig ¶
ClusterHealthCheckConfig defines the configurable parameters for cluster health check
type FederatedClusterController ¶
type FederatedClusterController struct {
// contains filtered or unexported fields
}
FederatedClusterController reconciles a FederatedCluster object
func NewFederatedClusterController ¶
func NewFederatedClusterController( kubeClient kubeclient.Interface, fedClient fedclient.Interface, clusterInformer fedcorev1a1informers.FederatedClusterInformer, federatedInformerManager informermanager.FederatedInformerManager, metrics stats.Metrics, logger klog.Logger, workerCount int, fedSystemNamespace string, componentConfig *controllercontext.ComponentConfig, ) (*FederatedClusterController, error)
func (*FederatedClusterController) HasSynced ¶
func (c *FederatedClusterController) HasSynced() bool
func (*FederatedClusterController) IsControllerReady ¶
func (c *FederatedClusterController) IsControllerReady() bool
func (*FederatedClusterController) Run ¶
func (c *FederatedClusterController) Run(ctx context.Context)
Click to show internal directories.
Click to hide internal directories.