worker

Documentation

Index

• type AppendAnnotation
  • func NewAppendAnnotation(config *AppendAnnotationConfig) *AppendAnnotation
  • func (operation *AppendAnnotation) Execute() *pb.Error
• type AppendAnnotationConfig
• type AppendLabel
  • func NewAppendLabel(config *AppendLabelConfig) *AppendLabel
  • func (operation *AppendLabel) Execute() *pb.Error
• type AppendLabelConfig
• type AppendTaint
  • func NewAppendTaint(config *AppendTaintConfig) *AppendTaint
  • func (operation *AppendTaint) Execute() *pb.Error
• type AppendTaintConfig
• type CommandRunner
  • func NewCommandRunner(executeLogWriter io.Writer) *CommandRunner
  • func (runner *CommandRunner) RunCommand(command command.Command, errorTitle, doSomeThing string) *pb.Error
• type JoinCluster
  • func NewJoinCluster(config *JoinClusterConfig) *JoinCluster
  • func (operation *JoinCluster) Execute() *pb.Error
  • func (operation *JoinCluster) JoinKubernetes() *pb.Error
• type JoinClusterConfig
• type StartKubelet
  • func NewStartKubelet(config *StartKubeletConfig) *StartKubelet
  • func (operation *StartKubelet) Execute() *pb.Error
  • func (operation *StartKubelet) RunKubelet() *pb.Error
• type StartKubeletConfig

Types

type AppendAnnotation

type AppendAnnotation struct {
	operation.BaseOperation
	// contains filtered or unexported fields
}

func NewAppendAnnotation

func NewAppendAnnotation(config *AppendAnnotationConfig) *AppendAnnotation

func (*AppendAnnotation) Execute

func (operation *AppendAnnotation) Execute() *pb.Error

type AppendAnnotationConfig

type AppendAnnotationConfig struct {
	MasterMachine    deployMachine.IMachine
	Logger           *logrus.Entry
	Node             *pb.NodeDeployConfig
	Cluster          *pb.ClusterConfig
	ExecuteLogWriter io.Writer
}

type AppendLabel

type AppendLabel struct {
	operation.BaseOperation
	// contains filtered or unexported fields
}

func NewAppendLabel

func NewAppendLabel(config *AppendLabelConfig) *AppendLabel

func (*AppendLabel) Execute

func (operation *AppendLabel) Execute() *pb.Error

type AppendLabelConfig

type AppendLabelConfig struct {
	MasterMachine    deployMachine.IMachine
	Logger           *logrus.Entry
	Node             *pb.NodeDeployConfig
	Cluster          *pb.ClusterConfig
	ExecuteLogWriter io.Writer
}

type AppendTaint

type AppendTaint struct {
	operation.BaseOperation
	// contains filtered or unexported fields
}

func NewAppendTaint

func NewAppendTaint(config *AppendTaintConfig) *AppendTaint

func (*AppendTaint) Execute

func (operation *AppendTaint) Execute() *pb.Error

type AppendTaintConfig

type AppendTaintConfig struct {
	Machine          deployMachine.IMachine
	Logger           *logrus.Entry
	Node             *pb.NodeDeployConfig
	Cluster          *pb.ClusterConfig
	ExecuteLogWriter io.Writer
}

type CommandRunner

type CommandRunner struct {
	// contains filtered or unexported fields
}

func NewCommandRunner

func NewCommandRunner(executeLogWriter io.Writer) *CommandRunner

func (*CommandRunner) RunCommand

func (runner *CommandRunner) RunCommand(command command.Command, errorTitle, doSomeThing string) *pb.Error

shellCommand is run at remote command errorTitle is pb.Error.Reason when error happened doSomeThing is describe what the command done

type JoinCluster

type JoinCluster struct {
	op.BaseOperation
	// contains filtered or unexported fields
}

func NewJoinCluster

func NewJoinCluster(config *JoinClusterConfig) *JoinCluster

func (*JoinCluster) Execute

func (operation *JoinCluster) Execute() *pb.Error

func (*JoinCluster) JoinKubernetes

func (operation *JoinCluster) JoinKubernetes() *pb.Error

type JoinClusterConfig

type JoinClusterConfig struct {
	Machine          deployMachine.IMachine
	Node             *pb.NodeDeployConfig
	Logger           *logrus.Entry
	Cluster          *pb.ClusterConfig
	MasterNodes      []*pb.Node
	ExecuteLogWriter io.Writer
}

type StartKubelet

type StartKubelet struct {
	operation.BaseOperation
	// contains filtered or unexported fields
}

func NewStartKubelet

func NewStartKubelet(config *StartKubeletConfig) *StartKubelet

func (*StartKubelet) Execute

func (operation *StartKubelet) Execute() *pb.Error

func (*StartKubelet) RunKubelet

func (operation *StartKubelet) RunKubelet() *pb.Error

type StartKubeletConfig

type StartKubeletConfig struct {
	Machine          deployMachine.IMachine
	Node             *pb.NodeDeployConfig
	Logger           *logrus.Entry
	ExecuteLogWriter io.Writer
}