task

type CmdMeta struct {
	WorkPath string `json:"work_path"`
	Command  string `json:"command"`
	// TaskID/InvocationID appears only when Command is CANCEL/STOP/PAUSE
	TaskID       string `json:"task_id"`
	InvocationID string `json:"invocation_id"`
}

type Output struct {
	ExitCode int    `json:"exit_code"`
	StdOut   string `json:"std_out"`
	StdErr   string `json:"std_err"`
}

type PullTaskRequestBody struct {
	InvokeScope string `json:"invoke_scope"`
	Resources   string `json:"resources"`
}

type PullTaskRespBody struct {
	Tasks []TaskPulled `json:"tasks"`
}

type ReplyTask struct {
	TaskID       string `json:"task_id"`
	InvocationID string `json:"invocation_id"`
	Status       string `json:"status"`
	// ErrNum indicates the internal error in our system, not the return code of certain execution
	ErrNum string `json:"err_no"`
	Output string `json:"output"`
}

type ReplyTaskRequestBody struct {
	InstanceID string      `json:"instance_id"`
	Tasks      []ReplyTask `json:"tasks"`
}

type ReplyTaskRespBody struct {
	SucceededList []string `json:"succeeded_list"`
	FailedList    []string `json:"failed_list"`
}

type Task struct {
	TaskPulled         *TaskPulled
	Cron               *cron.Cron
	TaskExecEntityList *list.List
}

type TaskCancel struct {
	TaskPulled *TaskPulled
}

type TaskEventProcessor struct{}

type TaskExecEntity struct {
	TaskInterface

	TaskPulled   *TaskPulled
	EventChan    chan string
	ExitCodeChan chan int
	ExitChan     chan bool
	OutputChan   chan *string
	Output       *string
	State        string
	States       *list.List
	Events       *list.List
}

type TaskInterface interface {
	// Blocking
	Run(chan int, chan *string) error
	// Unblocking
	Pause() error
	Cancel() error
	CarryOn() error
}

type TaskPulled struct {
	TaskID       string  `json:"task_id"`
	InvocationID string  `json:"invocation_id"`
	Name         string  `json:"name"`
	Description  string  `json:"description"`
	Command      string  `json:"command"`
	CmdMeta      CmdMeta `json:"cmd_meta"`
	Cron         string  `json:"cron"`
	Timeout      int     `json:"timeout"`
	Type         string  `json:"type"`
}

type TaskRunShell struct {
	TaskPulled *TaskPulled
	CMD        *exec.Cmd
}