Struct StatefulRuntimeEngineV3 

pub struct StatefulRuntimeEngineV3 { /* private fields */ }

Preview Runtime V3 engine for Stateful Handler ABI v2.

Implementations

impl StatefulRuntimeEngineV3

pub fn new( config: StatefulRuntimeConfigV3, handler: Arc<dyn StatefulHandlerV2>, ) -> Result<Self, StatefulHandlerErrorV2>

pub fn restore_snapshot( &self, snapshot: StatefulStateSnapshotV2, ) -> Result<(), StatefulHandlerErrorV2>

Restore a previously validated Runtime-owned state atomically.

pub fn snapshot( &self, ) -> Result<StatefulStateSnapshotV2, StatefulHandlerErrorV2>

pub fn runtime_snapshot( &self, ) -> Result<StatefulRuntimeSnapshotV3, StatefulHandlerErrorV2>

Return the handler state plus the durable decision ledger.

pub fn restore_runtime_snapshot( &self, snapshot: StatefulRuntimeSnapshotV3, ) -> Result<(), StatefulHandlerErrorV2>

Restore handler state and delayed feedback atomically.

pub fn stage_candidate( &self, snapshot: StatefulStateSnapshotV2, ) -> Result<(), StatefulHandlerErrorV2>

Validate and retain a candidate without activating it.

pub fn promote_candidate(&self) -> Result<u64, StatefulHandlerErrorV2>

Atomically activate a previously staged candidate.

pub fn rollback_previous_good(&self) -> Result<u64, StatefulHandlerErrorV2>

Restore the most recent previous-good state after a failed activation.

pub fn restore_snapshot_with_migration( &self, snapshot: StatefulStateSnapshotV2, migrator: &dyn StatefulStateMigratorV1, ) -> Result<(), StatefulHandlerErrorV2>

Migrate a snapshot without destructive in-place mutation.

pub fn handle_at( &self, envelope: EnvelopeV3, now_unix_ms: u64, ) -> RuntimeResponseV3

Handle one request at a caller-supplied clock value. No system clock is read by the library.

pub fn handle_json_at( &self, message: &[u8], now_unix_ms: u64, ) -> RuntimeResponseV3

Decode and handle one bounded IPC V3 JSON message. Malformed and oversized messages are rejected before a handler can observe them. The caller supplies the clock so replay and tests remain deterministic.

pub fn handle_preview_at( &self, envelope: EnvelopeV3, now_unix_ms: u64, ) -> RuntimeResponseV3Preview

Handle the additive Preview response surface. The frozen v3 response type remains available through handle_at for library consumers.

pub fn handle_preview_json_at( &self, message: &[u8], now_unix_ms: u64, ) -> RuntimeResponseV3Preview

pub fn diagnostics_at( &self, observed_at_unix_ms: u64, ) -> Result<RuntimeDiagnosticsV1, StatefulHandlerErrorV2>

Return structured diagnostics using a caller-provided timestamp.

Trait Implementations

impl Debug for StatefulRuntimeEngineV3

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

Formats the value using the given formatter.