tasksdk

type ScheduleData struct {
	TraceId string
	ErrMsg  string
	Cost    string
}

type ScheduleLog struct {
	LastData     ScheduleData
	HistoryDatas []ScheduleData
}

type TaskBase struct {
	Id               uint64
	TaskId           string
	UserId           string
	Status           int
	TaskType         string
	TaskStage        string
	TaskContext      string
	CrtRetryNum      int
	MaxRetryNum      int
	MaxRetryInterval int
	ScheduleLog      *ScheduleLog
	ContextIntf      interface{}
	Priority         int64
	OrderTime        int64
	CreateTime       time.Time
	ModifyTime       time.Time
}

type TaskHandler struct {
	TaskType string
	NewProc  func() TaskIntf // NewProc是一个函数，返回一个TaskIntf
}

type TaskIntf interface {
	ContextLoad() error
	HandleProcess() error
	SetTask() error
	HandleFinish()
	HandleFinishError() error
	Base() *TaskBase
	CreateTask() (string, error)
	HandleFailedMust() error
}

type TaskMgr struct {
	InternelTime  time.Duration
	TaskType      string
	ScheduleLimit int
}