scheduler

Jun 16, 2021

Changes in this version

type Scheduler

+ func (s *Scheduler) NextRun(jobID cron.EntryID) (time.Time, error)

Jun 8, 2021

Changes in this version

+ const RunNow

+ type Job struct

+ Context context.Context

+ End context.CancelFunc

+ ID cron.EntryID

+ RunCount int

+ Task tasks.Task

+ type Scheduler struct

+ func New() *Scheduler

+ func NewWithSeconds() *Scheduler

+ func (s *Scheduler) Add(cronExp string, task tasks.Task, maxRunTime, scheduleLimit time.Duration, ...) (cron.EntryID, error)

+ func (s *Scheduler) Close(ctx context.Context)

+ func (s *Scheduler) Remove(jobID cron.EntryID)

+ func (s *Scheduler) RunChan() <-chan Job