Module stream 

WebSocket event-streaming support. Event subscription streaming surfaces.

Re-exports

pub use cluster_stream::serve_cluster_socket;

pub use namespace_filter::GateVerdict;

pub use namespace_filter::NamespaceEventGate;

pub use resume::RESUME_CURSOR_AHEAD_OF_HISTORY;

pub use selector::SubscriptionSelector;

pub use socket::EncodedEventStream;

pub use socket::EncodedFrame;

pub use socket::SEQUENCE_CONTIGUITY_VIOLATION;

pub use socket::forward_subscription;

pub use socket::handle_subscription_socket;

pub use subscribe::EventSubscription;

pub use subscribe::MappedSubscription;

pub use subscribe::map_subscription_request;

pub use subscribe::subscribe_events;

pub use transcript_stream::serve_transcript_socket;

Modules

cluster_stream

WS3 cluster topology/ownership subscription serving. WS3 cluster subscription: deploy-gated snapshot + live-delta forward loop.

namespace_filter

Namespace-aware event gating at the broadcast/encode seam. Namespace-aware event gating at the broadcast/encode seam.

resume

Replay/live splice for per-workflow subscription resumption. Replay/live splice for per-workflow subscription resumption.

selector

Server-side workflow-type/status selector filtering. Server-side selector filtering for filtered subscriptions.

socket

WebSocket frame encoding and subscription forwarding helpers. WebSocket forward loop + lag handling.

subscribe

Event subscription request mapping and store subscription helpers. SubscriptionRequest to EventFilter mapping.

transcript_stream

NOI-5b agent-observability transcript subscription serving. NOI-5b transcript subscription: namespace-gated durable-tail + live-splice forward loop for one (workflow, run, activity, attempt) agent transcript.