Versions in this module Expand all Collapse all v1 v1.0.1 Jan 31, 2024 Changes in this version + func CancelTask(taskId taskmodel.TaskIdType) error + func CreateTask(taskType uint32, param *taskmodel.TaskParam) (taskmodel.TaskIdType, error) + func GetTaskStatus(taskId taskmodel.TaskIdType, status *taskmodel.TaskStatusData) error + func Join() error + func NotifyStop() error + func PauseTask(taskId taskmodel.TaskIdType) error + func RegisterTaskType(register *taskplugin.TaskPluginRegistration) error + func ResumeTask(taskId taskmodel.TaskIdType) error + func StartService(role dtfdef.ServiceRole, opts ...ServiceOption) error + func Version() string + type ServiceOption func(config *dtfdef.ServiceConfig) + func WithCollector(collector taskmodel.CollectorInvoker) ServiceOption + func WithExecutor(executor taskmodel.ExecutorInvoker) ServiceOption + func WithMongoDB(mongo *extconfig.MongoAddress) ServiceOption + func WithMySQL(mysql *extconfig.MySQLAddress) ServiceOption + func WithPrestop(d time.Duration) ServiceOption + func WithRedis(redis *extconfig.RedisAddress) ServiceOption + func WithRegisterCollectorHandler(register taskmodel.RegisterCollectorRequestHandler) ServiceOption + func WithRegisterExecutorHandler(register taskmodel.RegisterExecutorRequestHandler) ServiceOption v1.0.0 Jan 31, 2024