celers-kombu 0.2.0

Broker abstraction layer for CeleRS (inspired by Python Kombu)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

//! Broker abstraction layer (Kombu-style)
//!
//! This crate provides the abstract interface for message brokers, inspired by
//! Python's Kombu library. It defines the core traits that all broker implementations
//! must follow.
//!
//! # Architecture
//!
//! - **Transport**: Low-level broker connection (Redis, AMQP, SQS, Database)
//! - **Producer**: Message publishing interface
//! - **Consumer**: Message consuming interface
//! - **Queue**: Queue abstraction with routing
//! - **BatchProducer**: Batch message publishing interface
//! - **BatchConsumer**: Batch message consuming interface
//! - **HealthCheck**: Health monitoring interface
//! - **Metrics**: Metrics collection interface
//! - **Admin**: Broker administration interface

mod backpressure;
mod circuit_breaker;
mod connection;
mod dlq;
mod error;
mod exchange;
mod health;
mod middleware;
mod middleware_advanced;
mod middleware_basic;
mod middleware_extended;
mod middleware_monitoring;
mod mock;
mod priority;
mod queue_mode;
mod quota;
mod retry;
mod scheduler;
mod types;

pub mod utils;

// Re-export everything from submodules to preserve the public API
pub use backpressure::*;
pub use circuit_breaker::*;
pub use connection::*;
pub use dlq::*;
pub use error::*;
pub use exchange::*;
pub use health::*;
pub use middleware::*;
pub use middleware_advanced::*;
pub use middleware_basic::*;
pub use middleware_extended::*;
pub use middleware_monitoring::*;
pub use mock::*;
pub use priority::*;
pub use queue_mode::*;
pub use quota::*;
pub use retry::*;
pub use scheduler::*;
pub use types::*;

#[cfg(test)]
mod tests;
#[cfg(test)]
mod tests_advanced;
#[cfg(test)]
mod tests_middleware;