jobqueue

Oct 11, 2019

Changes in this version

+ type JobEntry interface

+ Name func() string

+ Run func()

+ type JobQueue struct

+ func Default() JobQueue

+ func (jobQueue JobQueue) Every(duration time.Duration, job JobEntry)

+ func (jobQueue JobQueue) In(duration time.Duration, job JobEntry)

+ func (jobQueue JobQueue) Now(job JobEntry)

+ func (jobQueue JobQueue) Remove(id cron.EntryID)

+ func (jobQueue JobQueue) Schedule(spec string, job JobEntry) error

+ func (jobQueue JobQueue) Start(pool int, concurrent int)

+ func (jobQueue JobQueue) Stop()

+ func (jobqueue JobQueue) StatusJSON() map[string]interface{}