AGScheduler

type Controller struct {
	Ctx      context.Context
	Deadline context.Context
	Cancel   context.CancelFunc
}

type CronState struct {
	CronCmd string `json:"cron_cmd"`
}

type CronTrigger struct {
	CronCmd   string
	StartTime time.Time
	Schedule  cron.Schedule
}

type DateState struct {
	RunDateTime time.Time `json:"run_date_time"`
}

type DateTrigger struct {
	RunDateTime time.Time
}

type IStore interface {
	GetDueTasks(now time.Time) []*Task
	GetTaskByName(name string) (*Task, error)
	GetAllTasks() []*Task
	AddTask(task *Task) error
	DelTask(task *Task) error
	UpdateTask(task *Task) error
	GetNextRunTime() time.Time
}

type ITrigger interface {
	NextFireTime(previous, now time.Time) time.Time
	GetTriggerState() TriggerState
}

type IntervalState struct {
	StartRunTime time.Time     `json:"start_run_time"`
	EndRunTime   time.Time     `json:"end_run_time"`
	Interval     time.Duration `json:"interval"`
}

type IntervalTrigger struct {
	Interval     time.Duration
	StartRunTime time.Time
	EndRunTime   time.Time
}

type MemoryStore struct {
	Tasks    *list.List
	TasksMap map[string]*list.Element
}

type PgStore struct {
	Pg     *pg.DB
	Logger *logrus.Entry
}

type Scheduler struct {
	StoresMap   map[string]IStore
	Logger      *logrus.Entry
	Controller  *Controller
	CloseCancel context.CancelFunc
}

type Task struct {
	Id              int64                     `json:"id" pg:",pk"`
	Name            string                    `json:"name" pg:",use_zero"`
	WorkKey         string                    `json:"work_key" pg:",use_zero"`
	Func            func(args ...interface{}) `json:"func" pg:"-"`
	Args            []interface{}             `json:"args" pg:",use_zero"`
	Scheduler       *Scheduler                `json:"scheduler" pg:"-"`
	Trigger         ITrigger                  `json:"trigger" pg:"-"`
	TriggerState    TriggerState              `json:"trigger_state" pg:",use_zero"`
	PreviousRunTime time.Time                 `json:"previous_run_time" pg:",use_zero"`
	NextRunTime     time.Time                 `json:"next_run_time" pg:",use_zero"`
	Logger          *logrus.Entry             `json:"logger" pg:"-"`
	Running         bool                      `json:"running" pg:",use_zero"`
	Coalesce        bool                      `json:"coalesce" pg:",use_zero"`
	Count           int64                     `json:"count" pg:",use_zero"`
}

type TriggerState struct {
	Name     string        `json:"name"`
	Cron     CronState     `json:"cron"`
	Date     DateState     `json:"date"`
	Interval IntervalState `json:"interval"`
}

type WorkDetail struct {
	Func func(args ...interface{})
	Args []interface{}
}