taskframework

Apr 29, 2022

Changes in this version

type TaskUnit

+ OnCancel func(lastRunResult *TaskUnitRunResult)

type TaskUnitRunResult

+ Cancel bool

Oct 24, 2021

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