Struct LiveIo 

pub struct LiveIo { /* private fields */ }

Live-mode IO provider that records deterministic facts for later replay.

Implementations

impl LiveIo

pub fn new( run_id: RunId, state_id: StateId, attempt: u32, artifacts: Arc<dyn ArtifactStore>, facts: FactIndex, fact_recorder: Arc<dyn FactRecorder>, transport: Box<dyn LiveIoTransport>, ) -> Self

Creates a live IO provider for a specific state attempt.

Trait Implementations

impl IoProvider for LiveIo

fn call<'life0, 'async_trait>( &'life0 mut self, call: IoCall, ) -> Pin<Box<dyn Future<Output = Result<IoResult, IoError>> + Send + 'async_trait>>

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

Executes an IO request and returns the structured response.

fn get_recorded_fact<'life0, 'life1, 'async_trait>( &'life0 mut self, key: &'life1 FactKey, ) -> Pin<Box<dyn Future<Output = Result<Option<ArtifactId>, IoError>> + Send + 'async_trait>>

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

Lookup recorded fact payload by key.

fn record_value<'life0, 'async_trait>( &'life0 mut self, key: FactKey, value: Value, ) -> Pin<Box<dyn Future<Output = Result<ArtifactId, IoError>> + Send + 'async_trait>>

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

Persist a deterministic structured value directly as a fact payload.

fn now_millis<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<u64, IoError>> + Send + 'async_trait>>

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

Current time. If used in deterministic logic, implementations MUST record as facts.

fn random_bytes<'life0, 'async_trait>( &'life0 mut self, n: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<u8>, IoError>> + Send + 'async_trait>>

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

Random bytes. If used in reproducible paths, implementations MUST record as facts.