Struct PersistentRuntimeDriver 

pub struct PersistentRuntimeDriver { /* private fields */ }

Persistent runtime driver — durable InputState via RuntimeStore.

Implementations

impl PersistentRuntimeDriver

pub fn new(runtime_id: LogicalRuntimeId, store: Arc<dyn RuntimeStore>) -> Self

Create a new persistent runtime driver.

pub fn inner_ref(&self) -> &EphemeralRuntimeDriver

Get immutable reference to the inner ephemeral driver.

pub fn is_idle(&self) -> bool

Check if the runtime is idle (delegates to inner).

pub fn start_run( &mut self, run_id: RunId, ) -> Result<(), RuntimeStateTransitionError>

Start a new run (delegates to inner).

pub fn complete_run(&mut self) -> Result<RunId, RuntimeStateTransitionError>

Complete a run (delegates to inner).

pub fn drain_events(&mut self) -> Vec<RuntimeEventEnvelope>

Get pending events (delegates to inner).

pub fn take_wake_requested(&mut self) -> bool

Check and clear wake flag (delegates to inner).

pub fn take_process_requested(&mut self) -> bool

Check and clear immediate processing flag (delegates to inner).

pub fn dequeue_next(&mut self) -> Option<(InputId, Input)>

Dequeue next input (delegates to inner).

pub fn stage_input( &mut self, input_id: &InputId, run_id: &RunId, ) -> Result<(), InputStateMachineError>

Stage input (delegates to inner).

pub fn apply_input( &mut self, input_id: &InputId, run_id: &RunId, ) -> Result<(), InputStateMachineError>

Apply input (delegates to inner).

pub fn rollback_staged( &mut self, input_ids: &[InputId], ) -> Result<(), InputStateMachineError>

Roll back staged inputs (delegates to inner).

pub fn consume_inputs( &mut self, input_ids: &[InputId], run_id: &RunId, ) -> Result<(), InputStateMachineError>

Consume applied inputs without completing a runtime run.

pub fn forget_input(&mut self, input_id: &InputId)

Remove a previously accepted input from the ledger/queue.

Trait Implementations

impl RuntimeDriver for PersistentRuntimeDriver

fn accept_input<'life0, 'async_trait>( &'life0 mut self, input: Input, ) -> Pin<Box<dyn Future<Output = Result<AcceptOutcome, RuntimeDriverError>> + Send + 'async_trait>>

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

Accept an input into the runtime.

fn on_runtime_event<'life0, 'async_trait>( &'life0 mut self, event: RuntimeEventEnvelope, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeDriverError>> + Send + 'async_trait>>

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

Handle a runtime event (from the event bus).

fn on_run_event<'life0, 'async_trait>( &'life0 mut self, event: RunEvent, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeDriverError>> + Send + 'async_trait>>

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

Handle a run event (from core).

fn on_runtime_control<'life0, 'async_trait>( &'life0 mut self, command: RuntimeControlCommand, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeDriverError>> + Send + 'async_trait>>

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

Handle a runtime control command.

fn recover<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<RecoveryReport, RuntimeDriverError>> + Send + 'async_trait>>

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

Recover from a crash/restart.

fn retire<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<RetireReport, RuntimeDriverError>> + Send + 'async_trait>>

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

Retire the runtime (no new input, abandon pending).

fn reset<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<ResetReport, RuntimeDriverError>> + Send + 'async_trait>>

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

Reset the runtime (abandon all pending input, drain queue).

fn runtime_state(&self) -> RuntimeState

Get the current runtime state.

fn input_state(&self, input_id: &InputId) -> Option<&InputState>

Get the state of a specific input.

fn active_input_ids(&self) -> Vec<InputId>

List all non-terminal input IDs.