ruststream_fred/
lib.rs

1//! Redis / Valkey broker implementation for `RustStream`, backed by [`fred`].
2//!
3//! This crate implements the `RustStream` broker contract over Redis Streams: durable consumer
4//! groups with acknowledgement, redelivery, and crash recovery. Subjects are stream keys; a
5//! subscription reads through a consumer group, either off the fresh tail
6//! ([`RedisStream::new`]) or reclaiming another consumer's stale pending entries
7//! ([`RedisStream::reclaim`]).
8//!
9//! Settlement follows the republish-retry model: `ack` is `XACK`, `nack(requeue = true)` re-appends
10//! a copy to the same stream then acks the original, and `nack(requeue = false)` acks to drop.
11//!
12//! [`fred`]: https://docs.rs/fred
13
14#![forbid(unsafe_code)]
15
16mod broker;
17mod convert;
18mod deadletter;
19mod delay;
20mod envelope;
21mod error;
22mod list;
23mod message;
24mod publisher;
25mod pubsub;
26mod recovery;
27mod stream;
28mod subscriber;
29
30/// Optional typed per-delivery context exposing native Redis metadata by compile-time key.
31pub mod context;
32
33pub use broker::RedisBroker;
34pub use deadletter::{DEAD_LETTER_REASON_HEADER, DELIVERY_COUNT_HEADER, IDLE_MS_HEADER};
35pub use delay::DelayedRetry;
36pub use error::RedisError;
37pub use list::{RedisList, RedisListMessage, RedisListPublisher, RedisListSubscriber};
38pub use message::{PARTITION_KEY_HEADER, RedisMessage};
39pub use publisher::RedisPublisher;
40pub use pubsub::{
41    PubSubMode, RedisPubSub, RedisPubSubMessage, RedisPubSubPublisher, RedisPubSubSubscriber,
42};
43pub use stream::{RedisStream, StreamStart};
44pub use subscriber::RedisSubscriber;
45
46// fred auth/TLS types re-exported for the `RedisBroker::tls` / `::credential_provider` builders, so
47// callers need not depend on `fred` directly to name them.
48#[cfg(feature = "credential-provider")]
49pub use fred::types::config::CredentialProvider;
50#[cfg(any(
51    feature = "tls-rustls",
52    feature = "tls-rustls-ring",
53    feature = "tls-native-tls"
54))]
55pub use fred::types::config::{TlsConfig, TlsConnector};
56
57#[cfg(feature = "testing")]
58pub mod testing;
ruststream_fred/lib.rs

ruststream_fred/
lib.rs
