package controller

import "k8s.io/kubernetes/pkg/cloudprovider/controller"

Package controller contains code for syncing cloud instances with minion registry

Index ¶

• type NodeController
• func NewNodeController( cloud cloudprovider.Interface, matchRE string, nodes []string, staticResources *api.NodeResources, kubeClient client.Interface) *NodeController
• func (s *NodeController) Run(period time.Duration)
• func (s *NodeController) SyncCloud() error
• func (s *NodeController) SyncStatic(period time.Duration) error

Types ¶

type NodeController ¶

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

func NewNodeController ¶

func NewNodeController(
	cloud cloudprovider.Interface,
	matchRE string,
	nodes []string,
	staticResources *api.NodeResources,
	kubeClient client.Interface) *NodeController

NewNodeController returns a new node controller to sync instances from cloudprovider.

func (*NodeController) Run ¶

func (s *NodeController) Run(period time.Duration)

Run starts syncing instances from cloudprovider periodically, or create initial node list.

func (*NodeController) SyncCloud ¶

func (s *NodeController) SyncCloud() error

SyncCloud syncs list of instances from cloudprovider to master etcd registry.

func (*NodeController) SyncStatic ¶

func (s *NodeController) SyncStatic(period time.Duration) error

SyncStatic registers list of machines from command line flag. It returns after successful registration of all machines.

Source Files ¶

doc.go nodecontroller.go