Skip to main content

Module consumer_group

reddb_server::storage::queue

Module consumer_group 

Source
Expand description

Consumer Groups for Queue

Multiple consumers can read from the same queue. Each consumer group tracks which messages have been delivered and acknowledged.

Structsยง

ConsumerGroup
A consumer group manages message delivery and acknowledgment for a set of consumers reading from the same queue.
ConsumerState
Consumer state within a group
PendingEntry
A pending message awaiting acknowledgment