cronext

Sep 9, 2022

Changes in this version

type Job

+ func (jb *Job) SetTask(task TaskWithHistory) error

type RamHistoryService

+ Inited time.Time

+ type TaskWithHistory func(lastRuntime time.Time) error

Aug 22, 2022

Changes in this version

+ const EventJobFinished

type Job

+ Bus EventBus.Bus

Jun 13, 2022

Changes in this version

type JobHistory

+ Message string

+ Succeed bool

Jun 8, 2022

Changes in this version

+ type Job struct

+ Hs JobHistoryService

+ Job string

+ Logger *zap.Logger

+ Scheduler string

+ func (jb *Job) PrintNextRuntime()

+ func (jb *Job) Schedule(cmd func()) error

+ func (jb *Job) WithHistory() cron.JobWrapper

+ type JobHistory struct

+ Duration time.Duration

+ Finished time.Time

+ Job string

+ Start time.Time

+ type JobHistoryService interface

+ GetLastRuntime func(job string) (time.Time, error)

+ ToHistory func(job JobHistory) error

+ type RamHistoryService struct

+ Logger *zap.Logger

+ func (a *RamHistoryService) GetLastRuntime(job string) (time.Time, error)

+ func (a *RamHistoryService) ToHistory(job JobHistory) error