addexample

Documentation

Index

• type AddActuator
  • func (e *AddActuator) Delete(ctx context.Context, task *framework.Task) (err error)
  • func (a *AddActuator) ExportOutput(ctx context.Context, ftask *framework.Task) error
  • func (a *AddActuator) GetAsyncTaskStatus(ctx context.Context, ftasks []framework.Task) (status []framework.AsyncTaskStatus, err error)
  • func (e *AddActuator) GetOutput(ctx context.Context, task *framework.Task) (data interface{}, err error)
  • func (a *AddActuator) Init(ctx context.Context, task *framework.Task) (newTask *framework.Task, err error)
  • func (a *AddActuator) Start(ctx context.Context, ftask *framework.Task) (newTask *framework.Task, ignoreErr bool, err error)
  • func (a *AddActuator) Stop(ctx context.Context, ftask *framework.Task) error
• type AddTask

Types

type AddActuator

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

AddActuator 加法执行器，同步任务异步化的示例

func (*AddActuator) Delete

func (e *AddActuator) Delete(ctx context.Context, task *framework.Task) (err error)

GetOutput ...

func (*AddActuator) ExportOutput

func (a *AddActuator) ExportOutput(ctx context.Context, ftask *framework.Task) error

ExportOutput 导出任务输出，自行处理任务结果

func (*AddActuator) GetAsyncTaskStatus

func (a *AddActuator) GetAsyncTaskStatus(ctx context.Context, ftasks []framework.Task) (
	status []framework.AsyncTaskStatus, err error)

GetAsyncTaskStatus 批量获取任务状态

func (*AddActuator) GetOutput

func (e *AddActuator) GetOutput(ctx context.Context, task *framework.Task) (
	data interface{}, err error)

GetOutput ...

func (*AddActuator) Init

func (a *AddActuator) Init(ctx context.Context, task *framework.Task) (
	newTask *framework.Task, err error)

Init 任务在被调度前的初始化工作

func (*AddActuator) Start

func (a *AddActuator) Start(ctx context.Context, ftask *framework.Task) (
	newTask *framework.Task, ignoreErr bool, err error)

Start 执行任务

func (*AddActuator) Stop

func (a *AddActuator) Stop(ctx context.Context, ftask *framework.Task) error

Stop 停止任务

type AddTask

type AddTask struct {
	StartTime time.Time
	A, B      int32
}

AddTask add 任务结构