Struct TaskMonitor 

pub struct TaskMonitor { /* private fields */ }

任务监控器

Implementations

impl TaskMonitor

pub fn new() -> TaskMonitor

创建新的任务监控器

pub fn with_event_sender(self, tx: Sender<MonitorEvent>) -> TaskMonitor

设置事件发送器

pub async fn start_monitoring(&self, task_id: &str, agent_id: &str)

开始监控任务

pub async fn update_task_status( &self, task_id: &str, status: TaskExecutionStatus, progress: u32, message: Option<String>, )

更新任务状态

pub async fn complete_task(&self, task_id: &str, result: ExecutionResult)

任务完成

pub async fn fail_task(&self, task_id: &str, error: &str)

任务失败

pub async fn get_task_snapshot(&self, task_id: &str) -> Option<TaskSnapshot>

获取任务快照

pub async fn get_all_snapshots(&self) -> Vec<TaskSnapshot>

获取所有任务快照

pub async fn create_decision( &self, todo_id: &str, decision_type: DecisionType, description: &str, options: Vec<DecisionOption>, recommended_option: Option<usize>, deadline: Option<u64>, ) -> CriticalDecision

创建决策请求

pub async fn request_decision( &self, decision: CriticalDecision, ) -> Result<HumanResponse, Error>

请求人类决策

pub async fn submit_human_response( &self, decision_id: &str, selected_option: usize, comment: Option<String>, ) -> Result<(), Error>

提交人类响应

pub async fn get_pending_decisions(&self) -> Vec<CriticalDecision>

获取待处理的决策

pub async fn handle_agent_message( &self, message: SecretaryMessage, ) -> Result<(), Error>

处理来自执行Agent的消息

pub async fn get_statistics(&self) -> HashMap<String, usize>

获取统计信息

Trait Implementations

impl Default for TaskMonitor

fn default() -> TaskMonitor

Returns the “default value” for a type.