task

type Awaken struct {
	Task       Task
	OverLapped *Task
}

type Context struct {
	context.Context
	// contains filtered or unexported fields
}

type Desc struct {
	TaskKey  string
	ExecDesc ExecConfig
	Tags     []string
	Overlap  bool
}

type ExecConfig struct {
	ExpectStartTime time.Time     `bson:"expectRetryTime"`
	MaxExecDuration time.Duration `bson:"maxExecDuration"`
	RemainExecCount int32         `bson:"remainExec"`
	Priority        int32         `bson:"priority"`
}

type ExecResult struct {
	ResultInfo string     `bson:"resultInfo"`
	ResultCode int64      `bson:"resultCode"`
	NextExec   ExecConfig `bson:"next,omitempty"`
}

type ExecSummery struct {
	CurrentIndex   int32
	ExpectExecTime time.Time
	MaxDuration    time.Duration
}

type Execution struct {
	Available  bool
	Config     ExecConfig `bson:"config"`
	CreateTime time.Time  `bson:"createTime,omitempty"`
	StartTime  time.Time  `bson:"startTime,omitempty"`
	EndTime    time.Time  `bson:"endTime,omitempty"`
	Result     ExecResult `bson:"result,omitempty"`
}

type Executor interface {
	StartExecution(cb Context) error
}

type FuncExecutor func(cb Context) error

type Info struct {
	Tags       []string   `bson:"tags"`
	ExecConfig ExecConfig `bson:"execDesc"`
	CreateTime time.Time  `bson:"createTime"`
	ExecCount  int32      `bson:"execCount"`
}

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

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

type Profile struct {
	TaskKey    string
	Status     StatusCode
	Executions []Execution
}

type Schedule struct {
	AwakenTime time.Time
	Priority   int32
}

type Scheduler interface {
	ScheduleTask(ctx context.Context, task Task, overlap bool) (Task, error)
	CloseTaskSchedule(ctx context.Context, task Task) error
	WaitTaskAwaken(ctx context.Context) (awaken Awaken, err error)
	ReadTask(ctx context.Context, taskKey string) (*Task, error)
	NewStageID(ctx context.Context, taskKey string) (stageID int64, err error)
	Close(ctx context.Context) error
}

type StatusCode int

type StatusProfile struct {
	Total    int64     `json:"total"`
	Count    int64     `json:"count"`
	Profiles []Profile `json:"profile"`
}

type Summery struct {
	StatusCount map[StatusCode]int64
}

type Task struct {
	Key       string    `bson:"_id"`
	Stage     int64     `bson:"stage"`
	Schedule  Schedule  `bson:"schedule"`
	Info      Info      `bson:"info"`
	Execution Execution `bson:"execution"`
}