controller

Documentation

Overview

Package controller contains code for syncing cloud instances with minion registry

Index

• type NodeController
  • func NewNodeController(cloud cloudprovider.Interface, matchRE string, nodes []string, ...) *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.