jobs_queue

README

Scheduled tasks/jobs queue runner

Helps to run scheduled tasks in background.

Example

JobsQueue.Functions["plus"] = func(params map[string]interface{}) (interface{}, error) {
	o1 := value.ToMapGet(params, "o1").Int()
	o2 := value.ToMapGet(params, "o2").Int()
	return o1 + o2, nil
}

JobsQueue.AddJob("plus", map[string]interface{}{"o1": 1, "o2": 2}, time.Now(), "")
JobsQueue.AddJob("plus", map[string]interface{}{"o1": 2, "o2": 3}, time.Now(), "")
JobsQueue.AddJob("plus", map[string]interface{}{"o1": 3, "o2": 4}, time.Now(), "15s")
JobsQueue.AddJob("plus", map[string]interface{}{"o1": 4, "o2": 5}, time.Now(), nil)

Documentation

Index

• type JobsQueue
  • func New(cycleSleepTime int, jobsPerCycle int, db *dbm.DB) *JobsQueue
  • func (jq *JobsQueue) AddJob(function string, params map[string]interface{}, t time.Time, ...) error
  • func (jq *JobsQueue) Restart()
  • func (jq *JobsQueue) Start()
  • func (jq *JobsQueue) Stop()

Types

type JobsQueue

type JobsQueue struct {
	DB *dbm.DB

	CycleSleepTime int // seconds
	JobsPerCycle   int
	Functions      map[string]func(map[string]interface{}) (interface{}, error)
	// contains filtered or unexported fields
}

func New

func New(cycleSleepTime int, jobsPerCycle int, db *dbm.DB) *JobsQueue

func (*JobsQueue) AddJob

func (jq *JobsQueue) AddJob(function string, params map[string]interface{}, t time.Time, repeat interface{}) error

func (*JobsQueue) Restart

func (jq *JobsQueue) Restart()

func (*JobsQueue) Start

func (jq *JobsQueue) Start()

func (*JobsQueue) Stop

func (jq *JobsQueue) Stop()