Enum RecoverLogicalLogState 

pub enum RecoverLogicalLogState {
    Start,
    ReadHeader {
        reader: Box<StreamingLogicalLogReader>,
        preserved_tvfs: Vec<Arc<VirtualTable>>,
    },
    ReadTxTs {
        reader: Box<StreamingLogicalLogReader>,
        preserved_tvfs: Vec<Arc<VirtualTable>>,
        header_present: bool,
        txts_st: ReadPersistentTxTsMaxState,
    },
    ReadCookie {
        reader: Box<StreamingLogicalLogReader>,
        preserved_tvfs: Vec<Arc<VirtualTable>>,
        persistent_tx_ts_max: u64,
    },
    QuerySchema {
        reader: Box<StreamingLogicalLogReader>,
        preserved_tvfs: Vec<Arc<VirtualTable>>,
        persistent_tx_ts_max: u64,
        cookie: u32,
        stmt: Option<Box<Statement>>,
        schema_rows: FxHashMap<i64, ImmutableRecord>,
    },
    Replay {
        ctx: Box<RecoverCtx>,
    },
    Done,
}

Sub state machine for MvStore::maybe_recover_logical_log. The setup phases (header read, persistent-tx-ts read, schema-cookie read, sqlite_schema scan) each yield IO; the Replay phase carries the loop accumulators in RecoverCtx across per-frame next_frame yields.

Variants

Start

ReadHeader

Fields

reader: Box<StreamingLogicalLogReader>

preserved_tvfs: Vec<Arc<VirtualTable>>

ReadTxTs

Fields

reader: Box<StreamingLogicalLogReader>

preserved_tvfs: Vec<Arc<VirtualTable>>

header_present: bool

txts_st: ReadPersistentTxTsMaxState

ReadCookie

Fields

reader: Box<StreamingLogicalLogReader>

preserved_tvfs: Vec<Arc<VirtualTable>>

persistent_tx_ts_max: u64

QuerySchema

Fields

reader: Box<StreamingLogicalLogReader>

preserved_tvfs: Vec<Arc<VirtualTable>>

persistent_tx_ts_max: u64

cookie: u32

stmt: Option<Box<Statement>>

schema_rows: FxHashMap<i64, ImmutableRecord>

Replay

Fields

ctx: Box<RecoverCtx>

Done

Trait Implementations

impl Default for RecoverLogicalLogState

fn default() -> RecoverLogicalLogState

Returns the “default value” for a type.