Documentation ¶ Index ¶ type Manager func NewManager(txer database.Txer, maxJob, workerN int) (*Manager, error) func (m *Manager) Add(job job.Job) <-chan error func (m *Manager) ExchangeManager(exm *exchange.Manager) *Manager func (m *Manager) Pubsuber(hub pubsub.Pubsuber) *Manager func (m *Manager) Start() error func (m *Manager) Stores(stores *store.Stores) *Manager Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Manager ¶ type Manager struct { *sync.Mutex // contains filtered or unexported fields } func NewManager ¶ func NewManager(txer database.Txer, maxJob, workerN int) (*Manager, error) func (*Manager) Add ¶ added in v0.4.0 func (m *Manager) Add(job job.Job) <-chan error func (*Manager) ExchangeManager ¶ added in v0.4.0 func (m *Manager) ExchangeManager(exm *exchange.Manager) *Manager func (*Manager) Pubsuber ¶ added in v0.4.0 func (m *Manager) Pubsuber(hub pubsub.Pubsuber) *Manager func (*Manager) Start ¶ func (m *Manager) Start() error func (*Manager) Stores ¶ added in v0.4.0 func (m *Manager) Stores(stores *store.Stores) *Manager Source Files ¶ View all Source files queue.go Directories ¶ Show internal Expand all Path Synopsis job Click to show internal directories. Click to hide internal directories.