Documentation
¶
Overview ¶
Package redis provides a Redis Streams-backed broker.Broker with at-least-once delivery and explicit Ack. Subscribers sharing a queue form a consumer group that load-balances messages; unacknowledged messages can be reclaimed later.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Options ¶
type Options struct {
// Addr is the Redis address used when Client is nil.
Addr string
// Client is a preconfigured Redis client.
Client redis.UniversalClient
}
Options configures the Redis broker.
Source Files
Click to show internal directories.
Click to hide internal directories.