Struct WebSocketManager 

pub struct WebSocketManager { /* private fields */ }

WebSocket manager for real-time event streaming (v0.2 feature)

Implementations

impl WebSocketManager

pub fn new() -> Self

pub fn with_config(config: WebSocketConfig) -> Self

Create a WebSocket manager with custom backpressure configuration.

pub fn broadcast_event(&self, event: Arc<Event>)

Broadcast an event to all connected WebSocket clients

pub fn subscribe_events(&self) -> Receiver<Arc<Event>>

Subscribe to the event broadcast channel (used by RESP3 SUBSCRIBE).

pub async fn handle_socket(&self, socket: WebSocket)

Handle a new WebSocket connection (fire-and-forget, no consumer tracking)

pub async fn handle_socket_with_consumer( &self, socket: WebSocket, consumer_id: String, store: Arc<EventStore>, )

Handle a WebSocket connection with a durable consumer for auto-replay.

Replays all events since the consumer’s last acked position, then switches to real-time delivery. The consumer’s event_type_filters are applied during replay.

pub fn stats(&self) -> WebSocketStats

Get statistics about connected clients

Trait Implementations

impl Default for WebSocketManager

fn default() -> Self

Returns the “default value” for a type.