aster_forge_events/
lib.rs

1//! Product-neutral transient event transport primitives.
2//!
3//! This crate owns broker connection lifecycle, reconnect backoff, shutdown cancellation, and
4//! raw payload delivery. Products own payload schemas, authorization, origin filtering, and the
5//! local event semantics built on top of the transport.
6
7mod supervisor;
8mod transient_bus;
9
10#[cfg(feature = "redis")]
11mod redis_transport;
12
13pub use supervisor::{
14    EventConnectionObservation, EventConnectionState, EventReconnectPolicy,
15    EventSubscriptionSource, EventSubscriptionUpdate, supervise_event_subscription,
16};
17pub use transient_bus::TransientEventBus;
18
19#[cfg(feature = "redis")]
20pub use redis_transport::{
21    EventConnectionObserver, RedisEventBus, RedisEventBusError, RedisEventReconnectPolicy,
22    RedisEventSubscription,
23};
aster_forge_events/lib.rs

aster_forge_events/
lib.rs
