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) Sync() 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) Sync ¶

func (s *MinionController) Sync() error

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

Source Files ¶

doc.go minioncontroller.go