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>, blob_store: Arc<dyn BlobStore>, ) -> Self

Create a new persistent runtime driver.

pub fn inner_ref(&self) -> &EphemeralRuntimeDriver

Get immutable reference to the inner ephemeral driver.

pub fn runtime_id(&self) -> &LogicalRuntimeId

Get the logical runtime ID for this driver.

pub fn silent_comms_intents(&self) -> Vec<String>

pub fn is_idle(&self) -> bool

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

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

Get pending events (delegates to inner).

pub fn take_post_admission_signal(&mut self) -> PostAdmissionSignal

Drain the typed post-admission signal (delegates to inner).

pub fn post_admission_signal(&self) -> PostAdmissionSignal

Inspect the current typed post-admission signal without draining it.

pub fn take_wake_requested(&mut self) -> bool

Check and clear wake flag (backward-compat, delegates to inner).

pub fn take_process_requested(&mut self) -> bool

Check and clear immediate processing flag (backward-compat, delegates to inner).

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

Dequeue next input (delegates to inner).

pub fn dequeue_by_id(&mut self, input_id: &InputId) -> Option<(InputId, Input)>

Dequeue a specific input by ID (delegates to inner).

pub fn has_queued_input_outside(&self, excluded: &[InputId]) -> bool

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

Stage input (delegates to inner).

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

Stage a batch of inputs atomically (delegates to inner).

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

Apply input (delegates to inner).

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

Roll back staged inputs (delegates to inner).

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 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 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 input_phase(&self, input_id: &InputId) -> Option<InputLifecycleState>

Get the current DSL-owned lifecycle phase of a specific input.

fn input_last_run_id(&self, input_id: &InputId) -> Option<RunId>

Get the current DSL-owned last run association for a specific input.

fn input_last_boundary_sequence(&self, input_id: &InputId) -> Option<u64>

Get the current DSL-owned last boundary sequence for a specific input.

fn stored_input_state(&self, input_id: &InputId) -> Option<StoredInputState>

Get the persisted shell+seed bundle for a specific input.

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

List all non-terminal input IDs.