manager

Documentation

Index

• Constants
• type Manager
  • func (mgr *Manager) Copy() *Manager
  • func (mgr *Manager) RunTaskOnAllNodes(task NodeTask, parallel bool) error
  • func (mgr *Manager) RunTaskOnEtcdNodes(task NodeTask, parallel bool) error
  • func (mgr *Manager) RunTaskOnK8sNodes(task NodeTask, parallel bool) error
  • func (mgr *Manager) RunTaskOnMasterNodes(task NodeTask, parallel bool) error
  • func (mgr *Manager) RunTaskOnNodes(nodes []kubekeyapi.HostCfg, task NodeTask, parallel bool) error
  • func (mgr *Manager) RunTaskOnWorkerNodes(task NodeTask, parallel bool) error
• type NodeTask
• type Task
  • func (t *Task) Run(mgr *Manager) error

Constants

const (
	DefaultCon = 10
	Timeout    = 120
)

Types

type Manager

type Manager struct {
	Cluster        *kubekeyapi.ClusterSpec
	Logger         log.FieldLogger
	Connector      *ssh.Dialer
	Runner         *runner.Runner
	AllNodes       []kubekeyapi.HostCfg
	EtcdNodes      []kubekeyapi.HostCfg
	MasterNodes    []kubekeyapi.HostCfg
	WorkerNodes    []kubekeyapi.HostCfg
	K8sNodes       []kubekeyapi.HostCfg
	ClientNode     []kubekeyapi.HostCfg
	ClusterHosts   []string
	WorkDir        string
	KsEnable       bool
	KsVersion      string
	Debug          bool
	SkipCheck      bool
	SkipPullImages bool
}

func (*Manager) Copy

func (mgr *Manager) Copy() *Manager

func (*Manager) RunTaskOnAllNodes

func (mgr *Manager) RunTaskOnAllNodes(task NodeTask, parallel bool) error

func (*Manager) RunTaskOnEtcdNodes

func (mgr *Manager) RunTaskOnEtcdNodes(task NodeTask, parallel bool) error

func (*Manager) RunTaskOnK8sNodes

func (mgr *Manager) RunTaskOnK8sNodes(task NodeTask, parallel bool) error

func (*Manager) RunTaskOnMasterNodes

func (mgr *Manager) RunTaskOnMasterNodes(task NodeTask, parallel bool) error

func (*Manager) RunTaskOnNodes

func (mgr *Manager) RunTaskOnNodes(nodes []kubekeyapi.HostCfg, task NodeTask, parallel bool) error

func (*Manager) RunTaskOnWorkerNodes

func (mgr *Manager) RunTaskOnWorkerNodes(task NodeTask, parallel bool) error

type NodeTask

type NodeTask func(mgr *Manager, node *kubekeyapi.HostCfg) error

type Task

type Task struct {
	Task   func(*Manager) error
	ErrMsg string
}

func (*Task) Run

func (t *Task) Run(mgr *Manager) error