Versions in this module Expand all Collapse all v1 v1.0.1 May 8, 2021 v1.0.0 May 8, 2021 Changes in this version + type C struct + Executor *Executor + MetricsPort int + type Executor struct + Jobs chan *Job + Name string + Stop chan struct{} + func DefaultExecutor() (*Executor, error) + func NewExecutor(name string, jobChan chan *Job, stopChan chan struct{}) (*Executor, error) + func (e *Executor) Run() + type Job struct + Count int + Frequency time.Duration + Function interface{} + LastRun time.Time + Name string + NextDeadline time.Time + NextRun time.Time + Params []interface{} + Timeout time.Duration + func NewJob(name string, frequency string, timeout string, function interface{}, ...) *Job + type Scheduler struct + ExecutorName *string + IsRunning bool + Jobs []*Job + MetricsServer *http.Server + func NewScheduler(config C) (*Scheduler, error) + func (s *Scheduler) Add(j *Job) + func (s *Scheduler) AddMany(jobs []*Job) + func (s *Scheduler) CleanUp() + func (s *Scheduler) Start() + func (s *Scheduler) StartAsync() + func (s *Scheduler) Stop() + func (s *Scheduler) StopMetricsServer()