Skip to main content

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 mod context;
15
16pub use broker::NatsBroker;
17pub use error::NatsError;
18pub use message::{CoreMessage, JetStreamMessage, NatsMessage, PARTITION_KEY_HEADER};
19pub use publisher::NatsPublisher;
20pub use subscribe_options::{DeliverPolicy, SubscribeOptions};
21pub use subscriber::NatsSubscriber;
22
23#[cfg(feature = "testing")]
24pub mod testing;