Versions in this module Expand all Collapse all v0 v0.4.0 Aug 17, 2020 Changes in this version + type DispatchCron struct + func (c *DispatchCron) Stop() type Dispatcher + func (d *Dispatcher) DispatchCron(run func(), cronStr string) (*DispatchCron, error) v0.3.1 Aug 15, 2020 Changes in this version + type DispatchTicker struct + func (dt *DispatchTicker) Stop() + type Dispatcher struct + func NewDispatcher(maxWorkers int, maxQueue int) *Dispatcher + func (d *Dispatcher) Dispatch(run func()) error + func (d *Dispatcher) DispatchEvery(run func(), interval time.Duration) (*DispatchTicker, error) + func (d *Dispatcher) DispatchIn(run func(), duration time.Duration) error + func (d *Dispatcher) Start() + func (d *Dispatcher) Stop() + type Job struct + Run func() + type Worker struct + func NewWorker(workerPool chan chan Job) *Worker + func (w Worker) Start() + func (w Worker) Stop()