Struct RemoteMonitor 

pub struct RemoteMonitor { /* private fields */ }

Remote monitoring server

Implementations

impl RemoteMonitor

pub fn new(config: RemoteMonitorConfig) -> Self

Create a new remote monitor

pub fn subscribe(&self) -> Receiver<RemoteEvent>

Subscribe to events

pub async fn register_node( &self, node: RemoteNode, ) -> Result<(), RemoteMonitorError>

Register a new node

pub async fn unregister_node( &self, node_id: &str, ) -> Result<bool, RemoteMonitorError>

Unregister a node

pub async fn heartbeat(&self, node_id: &str) -> Result<(), RemoteMonitorError>

Update node heartbeat

pub async fn get_node(&self, node_id: &str) -> Option<RemoteNode>

Get node by ID

pub async fn list_nodes(&self) -> Vec<RemoteNode>

List all nodes

pub async fn list_nodes_by_status(&self, status: NodeStatus) -> Vec<RemoteNode>

List nodes by status

pub async fn create_task( &self, task: RemoteTask, ) -> Result<RemoteTaskId, RemoteMonitorError>

Create a new task

pub async fn update_task_status( &self, task_id: &str, status: RemoteTaskStatus, ) -> Result<(), RemoteMonitorError>

Update task status

pub async fn update_task_progress( &self, task_id: &str, progress: f32, message: Option<String>, ) -> Result<(), RemoteMonitorError>

Update task progress

pub async fn update_task_step( &self, task_id: &str, step: u32, total: u32, description: Option<String>, ) -> Result<(), RemoteMonitorError>

Update task step

pub async fn complete_task( &self, task_id: &str, result: TaskResult, ) -> Result<(), RemoteMonitorError>

Complete a task

pub async fn fail_task( &self, task_id: &str, error: String, ) -> Result<(), RemoteMonitorError>

Fail a task

pub async fn cancel_task( &self, task_id: &str, reason: Option<String>, ) -> Result<(), RemoteMonitorError>

Cancel a task

pub async fn add_task_log( &self, task_id: &str, entry: TaskLogEntry, ) -> Result<(), RemoteMonitorError>

Add log entry to task

pub async fn get_task(&self, task_id: &str) -> Option<RemoteTask>

Get task by ID

pub async fn list_tasks(&self) -> Vec<RemoteTask>

List all tasks

pub async fn list_tasks_by_node(&self, node_id: &str) -> Vec<RemoteTask>

List tasks by node

pub async fn list_tasks_by_status( &self, status: RemoteTaskStatus, ) -> Vec<RemoteTask>

List tasks by status

pub async fn list_tasks_by_agent(&self, agent_id: &str) -> Vec<RemoteTask>

List tasks by agent

pub async fn get_stats(&self) -> MonitorStats

Get monitoring statistics

pub async fn check_node_timeouts(&self)

Check for timed out nodes and update their status

pub fn config(&self) -> &RemoteMonitorConfig

Get configuration