Struct SessionServer 

pub struct SessionServer { /* private fields */ }

Implementations

impl SessionServer

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

Create a new session server.

pub fn node_id(&self) -> NodeId

pub fn config(&self) -> &RealtimeConfig

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

Register a new connection.

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

Remove a connection.

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

Add a subscription to a connection.

pub fn remove_subscription(&self, subscription_id: SubscriptionId)

Remove a subscription from a connection.

pub fn try_send_to_session( &self, session_id: SessionId, message: RealtimeMessage, ) -> Result<(), SendError>

Non-blocking send with backpressure. Returns false if client was evicted.

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

Blocking send for initial data delivery where we need backpressure.

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

Send a delta to all sessions subscribed to a subscription.

pub fn connection_count(&self) -> usize

Get connection count.

pub fn subscription_count(&self) -> usize

Get subscription count.

pub fn stats(&self) -> SessionStats

Get server statistics.

pub fn cleanup_stale(&self, max_idle: Duration)

Cleanup stale connections.