Struct StreamingLogicalLogReader 

pub struct StreamingLogicalLogReader {
    pub offset: usize,
    /* private fields */
}

Fields

offset: usize

Offset to read from file

Implementations

impl StreamingLogicalLogReader

pub fn new( file: Arc<dyn File>, encryption_ctx: Option<EncryptionContext>, ) -> Self

pub fn last_valid_offset(&self) -> usize

Returns the byte offset just past the last fully validated transaction frame. After recovery, the log writer should resume from this offset so any torn-tail bytes beyond it are overwritten by the next append.

pub fn running_crc(&self) -> u32

Returns the running CRC state after all validated frames. Used during recovery to hand off the chain state to the writer so it can continue appending.

pub fn read_header(&mut self, io: &Arc<dyn IO>) -> Result<()>

pub fn next_portable_change_frame( &mut self, ) -> Result<IOResult<Option<PortableChangeFrame>>>

Reads the next transaction frame and returns its portable logical-change payload. This validates the LML3 frame envelope and chained CRC while treating the recovery payload as opaque bytes.

Empty payloads are returned because internal-only commits still advance the logical-log offset even though clients have no operation to apply.

pub fn next_portable_changes( &mut self, ) -> Result<IOResult<Option<PortableChangeFrame>>>

Reads the next portable logical-change payload, skipping internal-only frames.

Empty payloads are valid: internal-only commits still need recovery log frames, but they do not produce client-visible logical operations.

pub fn is_eof(&self) -> bool

pub fn read_more_data(&mut self, need: usize) -> Result<IOResult<()>>

Read at least need bytes from the logical log, issuing multiple reads if necessary. If at any point 0 bytes are read, that indicates corruption.

Non-blocking: a pread in flight is tracked in self.in_flight_read and the method yields its completion until done. Re-entry picks up where it left off without re-issuing the read.