jobqueue

Documentation

Index

• type JobEntry
• type JobQueue
  • 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(poolSize int, concurrency int)
  • func (jobqueue JobQueue) StatusJSON() map[string]interface{}
  • func (jobQueue JobQueue) Stop()

Types

type JobEntry

type JobEntry interface {
	Run()
	Name() string
}

type JobQueue

type JobQueue struct{}

func Default

func Default() JobQueue

func (JobQueue) Every

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

func (JobQueue) In

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

func (JobQueue) Now

func (jobQueue JobQueue) Now(job JobEntry)

func (JobQueue) Remove

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

func (JobQueue) Schedule

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

func (JobQueue) Start

func (jobQueue JobQueue) Start(poolSize int, concurrency int)

func (JobQueue) StatusJSON

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

func (JobQueue) Stop

func (jobQueue JobQueue) Stop()