Documentation ¶
Index ¶
- 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
- 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
- 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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Broker ¶
type Broker struct { common.Broker common.RedisConnector // contains filtered or unexported fields }
Broker represents a Redis broker
func (*Broker) GetDelayedTasks ¶ added in v1.7.7
GetDelayedTasks returns a slice of task signatures that are scheduled, but not yet in the queue
func (*Broker) GetPendingTasks ¶
GetPendingTasks returns a slice of task signatures waiting in the queue
func (*Broker) StartConsuming ¶
func (b *Broker) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error)
StartConsuming enters a loop and waits for incoming messages
type BrokerGR ¶ added in v1.7.7
BrokerGR represents a Redis broker
func (*BrokerGR) GetDelayedTasks ¶ added in v1.7.7
GetDelayedTasks returns a slice of task signatures that are scheduled, but not yet in the queue
func (*BrokerGR) GetPendingTasks ¶ added in v1.7.7
GetPendingTasks returns a slice of task signatures waiting in the queue
func (*BrokerGR) StartConsuming ¶ added in v1.7.7
func (b *BrokerGR) StartConsuming(consumerTag string, concurrency int, taskProcessor iface.TaskProcessor) (bool, error)
StartConsuming enters a loop and waits for incoming messages
func (*BrokerGR) StopConsuming ¶ added in v1.7.7
func (b *BrokerGR) StopConsuming()
StopConsuming quits the loop
Click to show internal directories.
Click to hide internal directories.