Versions in this module Expand all Collapse all v0 v0.1.0 Dec 6, 2017 Changes in this version + const UserAgentName + func GetClusterPods(client *clientset.Clientset) (allocatablePods int64, capacityPods int64, err error) + type ClusterClient struct + func NewClusterClientSet(c *federation_v1beta1.Cluster) (*ClusterClient, error) + func (self *ClusterClient) GetClusterHealthStatus() *federation_v1beta1.ClusterStatus + func (self *ClusterClient) GetClusterPods() (allocatablePods int64, capacityPods int64, err error) + func (self *ClusterClient) GetClusterZones() (zones []string, region string, err error) + type ClusterController struct + OnClusterChange ReconcileOnClusterChange + func StartClusterController(config *restclient.Config, stopChan <-chan struct{}, ...) *ClusterController + func (cc *ClusterController) GetCluster(clusterName string) (*v1beta1.Cluster, error) + func (cc *ClusterController) GetClusterClient(cluster *v1beta1.Cluster) (*ClusterClient, error) + func (cc *ClusterController) GetClusterDeployment(cluster *v1beta1.Cluster, namespace string, name string) (*extensions.Deployment, error) + func (cc *ClusterController) GetReadyClusters() ([]*v1beta1.Cluster, error) + func (cc *ClusterController) GetUnreadyClusters() ([]*v1beta1.Cluster, error) + func (cc *ClusterController) IsCapacityDataPresent(cluster *v1beta1.Cluster) bool + func (cc *ClusterController) IsClusterScaling(cluster *v1beta1.Cluster) bool + func (cc *ClusterController) IsSynced() bool + func (cc *ClusterController) Run(stopChan <-chan struct{}) + func (cc *ClusterController) UpdateCluster(cluster *v1beta1.Cluster) error + func (cc *ClusterController) UpdateClusterStatus() error + type ReconcileOnClusterChange func()