package controller

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

Package controller contains code for syncing cloud instances with minion registry

Index ¶

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

Types ¶

type MinionController ¶

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

func NewMinionController ¶

func NewMinionController(
	cloud cloudprovider.Interface,
	matchRE string,
	minions []string,
	staticResources *api.NodeResources,
	kubeClient client.Interface) *MinionController

NewMinionController returns a new minion controller to sync instances from cloudprovider.

func (*MinionController) Run ¶

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

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

func (*MinionController) SyncCloud ¶

func (s *MinionController) SyncCloud() error

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

func (*MinionController) SyncStatic ¶

func (s *MinionController) 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 minioncontroller.go