Versions in this module Expand all Collapse all v0 v0.1.3 Aug 26, 2019 v0.1.2 Apr 9, 2019 Changes in this version type Task + Tags func() map[string]string v0.1.0 Feb 23, 2019 Changes in this version + var ErrManagerClosed = errors.New("manager closed") + var ErrTaskExists = errors.New("task already exists in store") + var ErrTaskNotFound = errors.New("task not found") + type Config struct + IncomingBuffer int + MaxTaskThroughput time.Duration + NumIncomingWorkers int + NumRetryWorkers int + PollRetriesInterval time.Duration + RetryBuffer int + RetryInterval time.Duration + Testing bool + type Executor interface + Exec func(Task) error + Name func() string + type Manager interface + Add func(Task) error + Close func() + Find func(query interface{}) ([]Task, error) + SyncExec func(Task) error + func NewManager(config Config, stats tally.Scope, store Store, executor Executor) (Manager, error) + type Store interface + AddFailed func(Task) error + AddPending func(Task) error + Find func(query interface{}) ([]Task, error) + GetFailed func() ([]Task, error) + GetPending func() ([]Task, error) + MarkFailed func(Task) error + MarkPending func(Task) error + Remove func(Task) error + type Task interface + GetFailures func() int + GetLastAttempt func() time.Time + Ready func() bool