Versions in this module Expand all Collapse all v0 v0.4.159 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()