impl

Documentation

Index

• func NewTasks(s *structs.AppCtx) tasks.ITasks
• type Tasks
  • func (t *Tasks) CreateAsyncTask(ctx context.Context, funcAPIName string, params map[string]interface{}) (int64, error)
  • func (t *Tasks) CreateDistributedTask(ctx context.Context, dataset interface{}, handlerFunc string, ...) (int64, error)

Functions

func NewTasks

func NewTasks(s *structs.AppCtx) tasks.ITasks

Types

type Tasks

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

func (*Tasks) CreateAsyncTask

func (t *Tasks) CreateAsyncTask(ctx context.Context, funcAPIName string, params map[string]interface{}) (int64, error)

func (*Tasks) CreateDistributedTask

func (t *Tasks) CreateDistributedTask(ctx context.Context, dataset interface{}, handlerFunc string, progressCallbackFunc string, completedCallbackFunc string, options *tasks.Options) (int64, error)

CreateDistributedTask *

• 创建分布式任务
• @param dataset 待处理数据组成的数组
• @param handlerFunc 用于处理数据集的全局函数的 API name
• @param progressCallbackFunc 任务进度发生变化时回调的全局函数的 API name，可通过传入 "" 跳过此步骤
• @param completedCallbackFunc 任务完成时回调的全局函数的 API name，可通过传入 "" 跳过此步骤
• @param options 高级配置参数，可选