Versions in this module Expand all Collapse all v1 v1.0.3 May 3, 2020 v1.0.2 May 2, 2020 Changes in this version + var TaskUnitRunResultSuccess = &TaskUnitRunResult + type TaskExecutor struct + IsFailedDeque bool + func NewTaskExecutor() *TaskExecutor + func (te *TaskExecutor) Append(unit TaskUnit, maxRetry int) *TaskInfo + func (te *TaskExecutor) AppendNoRetry(unit TaskUnit) + func (te *TaskExecutor) Count() int + func (te *TaskExecutor) Execute() + func (te *TaskExecutor) FailedDeque() *lane.Deque + func (te *TaskExecutor) Pause() + func (te *TaskExecutor) Resume() + func (te *TaskExecutor) SetParallel(parallel int) + func (te *TaskExecutor) Stop() + type TaskInfo struct + func (t *TaskInfo) Id() string + func (t *TaskInfo) IsExceedRetry() bool + func (t *TaskInfo) MaxRetry() int + func (t *TaskInfo) Retry() int + func (t *TaskInfo) SetMaxRetry(maxRetry int) + type TaskInfoItem struct + Info *TaskInfo + Unit TaskUnit + type TaskUnit interface + OnComplete func(lastRunResult *TaskUnitRunResult) + OnFailed func(lastRunResult *TaskUnitRunResult) + OnRetry func(lastRunResult *TaskUnitRunResult) + OnSuccess func(lastRunResult *TaskUnitRunResult) + RetryWait func() time.Duration + Run func() (result *TaskUnitRunResult) + SetTaskInfo func(info *TaskInfo) + type TaskUnitRunResult struct + Err error + Extra interface{} + NeedRetry bool + ResultCode int + ResultMessage string + Succeed bool