Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Tasks ¶
type Tasks struct {
// contains filtered or unexported fields
}
func (*Tasks) CreateAsyncTask ¶
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 高级配置参数,可选
Click to show internal directories.
Click to hide internal directories.