Struct WebSocketState 

pub struct WebSocketState {
    pub broadcaster: Arc<Sender<WorkflowEvent>>,
    pub monitoring: Arc<MonitoringService>,
}

WebSocket state.

Fields

broadcaster: Arc<Sender<WorkflowEvent>>

Event broadcaster.

monitoring: Arc<MonitoringService>

Monitoring service.

Implementations

impl WebSocketState

pub fn new(monitoring: Arc<MonitoringService>) -> Self

Create a new WebSocket state.

pub fn broadcast(&self, event: WorkflowEvent)

Broadcast an event to all connected clients.

pub fn broadcast_workflow_started( &self, workflow_id: WorkflowId, workflow_name: String, )

Broadcast workflow started event.

pub fn broadcast_workflow_completed( &self, workflow_id: WorkflowId, success: bool, )

Broadcast workflow completed event.

pub fn broadcast_task_state_changed( &self, workflow_id: WorkflowId, task_id: TaskId, task_name: String, state: TaskState, )

Broadcast task state changed event.

pub fn broadcast_progress_update( &self, workflow_id: WorkflowId, progress: f64, completed_tasks: usize, total_tasks: usize, )

Broadcast progress update.

pub fn broadcast_metrics_update(&self, metrics: WorkflowMetrics)

Broadcast metrics update.

pub fn broadcast_error(&self, workflow_id: WorkflowId, message: String)

Broadcast error event.

Trait Implementations

impl Clone for WebSocketState

fn clone(&self) -> WebSocketState

Returns a duplicate of the value.

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

Performs copy-assignment from source.