gocron

Jan 4, 2023

Changes in this version

type Job

+ MaxMetricsDataLen int

+ func (s *Job) MetricsRunData() (d []MetricsRunDataItem)

type JobItem

+ RawJob *Job

+ type MetricsRunDataItem struct

+ EndAt time.Time

+ Skipped bool

+ StartAt time.Time

Dec 30, 2022

Changes in this version

type JobItem

+ TriggerCount uint64

Dec 29, 2022

Changes in this version

type JobItem

+ Mutex bool

Dec 28, 2022

Changes in this version

+ var DefaultLogger = NewLogger()

+ func AddJob(job Job) (jobID int, err error)

+ func HandlerFilter(job Job) func(ctx gcore.Ctx) error

+ func HandlerFunc() http.HandlerFunc

+ func NewLogger() *logger

+ func RemoveJob(jobID int) (err error)

+ func SetHandlerFilter(handlerFilter func(ctx gcore.Ctx) error)

+ func TriggerJob(jobID int)

+ type CrontabManager struct

+ func NewCrontabManager() *CrontabManager

+ func (s *CrontabManager) AddJob(job Job) (jobID int, err error)

+ func (s *CrontabManager) ExistsJob(jobID int) bool

+ func (s *CrontabManager) GetJob(jobID int) (jobItem *JobItem)

+ func (s *CrontabManager) HandlerFilter() func(ctx gcore.Ctx) error

+ func (s *CrontabManager) HandlerFunc() http.HandlerFunc

+ func (s *CrontabManager) JobList() (jobItems []*JobItem)

+ func (s *CrontabManager) RemoveJob(jobID int) (err error)

+ func (s *CrontabManager) SetHandlerFilter(handlerFilter func(ctx gcore.Ctx) error)

+ func (s *CrontabManager) Start() *CrontabManager

+ func (s *CrontabManager) Stop() *CrontabManager

+ func (s *CrontabManager) TriggerJob(jobID int) (err error)

+ type Job struct

+ CronExp string

+ Description string

+ Executor func()

+ Mutex bool

+ TriggerAt time.Time

+ type JobItem struct

+ CronExp string

+ Description string

+ JobID int

+ NextAt int64

+ PrevAt int64

+ RunningCount int64

+ TriggerAt int64

+ func GetJob(jobID int) (jobItem *JobItem)

+ func JobList() []*JobItem