Skip to main content

Module queue

Module queue 

Source
Expand description

Queue / Deque Storage Module

FIFO/LIFO message queue with:

  • Push/Pop from both ends (deque)
  • Consumer groups with acknowledgment
  • Dead-letter queue support
  • Priority queue mode
  • Per-message TTL

Modules§

consumer_group
Consumer Groups for Queue
deque
Core Queue / Deque implementation
mode

Structs§

ConsumerGroup
A consumer group manages message delivery and acknowledgment for a set of consumers reading from the same queue.
PendingEntry
A pending message awaiting acknowledgment
QueueStore
Core queue data structure supporting FIFO, LIFO, and priority modes.

Enums§

QueueMode
QueueSide
Which end of the queue to push/pop from