routines

Documentation

Index

• Constants
• Variables
• type Scheduler
  • func NewScheduler(db *pg.DB, maxConcurrentWorkers int, host string, retry int) *Scheduler
  • func (s *Scheduler) Run(interval time.Duration)
  • func (s *Scheduler) Trigger(id int64) error
  • func (s *Scheduler) UpdateRoutines() error

Constants

const (
	NotificationsMqttPath = "notifications"
	EventsMqttPath        = "events"

	QosAtMostOnce  = 0
	QosAtLeastOnce = 1
	QosExactlyOnce = 2
)

Variables

var (
	ErrRoutineNotFound = errors.New("routine not found")
)

Types

type Scheduler

type Scheduler struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Scheduler holds the routines and their triggers. When a trigger event is raised

func NewScheduler

func NewScheduler(db *pg.DB, maxConcurrentWorkers int, host string, retry int) *Scheduler

func (*Scheduler) Run

func (s *Scheduler) Run(interval time.Duration)

Run will periodically check at the specified interval rate if actions should run. Let's say interval is 10 seconds, this means that every 10 seconds we'll check if an action should run.

func (*Scheduler) Trigger

func (s *Scheduler) Trigger(id int64) error

func (*Scheduler) UpdateRoutines

func (s *Scheduler) UpdateRoutines() error