Struct WebSocketManager

pub struct WebSocketManager { /* private fields */ }

WebSocket manager for handling real-time dashboard connections

Implementations

impl WebSocketManager

pub fn new(dashboard_service: Arc<DashboardService>) -> Self

pub async fn handle_websocket(&self, ws: WebSocketUpgrade) -> Response

Handle new WebSocket connection

pub async fn broadcast_statistics_update( &self, ) -> Result<(), Box<dyn Error + Send + Sync>>

Broadcast statistics update to all connected clients

pub async fn broadcast_job_update( &self, job_id: String, state: String, updated_at: String, )

Broadcast job update to all connected clients

pub async fn connected_clients_count(&self) -> usize

Get number of connected clients

pub async fn start_periodic_updates(&self, interval_seconds: u64)

Start periodic statistics broadcast