taskframework

type TaskExecutor struct {

	// 是否统计失败队列
	IsFailedDeque bool
	// contains filtered or unexported fields
}

type TaskInfo struct {
	// contains filtered or unexported fields
}

type TaskInfoItem struct {
	Info *TaskInfo
	Unit TaskUnit
}

type TaskUnit interface {
	SetTaskInfo(info *TaskInfo)
	// 执行任务
	Run() (result *TaskUnitRunResult)
	// 重试任务执行的方法
	// 当达到最大重试次数, 执行失败
	OnRetry(lastRunResult *TaskUnitRunResult)
	// 每次执行成功执行的方法
	OnSuccess(lastRunResult *TaskUnitRunResult)
	// 每次执行失败执行的方法
	OnFailed(lastRunResult *TaskUnitRunResult)
	// 每次执行结束执行的方法, 不管成功失败
	OnComplete(lastRunResult *TaskUnitRunResult)
	// 重试等待的时间
	RetryWait() time.Duration
}

type TaskUnitRunResult struct {
	Succeed   bool // 是否执行成功
	NeedRetry bool // 是否需要重试

	// 以下是额外的信息
	Err           error       // 错误信息
	ResultCode    int         // 结果代码
	ResultMessage string      // 结果描述
	Extra         interface{} // 额外的信息
}