kubernetes/pkg/kubemark/controller.go

const namespaceKubemark …

const nodeGroupLabel …

const numRetries …

type KubemarkController …

type externalCluster …

type kubemarkCluster …

// NewKubemarkController creates KubemarkController using the provided clients to talk to external
// and kubemark clusters.
func NewKubemarkController(externalClient kubeclient.Interface, externalInformerFactory informers.SharedInformerFactory,
	kubemarkClient kubeclient.Interface, kubemarkNodeInformer informersv1.NodeInformer) (*KubemarkController, error) { … }

// WaitForCacheSync waits until all caches in the controller are populated.
func (kubemarkController *KubemarkController) WaitForCacheSync(stopCh chan struct{ … }

// Run populates the node template needed for creation of kubemark nodes and
// starts the worker routine for creating new nodes.
func (kubemarkController *KubemarkController) Run(stopCh chan struct{ … }

// GetNodeNamesForNodeGroup returns list of the nodes in the node group.
func (kubemarkController *KubemarkController) GetNodeNamesForNodeGroup(nodeGroup string) ([]string, error) { … }

// GetNodeGroupSize returns the current size for the node group as observed.
func (kubemarkController *KubemarkController) GetNodeGroupSize(nodeGroup string) (int, error) { … }

// GetNodeGroupTargetSize returns the size of the node group as a sum of current
// observed size and number of upcoming nodes.
func (kubemarkController *KubemarkController) GetNodeGroupTargetSize(nodeGroup string) (int, error) { … }

// SetNodeGroupSize changes the size of node group by adding or removing nodes.
func (kubemarkController *KubemarkController) SetNodeGroupSize(nodeGroup string, size int) error { … }

// GetNodeGroupForNode returns the name of the node group to which the node
// belongs.
func (kubemarkController *KubemarkController) GetNodeGroupForNode(node string) (string, error) { … }

func (kubemarkController *KubemarkController) addNodeToNodeGroup(nodeGroup string) error { … }

func (kubemarkController *KubemarkController) RemoveNodeFromNodeGroup(nodeGroup string, node string) error { … }

func (kubemarkController *KubemarkController) getReplicationControllerByName(name string) *apiv1.ReplicationController { … }

func (kubemarkController *KubemarkController) getPodByName(name string) *apiv1.Pod { … }

func (kubemarkController *KubemarkController) getNodeNameForPod(podName string) (string, error) { … }

// getNodeTemplate returns the template for hollow node replication controllers
// by looking for an existing hollow node specification. This requires at least
// one kubemark node to be present on startup.
func (kubemarkController *KubemarkController) getNodeTemplate() (*apiv1.ReplicationController, error) { … }

func (kubemarkController *KubemarkController) runNodeCreation(stop <-chan struct{ … }

func (kubemarkCluster *kubemarkCluster) getHollowNodeName() (string, error) { … }

func (kubemarkCluster *kubemarkCluster) removeUnneededNodes(oldObj interface{ … }

func (kubemarkCluster *kubemarkCluster) markNodeForDeletion(name string) { … }

func newReplicationControllerInformer(kubeClient kubeclient.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer { … }

func newPodInformer(kubeClient kubeclient.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer { … }