async_task

type IReport interface {
	// Phase 上报运行阶段，bool表示finished/failed是否删除任务记录
	Phase() (RunPhase, bool)
	// Context 上报上下文
	Context() string
}

type ITask interface {
	// Running 任务执行，任务接收到stop消息后，须主动Report，之后退出即可
	Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan IReport
	// Deleting 删除任务
	Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan IReport
}

type ITaskFunc func() ITask

type RunPhase int32

type State int32

type Task struct {
	ID        uint32
	User      string
	Group     string
	Type      uint32
	State     State
	CreatedAt int64
	DoneAt    int64
	Ctx       string
}