Versions in this module Expand all Collapse all v1 v1.0.0 Mar 23, 2021 Changes in this version + type BrokerBroadcast struct + func New(cnf *config.Config, addrs []string, db int) *BrokerBroadcast + func NewWithOptions(cnf *config.Config, addrs []string, db int, opts ...Option) *BrokerBroadcast + func (b *BrokerBroadcast) Publish(ctx context.Context, signature *tasks.Signature) error + func (b *BrokerBroadcast) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error) + func (b *BrokerBroadcast) StopConsuming() + type BrokerGR struct + func (b *BrokerGR) GetDelayedTasks() ([]*tasks.Signature, error) + func (b *BrokerGR) GetPendingTasks(queue string) ([]*tasks.Signature, error) + type Option func(broadcast *BrokerBroadcast) + func WithBroadcastHeaderKey(key string) Option + func WithRedisBroadcastTasksKey(key string) Option
Go to main page