Versions in this module Expand all Collapse all v1 v1.4.2 Aug 4, 2018 v1.4.1 Jul 12, 2018 Changes in this version + func New() iface.Broker + type Broker struct + func (eagerBroker *Broker) AssignWorker(w iface.TaskProcessor) + func (eagerBroker *Broker) GetPendingTasks(queue string) ([]*tasks.Signature, error) + func (eagerBroker *Broker) Publish(task *tasks.Signature) error + func (eagerBroker *Broker) StartConsuming(consumerTag string, concurrency int, p iface.TaskProcessor) (bool, error) + func (eagerBroker *Broker) StopConsuming() + type EagerMode interface + AssignWorker func(p iface.TaskProcessor)
Go to main page