Struct DefaultExecutionEngine 

pub struct DefaultExecutionEngine { /* private fields */ }

Default runtime implementation for the unstable v4 execution engine.

The engine validates the run contract, rehydrates facts from prior events, and executes states in topological order with retry/resume semantics.

Implementations

impl DefaultExecutionEngine

pub fn new(resolver: Arc<dyn PlanResolver>) -> Self

Creates an engine that resolves plans with resolver and rejects live IO by default.

pub fn with_live_transport_factory( self, factory: Arc<dyn LiveIoTransportFactory>, ) -> Self

Installs the live IO transport factory used for state execution in live mode.

pub fn with_failpoints(self, failpoints: EngineFailpoints) -> Self

Enables test failpoints for the returned engine instance.

Trait Implementations

impl Clone for DefaultExecutionEngine

fn clone(&self) -> DefaultExecutionEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ExecutionEngine for DefaultExecutionEngine

fn start<'life0, 'async_trait>( &'life0 self, stores: Stores, run: StartRun, ) -> Pin<Box<dyn Future<Output = Result<RunResult, RunError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Starts a new run from the supplied manifest, plan, and initial context.

fn resume<'life0, 'async_trait>( &'life0 self, stores: Stores, run_id: RunId, ) -> Pin<Box<dyn Future<Output = Result<RunResult, RunError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Resumes a previously started run from persisted state.