task

type Option struct {
	TaskRenewTick time.Duration
}

type Scheduler struct {
	WaitGroup util.WaitGroupWrapper

	Tasks Tasks
	Raft  *raft.Raft
	// contains filtered or unexported fields
}

type Task struct {
	Name            string               `json:"name"`
	Cmd             string               `json:"cmd"`
	CronLine        string               `json:"cron_line"`
	PlanExecTime    time.Time            `json:"-"`
	CronExpression  *cronexpr.Expression `json:"-"`
	Status          int                  `json:"-"`
	NodeID          string               `json:"-"`
	IP              string               `json:"-"`
	ActualStartTime time.Time            `json:"-"`
	ActualEndTime   time.Time            `json:"-"`
	Result          []byte               `json:"-"`
}

type Tasks interface {
	heap.Interface
	Remove(name string)
	Top() interface{}
}