tasks

Documentation

Index

• type DispatcherConfig
  • func (c DispatcherConfig) DispatchTask() error
• type ParallelTask
  • func NewParallelTask(timeoutSecond int) *ParallelTask
  • func (t *ParallelTask) AddTask(tasks ...Task)
  • func (t *ParallelTask) AddTaskOperator(operators ...TaskOperator)
  • func (t *ParallelTask) Start() error
• type Params
• type SyncTask
  • func NewSyncTask(timeoutSecond int) *SyncTask
  • func (t *SyncTask) AddTask(tasks ...Task)
  • func (t *SyncTask) AddTaskOperator(operators ...TaskOperator)
  • func (t *SyncTask) Start() error
• type Task
• type TaskOperator
• type TaskWrapper

Types

type DispatcherConfig

type DispatcherConfig struct {
	//任务超时秒数
	Timeout int
	// 预处理任务
	Prepare []string
	// 编排任务
	Tasks []TaskWrapper
}

多任务配置 每个元素都是独立的执行命令

func (DispatcherConfig) DispatchTask

func (c DispatcherConfig) DispatchTask() error

type ParallelTask

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

并行任务

func NewParallelTask

func NewParallelTask(timeoutSecond int) *ParallelTask

func (*ParallelTask) AddTask

func (t *ParallelTask) AddTask(tasks ...Task)

添加任务

func (*ParallelTask) AddTaskOperator

func (t *ParallelTask) AddTaskOperator(operators ...TaskOperator)

func (*ParallelTask) Start

func (t *ParallelTask) Start() error

启动任务

type Params

type Params map[string]interface{}

type SyncTask

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

同步任务

func NewSyncTask

func NewSyncTask(timeoutSecond int) *SyncTask

func (*SyncTask) AddTask

func (t *SyncTask) AddTask(tasks ...Task)

添加任务

func (*SyncTask) AddTaskOperator

func (t *SyncTask) AddTaskOperator(operators ...TaskOperator)

func (*SyncTask) Start

func (t *SyncTask) Start() error

启动任务

type Task

type Task func(id int) error

type TaskOperator

type TaskOperator interface {
	AddTask(tasks ...Task)
	AddTaskOperator(operators ...TaskOperator)
	Start() error
}

任务操作接口

type TaskWrapper

type TaskWrapper struct {
	// type只能是sync(同步执行任务)、parallel(并行执行任务)
	Type string
	Cmds []string
}

任务