ruststream-fred 0.4.1

Redis / Valkey broker implementation (Streams) for the RustStream messaging framework, backed by fred.
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

//! In-process Redis test driver used by handler integration tests.
//!
//! Gated by the `testing` cargo feature. The broker is a synchronous dispatcher: `publish` fans the
//! message out to every subscriber whose stream key matches exactly. Public surface:
//!
//! * [`RedisTestBroker`] - `Broker` impl backed by an in-process key router;
//! * [`RedisTestPublisher`] - `Publisher`;
//! * [`RedisTestSubscriber`] / [`RedisTestMessage`] - `Subscriber` and `IncomingMessage` impls with
//!   `nack(requeue = true)` redelivery (re-sent into the same subscriber's queue);
//! * [`RedisTestClient`] - `TestClient` driver consumed by the conformance harness.
//!
//! No `redis-server`, no docker, no network. Broker-specific edge cases (consumer-group cursors,
//! `XAUTOCLAIM` redelivery, idle reclaim, `MAXLEN` trimming, dead-letter routing) are out of scope
//! here. Exercise them against a real Redis server.

mod broker;
mod client;
mod publisher;
mod router;
mod subscriber;

pub use broker::RedisTestBroker;
pub use client::RedisTestClient;
pub use publisher::RedisTestPublisher;
pub use subscriber::{RedisTestMessage, RedisTestSubscriber};