background_tasks

Mar 25, 2024

Changes in this version

+ type EventTrigger struct

+ Trigger chan bool

+ func (t *EventTrigger) IsReady() bool

+ func (t *EventTrigger) Reset()

+ type Execution struct

+ EndedAt time.Time

+ Error string

+ Event interface{}

+ Results interface{}

+ StartedAt time.Time

+ Status string

+ type OneTimeTrigger struct

+ Delay time.Duration

+ func (t *OneTimeTrigger) IsReady() bool

+ func (t *OneTimeTrigger) Reset()

+ type PeriodicTrigger struct

+ CronExpr string

+ Interval time.Duration

+ func (t *PeriodicTrigger) IsReady() bool

+ func (t *PeriodicTrigger) Reset()

+ type RetryPolicy struct

+ Delay time.Duration

+ MaxRetries int

+ type Scheduler struct

+ func NewScheduler(maxRunningTasks int) *Scheduler

+ func (s *Scheduler) AddTask(task *Task) *Task

+ func (s *Scheduler) RemoveTask(taskID int)

+ func (s *Scheduler) Start()

+ func (s *Scheduler) Stop()

+ type Task struct

+ Args []interface{}

+ Description string

+ Enabled bool

+ ExecutionHist []Execution

+ Function func(args interface{}) error

+ ID int

+ Name string

+ Priority int

+ RetryPolicy RetryPolicy

+ Triggers []Trigger

+ type Trigger interface

+ IsReady func() bool

+ Reset func()