Versions in this module Expand all Collapse all v2 v2.0.14 Oct 26, 2024 Changes in this version + func New(cnf *config.Config, host, password, socketPath string, db int) iface.Broker + func NewGR(cnf *config.Config, addrs []string, db int) iface.Broker + type Broker struct + func (b *Broker) GetDelayedTasks() ([]*tasks.Signature, error) + func (b *Broker) GetPendingTasks(queue string) ([]*tasks.Signature, error) + func (b *Broker) Publish(ctx context.Context, signature *tasks.Signature) error + func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error) + func (b *Broker) StopConsuming() + type BrokerGR struct + func (b *BrokerGR) GetDelayedTasks() ([]*tasks.Signature, error) + func (b *BrokerGR) GetPendingTasks(queue string) ([]*tasks.Signature, error) + func (b *BrokerGR) Publish(ctx context.Context, signature *tasks.Signature) error + func (b *BrokerGR) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error) + func (b *BrokerGR) StopConsuming()
Go to main page