rskit-messaging 0.1.0-alpha.2

Message broker abstractions, registry, middleware, and in-memory adapter
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

//! # rskit-messaging
//!
//! Message broker abstractions with an in-memory implementation for testing.
//! Broker SDKs live in opt-in adapter crates such as `rskit-messaging-kafka`.
//!
//! ## Quick start
//!
//! ```rust
//! use rskit_messaging::memory::InMemoryBroker;
//! use rskit_messaging::{Message, MessageProducer, MessageConsumer};
//!
//! # #[tokio::main] async fn main() -> Result<(), Box<dyn std::error::Error>> {
//! let broker = InMemoryBroker::<String>::new(64);
//! let producer = broker.producer();
//! let consumer = broker.consumer();
//!
//! consumer.subscribe(&["events"]).await?;
//! producer.send(Message::new("events", "hello".into())).await?;
//!
//! let msg = consumer.recv().await?;
//! assert_eq!(msg.payload, "hello");
//! # Ok(())
//! # }
//! ```

pub mod batch;
pub mod bridge;
pub mod config;
pub mod errors;
pub mod event;
pub mod event_publisher;
pub mod handler;
pub mod managed_consumer;
pub mod managed_producer;
pub mod memory;
pub mod message;
pub mod metrics;
pub mod middleware;
pub mod registry;
pub mod router;
pub mod runner;
pub mod traits;
pub mod translator;

pub use batch::{BatchConfig, BatchProducer};
pub use config::{
    BrokerConfig, BrokerConfigExt, BrokerConfigOverrides, CommitStrategy, DeliveryGuarantee,
    DlqPolicy,
};
pub use errors::{ErrorClassifier, NoopErrorClassifier};
pub use event::Event;
pub use event_publisher::EventPublisher;
pub use handler::{FnHandler, HandlerMiddleware, MessageHandler, chain_handlers, middleware_fn};
pub use managed_consumer::{ManagedConsumer, ManagedConsumerBuilder};
pub use managed_producer::{ManagedProducer, ManagedProducerBuilder};
pub use memory::{
    InMemoryBroker, InMemoryConsumer, InMemoryProducer, assert_no_messages, assert_published,
    assert_published_n, wait_for_message,
};
pub use message::Message;
pub use metrics::{MetricsCollector, NoopMetrics};
pub use middleware::StackBuilder;
pub use registry::{MessagingBackend, MessagingFactory, MessagingRegistry};
pub use router::MessageRouter;
pub use runner::ConsumerRunner;
pub use traits::{BrokerComponent, EventConsumer, EventProducer, MessageConsumer, MessageProducer};
pub use translator::{JsonStringTranslator, JsonTranslator, MessageTranslator};