Struct InlineRuntimeEffectController 

pub struct InlineRuntimeEffectController;

Default in-process effect controller.

The inline controller executes local runners in process, provides in-memory await-event resolution, and exposes durable-tool-effect semantics for local runs. It does not make in-flight effects crash durable; workflow adapters provide that by recording outcomes in their own history.

Trait Implementations

impl AwaitEventResolver for InlineRuntimeEffectController

fn supports_durable_effects(&self) -> bool

fn await_event_key<'life0, 'life1, 'async_trait>( &'life0 self, scope: &'life1 ExecutionScope, wait: AwaitEventWaitIdentity, ) -> Pin<Box<dyn Future<Output = Result<AwaitEventKey, RuntimeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InlineRuntimeEffectController: 'async_trait,

fn resolve_await_event<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 AwaitEventKey, resolution: Resolution, ) -> Pin<Box<dyn Future<Output = Result<ResolveOutcome, RuntimeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InlineRuntimeEffectController: 'async_trait,

fn await_await_event<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 AwaitEventKey, cancel: CancellationToken, deadline: Option<Instant>, ) -> Pin<Box<dyn Future<Output = Result<Resolution, RuntimeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InlineRuntimeEffectController: 'async_trait,

fn revoke_await_events_for_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InlineRuntimeEffectController: 'async_trait,

fn cancel_await_events_for_session<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InlineRuntimeEffectController: 'async_trait,

Cancel every outstanding durable wait for session_id without deleting the session: each waiter receives a terminal Resolution::Cancelled instead of hanging, late resolves observe that terminal, and waits registered afterwards behave normally — in contrast to revoke_await_events_for_session, which tombstones the session’s waits forever.

fn durability_tier(&self) -> DurabilityTier

impl Clone for InlineRuntimeEffectController

fn clone(&self) -> InlineRuntimeEffectController

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InlineRuntimeEffectController

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

Formats the value using the given formatter.

impl Default for InlineRuntimeEffectController

fn default() -> InlineRuntimeEffectController

Returns the “default value” for a type.

impl RuntimeEffectController for InlineRuntimeEffectController

fn execute_effect<'life0, 'life1, 'async_trait>( &'life0 self, envelope: RuntimeEffectEnvelope, local_executor: RuntimeEffectLocalExecutor<'life1>, ) -> Pin<Box<dyn Future<Output = Result<RuntimeEffectOutcome, RuntimeEffectControllerError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InlineRuntimeEffectController: 'async_trait,

fn wants_segment_boundary( &self, _progress: &SegmentProgress, ) -> Option<BoundaryReason>

Advises an engine to end the current in-process execution segment at a quiescent point. Engines may decline when live state is not capturable, but must make progress before returning another decline. In particular, an engine must not repeatedly return the same boundary and unchanged durable-wait state in one invocation; a host may bound and retry such a non-progressing invocation.

fn supports_concurrent_effects(&self) -> bool

Whether this controller can safely accept overlapping execute_effect calls from one runtime coordinator.