Struct CompositionExecutionEngine 

pub struct CompositionExecutionEngine { /* private fields */ }

Composition execution engine

Provides comprehensive execution orchestration for modular component composition with resource management, parallel execution, fault tolerance, and performance optimization.

Implementations

impl CompositionExecutionEngine

pub fn new( component_registry: Arc<GlobalComponentRegistry>, dependency_resolver: Arc<DependencyResolver>, lifecycle_manager: Arc<LifecycleManager>, ) -> Self

Create a new execution engine

pub fn create_context( &self, context_id: &str, ) -> SklResult<Arc<RwLock<CompositionContext>>>

Create a new composition context

pub fn get_context( &self, context_id: &str, ) -> Option<Arc<RwLock<CompositionContext>>>

Get composition context

pub async fn execute_pipeline( &self, context_id: &str, pipeline: Pipeline, input_data: PipelineData, ) -> SklResult<ExecutionResult>

Execute a pipeline within a context

pub async fn execute_pipelines_concurrent( &self, executions: Vec<ConcurrentExecution>, ) -> SklResult<Vec<ExecutionResult>>

Execute multiple pipelines concurrently

pub async fn execute_composition( &self, context_id: &str, composition: CompositionGraph, input_data: HashMap<String, PipelineData>, ) -> SklResult<CompositionResult>

Execute a composition graph

pub fn get_statistics(&self) -> ExecutionStatistics

Get execution statistics

pub fn configure(&mut self, config: ExecutionEngineConfig)

Configure the execution engine

pub async fn shutdown(&self) -> SklResult<()>

Shutdown the execution engine

Trait Implementations

impl Clone for CompositionExecutionEngine

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CompositionExecutionEngine

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.