Versions in this module Expand all Collapse all v0 v0.0.3 Feb 18, 2022 Changes in this version + const DEFAULT_JOB_POOL_SIZE + const UNNAMED + type Func func() + func (r Func) Run() + type ItaskMana interface + Every func(duration time.Duration, job cron.Job) + FindTask func(jobId string) (ok bool) + In func(duration time.Duration, job cron.Job) + Now func(job cron.Job) + Remove func(jobId string) + Schedule func(spec string, jobId string, job cron.Job) (id cron.EntryID, err error) + Start func(v ...int) + StatusJson func() map[string]interface{} + Stop func() + func NewTask() ItaskMana + type Job struct + Latency string + Name string + Status string + func New(job cron.Job) *Job + func (j *Job) Run() + func (j *Job) StatusUpdate() string + type StatusData struct + Id cron.EntryID + JobRunner *Job + Next string + Prev string + type TaskMana struct + MainCron *cron.Cron + Name map[string]cron.EntryID + func (t *TaskMana) Entries() []cron.Entry + func (t *TaskMana) Every(duration time.Duration, job cron.Job) + func (t *TaskMana) FindTask(jobId string) (ok bool) + func (t *TaskMana) In(duration time.Duration, job cron.Job) + func (t *TaskMana) Now(job cron.Job) + func (t *TaskMana) Remove(jobId string) + func (t *TaskMana) Schedule(spec string, jobId string, job cron.Job) (id cron.EntryID, err error) + func (t *TaskMana) Start(v ...int) + func (t *TaskMana) StatusJson() map[string]interface{} + func (t *TaskMana) StatusPage() []StatusData + func (t *TaskMana) Stop()
Go to main page