redis

Oct 6, 2021

Changes in this version

+ func NewGR(cnf *config.Config, addrs []string, db int) iface.Broker

type Broker

+ func (b *Broker) GetDelayedTasks() ([]*tasks.Signature, error)

+ 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()

Jul 12, 2018

Changes in this version

+ func New(cnf *config.Config, host, password, socketPath string, db int) iface.Broker

+ type Broker struct

+ func (b *Broker) GetPendingTasks(queue string) ([]*tasks.Signature, error)

+ func (b *Broker) Publish(signature *tasks.Signature) error

+ func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error)

+ func (b *Broker) StopConsuming()