impl

package
v0.0.13 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 13, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 高级配置参数,可选

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL