Struct ExecutionMonitor 

pub struct ExecutionMonitor { /* private fields */ }

执行监控器

Implementations

impl ExecutionMonitor

pub fn new(plan: ExecutionPlan) -> Self

创建新的执行监控器

pub async fn set_progress_callback<F>(&self, callback: F)

where F: Fn(&str, ExecutionStatus) + Send + Sync + 'static,

设置进度回调

pub async fn get_status(&self) -> ExecutionStatus

获取当前状态

pub async fn get_progress(&self) -> u32

获取执行进度 (0-100)

pub async fn start(&self) -> Layer2Result<()>

开始执行

pub async fn report_step_completed( &self, subtask_id: &str, output: String, ) -> Layer2Result<()>

报告步骤完成

pub async fn report_step_failed( &self, subtask_id: &str, error: String, ) -> Layer2Result<CorrectionDecision>

报告步骤失败

pub async fn apply_correction( &self, subtask_id: &str, decision: &CorrectionDecision, ) -> Layer2Result<bool>

应用纠错策略

pub async fn complete(&self) -> Layer2Result<ExecutionSummary>

完成执行

pub async fn get_correction_history(&self) -> Vec<CorrectionRecord>

获取纠错历史