Struct ClientManager 

pub struct ClientManager { /* private fields */ }

Manages all connected WebSocket clients

Implementations

impl ClientManager

pub fn new() -> Self

pub fn with_timeout(self, timeout: Duration) -> Self

pub fn with_message_queue_size(self, queue_size: usize) -> Self

pub async fn add_client( &self, client_id: Uuid, ws_sender: WebSocketSender, ) -> Result<()>

Add a new client connection

pub async fn remove_client(&self, client_id: Uuid)

pub async fn client_count(&self) -> usize

pub async fn send_to_client( &self, client_id: Uuid, data: Arc<Bytes>, ) -> Result<()>

pub async fn update_subscription( &self, client_id: Uuid, subscription: Subscription, ) -> bool

pub async fn update_client_last_seen(&self, client_id: Uuid)

pub async fn get_subscription(&self, client_id: Uuid) -> Option<Subscription>

pub async fn cleanup_stale_clients(&self) -> usize

pub async fn start_cleanup_task(&self)

Trait Implementations

impl Clone for ClientManager

fn clone(&self) -> ClientManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for ClientManager

fn default() -> Self

Returns the “default value” for a type.