ruststream_nats/lib.rs
1//! `NATS` / `JetStream` broker implementation for `RustStream`.
2
3#![forbid(unsafe_code)]
4
5mod broker;
6mod convert;
7mod error;
8mod message;
9mod publisher;
10mod request_reply;
11mod subscribe_options;
12mod subscriber;
13
14pub use broker::NatsBroker;
15pub use error::NatsError;
16pub use message::{CoreMessage, JetStreamMessage, NatsMessage, PARTITION_KEY_HEADER};
17pub use publisher::NatsPublisher;
18pub use subscribe_options::{DeliverPolicy, SubscribeOptions};
19pub use subscriber::NatsSubscriber;
20
21#[cfg(feature = "testing")]
22pub mod testing;