reddb_server/storage/queue/mod.rs
1//! Queue / Deque Storage Module
2//!
3//! FIFO/LIFO message queue with:
4//! - Push/Pop from both ends (deque)
5//! - Consumer groups with acknowledgment
6//! - Dead-letter queue support
7//! - Priority queue mode
8//! - Per-message TTL
9
10pub mod consumer_group;
11pub mod deque;
12pub(crate) mod lifecycle;
13pub mod mode;
14pub mod presence;
15
16pub use consumer_group::{ConsumerGroup, PendingEntry};
17pub use deque::{QueueSide, QueueStore};
18pub use mode::QueueMode;
19pub use presence::{
20 ConsumerPresence, ConsumerPresenceRegistry, PresenceState, DEFAULT_PRESENCE_TTL_MS,
21};