Struct SqliteRuntimeEffectController 

pub struct SqliteRuntimeEffectController { /* private fields */ }

Scoped SQLite-backed runtime effect controller.

Implementations

impl SqliteRuntimeEffectController

pub async fn open(path: &Path, scope: ExecutionScope) -> Result<Self>

pub async fn open_with_clock( path: &Path, scope: ExecutionScope, clock: Arc<dyn Clock>, ) -> Result<Self>

pub async fn open_with_options( path: &Path, scope: ExecutionScope, options: SqliteEffectReplayOptions, ) -> Result<Self>

pub async fn open_with_options_and_clock( path: &Path, scope: ExecutionScope, options: SqliteEffectReplayOptions, clock: Arc<dyn Clock>, ) -> Result<Self>

pub async fn memory(scope: ExecutionScope) -> Result<Self>

pub async fn memory_with_clock( scope: ExecutionScope, clock: Arc<dyn Clock>, ) -> Result<Self>

pub async fn memory_with_options( scope: ExecutionScope, options: SqliteEffectReplayOptions, ) -> Result<Self>

pub async fn memory_with_options_and_clock( scope: ExecutionScope, options: SqliteEffectReplayOptions, clock: Arc<dyn Clock>, ) -> Result<Self>

pub fn start_replay(&self)

Force strict replay mode: missing effect history fails instead of executing locally. Normal operation still replays any completed row.

Trait Implementations

impl AwaitEventResolver for SqliteRuntimeEffectController

fn durability_tier(&self) -> DurabilityTier

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, Self: '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, Self: '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, Self: '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, Self: '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, Self: '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.

impl Clone for SqliteRuntimeEffectController

fn clone(&self) -> SqliteRuntimeEffectController

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl RuntimeEffectController for SqliteRuntimeEffectController

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 Self: 'async_trait, 'life0: 'async_trait, 'life1: '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.