Documentation

Overview

    Package cluster contains code for syncing cluster

    Index

    Constants

    View Source
    const (
    	UserAgentName = "Cluster-Controller"
    )

    Variables

    This section is empty.

    Functions

    func StartClusterController

    func StartClusterController(config *restclient.Config, stopChan <-chan struct{}, clusterMonitorPeriod time.Duration)

      StartClusterController starts a new cluster controller

      Types

      type ClusterClient

      type ClusterClient struct {
      	// contains filtered or unexported fields
      }

      func NewClusterClientSet

      func NewClusterClientSet(c *federation_v1beta1.Cluster) (*ClusterClient, error)

      func (*ClusterClient) GetClusterHealthStatus

      func (self *ClusterClient) GetClusterHealthStatus() *federation_v1beta1.ClusterStatus

        GetClusterHealthStatus gets the kubernetes cluster health status by requesting "/healthz"

        func (*ClusterClient) GetClusterZones

        func (self *ClusterClient) GetClusterZones() (zones []string, region string, err error)

          GetClusterZones gets the kubernetes cluster zones and region by inspecting labels on nodes in the cluster.

          type ClusterController

          type ClusterController struct {
          	// contains filtered or unexported fields
          }

          func (*ClusterController) GetClusterClient

          func (cc *ClusterController) GetClusterClient(cluster *federationv1beta1.Cluster) (*ClusterClient, error)

          func (*ClusterController) GetClusterStatus

          func (*ClusterController) Run

          func (cc *ClusterController) Run(stopChan <-chan struct{})

            Run begins watching and syncing.

            func (*ClusterController) UpdateClusterStatus

            func (cc *ClusterController) UpdateClusterStatus() error

              UpdateClusterStatus checks cluster status and get the metrics from cluster's restapi