Trait RecoveryReader 

pub trait RecoveryReader<C>:
    Debug
    + Send
    + Sync {
    // Required method
    fn latest_checkpoint(&self) -> Option<RecoveryCheckpoint<C>>;
}

Reads the latest checkpoint from durable storage. Separated from DurabilityWriter so that write-only sinks (e.g. append-only audit log) don’t need to implement recovery, and read-only sinks don’t need to implement writes.

Required Methods

fn latest_checkpoint(&self) -> Option<RecoveryCheckpoint<C>>

Implementors

impl<C> RecoveryReader<C> for FileDurability<C>

where C: Catalog + Serialize + DeserializeOwned + Clone + 'static,

impl<C> RecoveryReader<C> for InMemoryDurability<C>

where C: Catalog + Serialize + DeserializeOwned + Clone + 'static,

impl<C> RecoveryReader<C> for NoopDurability<C>

where C: Catalog + Serialize + DeserializeOwned,