Trait PublicReplayReads 

pub trait PublicReplayReads {
    type Error: From<BookkeepingError>;

    // Required methods
    fn outcome(
        &mut self,
        outcome_key: &str,
    ) -> Result<Option<StoredPublicOutcome>, Self::Error>;
    fn floor_ms(&mut self) -> Result<i64, Self::Error>;
    fn run_id_cursor(
        &mut self,
        run_id: &str,
    ) -> Result<Option<String>, Self::Error>;
}

The three reads behind the shared replay spine, generic over the host’s error currency. The coordinator instantiates it over OneShotBackend (with WritePlaneError); the replicator’s transaction-outcome cursor path instantiates it over a raw connection with MasterError — ONE decision matrix and ONE resolver, no twin, which is what decision C4 means by “generic by construction”.

Required Associated Types

type Error: From<BookkeepingError>

The host’s error currency; every shared decision converts up from BookkeepingError, which both hosts absorb losslessly.

Required Methods

fn outcome( &mut self, outcome_key: &str, ) -> Result<Option<StoredPublicOutcome>, Self::Error>

Read one stored outcome row.

fn floor_ms(&mut self) -> Result<i64, Self::Error>

The operation-namespace retention floor (host clock injected host-side).

fn run_id_cursor(&mut self, run_id: &str) -> Result<Option<String>, Self::Error>

The legacy run_id → cursor scan.

Implementors