Versions in this module Expand all Collapse all v2 v2.0.14 Oct 26, 2024 Changes in this version + func New() iface.Broker + type Broker struct + func (eagerBroker *Broker) AssignWorker(w iface.TaskProcessor) + func (eagerBroker *Broker) Publish(ctx context.Context, task *tasks.Signature) error + func (eagerBroker *Broker) StartConsuming(consumerTag string, concurrency int, p iface.TaskProcessor) (bool, error) + func (eagerBroker *Broker) StopConsuming() + type Mode interface + AssignWorker func(p iface.TaskProcessor)
Go to main page