aion_server/stream/
mod.rs

1//! Event subscription streaming surfaces.
2
3/// WS3 cluster topology/ownership subscription serving.
4pub mod cluster_stream;
5/// Namespace-aware event gating at the broadcast/encode seam.
6pub mod namespace_filter;
7/// Replay/live splice for per-workflow subscription resumption.
8pub mod resume;
9/// Server-side workflow-type/status selector filtering.
10pub mod selector;
11/// WebSocket frame encoding and subscription forwarding helpers.
12pub mod socket;
13/// Event subscription request mapping and store subscription helpers.
14pub mod subscribe;
15/// NOI-5b agent-observability transcript subscription serving.
16pub mod transcript_stream;
17
18pub use cluster_stream::serve_cluster_socket;
19pub use namespace_filter::{GateVerdict, NamespaceEventGate};
20pub use resume::RESUME_CURSOR_AHEAD_OF_HISTORY;
21pub use selector::SubscriptionSelector;
22pub use socket::{
23    EncodedEventStream, EncodedFrame, SEQUENCE_CONTIGUITY_VIOLATION, forward_subscription,
24    handle_subscription_socket,
25};
26pub use subscribe::{
27    EventSubscription, MappedSubscription, map_subscription_request, subscribe_events,
28};
29pub(crate) use transcript_stream::gate_transcript_workflow;
30pub use transcript_stream::serve_transcript_socket;
aion_server/stream/mod.rs

aion_server/stream/
mod.rs
