Struct ExecutionEngine 

pub struct ExecutionEngine { /* private fields */ }

Main execution engine

Thread-safe, async execution engine with:

• Semaphore-based concurrency limiting
• In-memory state management
• Event emission support
• Automatic cleanup (optional)

Implementations

impl ExecutionEngine

pub fn new(config: ExecutionConfig) -> Result<Self>

Create new ExecutionEngine

pub fn with_event_handler(self, handler: Arc<dyn EventHandler>) -> Self

Set event handler (builder pattern)

pub async fn execute(&self, request: ExecutionRequest) -> Result<Uuid>

Execute a command asynchronously

Returns execution ID immediately and spawns background task. Use get_status() or get_result() to check progress.

pub async fn get_status(&self, execution_id: Uuid) -> Result<ExecutionStatus>

Get current status of an execution

pub async fn get_result(&self, execution_id: Uuid) -> Result<ExecutionResult>

Get execution result (returns error if not complete)

pub async fn wait_for_completion( &self, execution_id: Uuid, ) -> Result<ExecutionResult>

Wait for execution to complete and return result

pub async fn cancel(&self, execution_id: Uuid) -> Result<()>

Cancel a running execution

pub async fn list_executions(&self) -> Vec<ExecutionSummary>

List all executions in memory

pub async fn running_count(&self) -> usize

Get number of currently running executions

pub async fn total_count(&self) -> usize

Get total number of executions in memory

pub async fn read_logs(&self, execution_id: Uuid) -> Result<String>

Read logs for an execution

pub fn config(&self) -> &ExecutionConfig

Get configuration

pub fn available_permits(&self) -> usize

Get available semaphore permits (concurrency slots)

pub async fn cleanup_old_executions(&self) -> usize

Clean up old executions based on retention policy

Removes executions based on:

1. Age: Older than execution_retention_secs
2. Count: Exceeds max_in_memory_executions

Returns the number of executions removed.

pub async fn remove_execution(&self, execution_id: Uuid) -> Result<()>

Remove a specific execution from memory

Returns Ok(()) if removed, or NotFound error if execution doesn’t exist.

pub fn start_cleanup_task(self: Arc<Self>)

Start automatic cleanup task

Spawns a background task that runs every 5 minutes to clean up old executions. Only starts if enable_auto_cleanup is true in config.

This method consumes self by value and requires Arc wrapper.

Trait Implementations

impl Clone for ExecutionEngine

fn clone(&self) -> ExecutionEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.