queue

Nov 4, 2017

Changes in this version

+ type Config struct

+ Delay time.Duration

+ Workers int

+ func NewConfig() *Config

+ func (c *Config) Load(configReporter config.Reporter) error

+ func (c *Config) Validate() error

+ type Queue struct

+ func New(cfg *Config, lgr log.Logger, str store.Store) (*Queue, error)

+ func (q *Queue) RegisterRunner(runner Runner) error

+ func (q *Queue) Start()

+ func (q *Queue) Stop()

+ type Runner interface

+ CanRunTask func(tks *task.Task) bool

+ Run func(ctx context.Context, tsk *task.Task)