executor

Documentation

Index

• Variables
• func GetOrAddTaskStatusChM(name string) chan Task
• func Init()
• func Push2TaskStatusCh(task Task)
• type Executor
  • func NewCrdExecutor() Executor
• type Task

Variables

var (
	// ErrTaskNotExists is returned when we can't find specific task from istio
	ErrTaskNotExists = errors.New("task isn't exists")
)

var (
	// ErrUnknownCmd defines invalid command error
	ErrUnknownCmd = errors.New("unknown command")
)

var (
	// TaskStatusChM stores task execution result into a channel map
	TaskStatusChM = make(map[string]chan Task)
)

Functions

func GetOrAddTaskStatusChM

func GetOrAddTaskStatusChM(name string) chan Task

GetOrAddTaskStatusChM returns task channel from taskStatusChM group by operator, if channel is not exists, we makes a new one then return it.

func Init

func Init()

Init initializes executor package.

func Push2TaskStatusCh

func Push2TaskStatusCh(task Task)

Push2TaskStatusCh pushes task into taskStatusChM.

Types

type Executor

type Executor interface {
	Execute(Task) error
}

Executor will dispatch and execute task from channel.

var DefaultExecutor Executor

DefaultExecutor defines default task executor.

func NewCrdExecutor

func NewCrdExecutor() Executor

NewCrdExecutor returns a istiocrd executor.

type Task

type Task = model.Task

Task is an alias of model.Task