Documentation ¶
Index ¶
- func AfterTaskCompleted(taskRecord *dbdef.DBTaskRecord) error
- 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 MonitorCompletedTask()
- func MonitorTaskTableRoutine()
- func MonitorTaskTimeout()
- func PauseTask(taskId taskmodel.TaskIdType) error
- func RefillTaskParam(taskId taskmodel.TaskIdType, taskParam *taskmodel.TaskParam) error
- func RemoveFromRunningList(taskId taskmodel.TaskIdType) error
- func ResumeTask(taskId taskmodel.TaskIdType) error
- func TaskCreationRoutine(taskId taskmodel.TaskIdType, taskType uint32, taskParam *taskmodel.TaskParam)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AfterTaskCompleted ¶
func AfterTaskCompleted(taskRecord *dbdef.DBTaskRecord) error
任务完成时,执行任务类型的完成回调
func CreateTask ¶
创建任务
func GetTaskStatus ¶
func GetTaskStatus(taskId taskmodel.TaskIdType, status *taskmodel.TaskStatusData) error
查询任务的运行状态
func RefillTaskParam ¶
func RefillTaskParam( taskId taskmodel.TaskIdType, taskParam *taskmodel.TaskParam, ) error
重新填写任务结构
func RemoveFromRunningList ¶
func RemoveFromRunningList(taskId taskmodel.TaskIdType) error
从运行中任务列表中删除任务
func TaskCreationRoutine ¶
func TaskCreationRoutine( taskId taskmodel.TaskIdType, taskType uint32, taskParam *taskmodel.TaskParam, )
任务创建协程
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.