controller

Documentation

Overview

Package controller contains code for syncing cloud instances with minion registry

Index

• type MinionController
  • func NewMinionController(cloud cloudprovider.Interface, matchRE string, minions []string, ...) *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.