Struct ExecutionManager 

pub struct ExecutionManager { /* private fields */ }

Central coordinator for execution plan execution

Manages execution lifecycle (start, pause, resume, cancel) and tracks active executions. Wraps the WorkflowEngine and provides high-level execution plan management.

Implementations

impl ExecutionManager

pub fn new() -> Self

Create a new execution manager

pub fn register_plan(&mut self, plan: ExecutionPlan) -> ExecutionResult<String>

Register an execution plan

Stores the plan for later execution. Returns the plan ID.

pub fn get_plan(&self, plan_id: &str) -> ExecutionResult<ExecutionPlan>

Get a registered plan

pub fn start_execution( &mut self, plan_id: &str, mode: ExecutionMode, ) -> ExecutionResult<String>

Start execution of a plan

Creates a new execution state and begins execution in the specified mode. Also creates a progress tracker for the execution.

pub fn pause_execution(&mut self, execution_id: &str) -> ExecutionResult<()>

Pause an active execution

Saves the current execution state for later resumption.

pub fn resume_execution(&mut self, execution_id: &str) -> ExecutionResult<()>

Resume a paused execution

Continues execution from where it was paused.

pub fn cancel_execution(&mut self, execution_id: &str) -> ExecutionResult<()>

Cancel an active execution

Stops execution and removes the execution state and progress tracker.

pub fn get_execution_state( &self, execution_id: &str, ) -> ExecutionResult<ExecutionState>

Get the current state of an execution

pub fn get_active_executions(&self) -> Vec<ExecutionState>

Get all active executions

pub fn is_active(&self, execution_id: &str) -> bool

Check if an execution is active

pub fn get_progress_tracker_mut( &mut self, execution_id: &str, ) -> ExecutionResult<&mut ProgressTracker>

Get the progress tracker for an execution

Returns a mutable reference to the progress tracker for the given execution.

pub fn get_progress_tracker( &self, execution_id: &str, ) -> ExecutionResult<&ProgressTracker>

Get the progress tracker for an execution (read-only)

Returns a reference to the progress tracker for the given execution.

pub fn on_progress<F>( &mut self, execution_id: &str, callback: F, ) -> ExecutionResult<()>

where F: Fn(ProgressUpdate) + Send + Sync + 'static,

Register a progress callback for an execution

Callbacks are called whenever progress is updated during execution.

Trait Implementations

impl Default for ExecutionManager

fn default() -> Self

Returns the “default value” for a type.