Struct WebSocketServer 

pub struct WebSocketServer { /* private fields */ }

WebSocket server for managing real-time connections.

Implementations

impl WebSocketServer

pub fn new(node_id: NodeId, config: WebSocketConfig) -> Self

Create a new WebSocket server.

pub fn node_id(&self) -> NodeId

Get the node ID.

pub fn config(&self) -> &WebSocketConfig

Get the configuration.

pub async fn register_connection( &self, session_id: SessionId, sender: Sender<WebSocketMessage>, )

Register a new connection.

pub async fn remove_connection( &self, session_id: SessionId, ) -> Option<Vec<SubscriptionId>>

Remove a connection.

pub async fn add_subscription( &self, session_id: SessionId, subscription_id: SubscriptionId, ) -> Result<()>

Add a subscription to a connection.

pub async fn remove_subscription(&self, subscription_id: SubscriptionId)

Remove a subscription from a connection.

pub async fn send_to_session( &self, session_id: SessionId, message: WebSocketMessage, ) -> Result<()>

Send a message to a specific session.

pub async fn broadcast_delta( &self, subscription_id: SubscriptionId, delta: Delta<Value>, ) -> Result<()>

Send a delta to all sessions subscribed to a subscription.

pub async fn connection_count(&self) -> usize

Get connection count.

pub async fn subscription_count(&self) -> usize

Get subscription count.

pub async fn stats(&self) -> WebSocketStats

Get server statistics.

pub async fn cleanup_stale(&self, max_idle: Duration)

Cleanup stale connections.