taskexecutor

Documentation

Index

• Constants
• Variables
• func Register(name string, executor Executor)
• type BaseExecutor
  • func NewBaseExecutor(name string, methods map[string]func(types.NodeTaskRequest) fsm.Event) *BaseExecutor
  • func (be *BaseExecutor) Do(taskReq types.NodeTaskRequest) (fsm.Event, error)
  • func (be *BaseExecutor) Name() string
• type Executor
  • func GetExecutor(name string) (Executor, error)
  • func NewPrePullExecutor() Executor
  • func NewUpgradeExecutor() Executor
• type PrePull
  • func (p *PrePull) Name() string
• type Upgrade
  • func (u *Upgrade) Name() string

Constants

const (
	MaxCPUUsage  float64 = 80
	MaxMemUsage  float64 = 80
	MaxDiskUsage float64 = 80
)

const (
	TaskPrePull = "prepull"
)

const (
	TaskUpgrade = "upgrade"
)

Variables

var (
	CommonMethods = map[string]func(types.NodeTaskRequest) fsm.Event{
		string(v1alpha1.TaskChecking): preCheck,
		string(v1alpha1.TaskInit):     normalInit,
	}
)

Functions

func Register

func Register(name string, executor Executor)

Types

type BaseExecutor

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

func NewBaseExecutor

func NewBaseExecutor(name string, methods map[string]func(types.NodeTaskRequest) fsm.Event) *BaseExecutor

func (*BaseExecutor) Do

func (be *BaseExecutor) Do(taskReq types.NodeTaskRequest) (fsm.Event, error)

func (*BaseExecutor) Name

func (be *BaseExecutor) Name() string

type Executor

type Executor interface {
	Name() string
	Do(types.NodeTaskRequest) (fsm.Event, error)
}

func GetExecutor

func GetExecutor(name string) (Executor, error)

func NewPrePullExecutor

func NewPrePullExecutor() Executor

func NewUpgradeExecutor

func NewUpgradeExecutor() Executor

type PrePull

type PrePull struct {
	*BaseExecutor
}

func (*PrePull) Name

func (p *PrePull) Name() string

type Upgrade

type Upgrade struct {
	*BaseExecutor
}

func (*Upgrade) Name

func (u *Upgrade) Name() string