cluster

Documentation

Index

• Variables
• func CallBackCmd(opt types.OperatorType, optParam interface{}, pkgServer string) string
• func CniK8sverRuntimeCmdParam(node []execute.ClusterNodes) string
• func EtcdCmdParam(node []execute.ClusterNodes) string
• func InitNodeDownloadPkgCmd(nodes []execute.ClusterNodes) string
• type Actuator
  • func NewActuator(agent provider.Agent, nodes types.Nodes, env types.Env) *Actuator
  • func (a *Actuator) EtcdDownloadPkg() bool
  • func (a Actuator) EtcdInstall() bool
  • func (a *Actuator) K8sDownloadPkgAndInstallInitMaster() bool
  • func (a *Actuator) K8sJoinOtherMastersAndWorkers() bool
  • func (a *Actuator) K8sRemoveNodes() bool
  • func (a *Actuator) K8sResetNodes() bool
  • func (a *Actuator) K8sScaleNodes() bool
  • func (a *Actuator) SSHAuth() bool

Variables

var ClusterName = os.Getenv("PWC_NAME")

var (
	DownloadPkgTimeout = time.Duration(timeout) * time.Second
)

Functions

func CallBackCmd

func CallBackCmd(opt types.OperatorType, optParam interface{}, pkgServer string) string

func CniK8sverRuntimeCmdParam

func CniK8sverRuntimeCmdParam(node []execute.ClusterNodes) string

func EtcdCmdParam

func EtcdCmdParam(node []execute.ClusterNodes) string

func InitNodeDownloadPkgCmd

func InitNodeDownloadPkgCmd(nodes []execute.ClusterNodes) string

Types

type Actuator

type Actuator struct {
	Agent      provider.Agent
	Nodes      []execute.ClusterNodes
	Env        types.Env
	Concurrent *execute.Concurrent
}

func NewActuator

func NewActuator(agent provider.Agent, nodes types.Nodes, env types.Env) *Actuator

func (*Actuator) EtcdDownloadPkg

func (a *Actuator) EtcdDownloadPkg() bool

func (Actuator) EtcdInstall

func (a Actuator) EtcdInstall() bool

func (*Actuator) K8sDownloadPkgAndInstallInitMaster

func (a *Actuator) K8sDownloadPkgAndInstallInitMaster() bool

func (*Actuator) K8sJoinOtherMastersAndWorkers

func (a *Actuator) K8sJoinOtherMastersAndWorkers() bool

func (*Actuator) K8sRemoveNodes

func (a *Actuator) K8sRemoveNodes() bool

需要考虑某个节点既是master又是worker的情况

func (*Actuator) K8sResetNodes

func (a *Actuator) K8sResetNodes() bool

func (*Actuator) K8sScaleNodes

func (a *Actuator) K8sScaleNodes() bool

func (*Actuator) SSHAuth

func (a *Actuator) SSHAuth() bool