pub struct LazyWalReader { /* private fields */ }Expand description
Lazy WAL reader that separates header reading from payload reading.
Implementations§
Source§impl LazyWalReader
impl LazyWalReader
Sourcepub fn next_header(&mut self) -> Result<Option<RecordHeader>>
pub fn next_header(&mut self) -> Result<Option<RecordHeader>>
Read the next record header (30 bytes) without reading the payload.
Returns None at EOF or first corruption. After this call, use
either read_payload() to get the payload or skip_payload() to
seek past it.
Sourcepub fn read_payload(&mut self, header: &RecordHeader) -> Result<Vec<u8>>
pub fn read_payload(&mut self, header: &RecordHeader) -> Result<Vec<u8>>
Read the payload for a header that was just returned by next_header().
Must be called exactly once after next_header() returns Some,
and before calling next_header() again (unless skip_payload()
was called instead).
Sourcepub fn read_record(&mut self, header: &RecordHeader) -> Result<WalRecord>
pub fn read_record(&mut self, header: &RecordHeader) -> Result<WalRecord>
Read the payload and return a full WalRecord.
Sourcepub fn skip_payload(&mut self, header: &RecordHeader) -> Result<()>
pub fn skip_payload(&mut self, header: &RecordHeader) -> Result<()>
Skip the payload for a header, seeking forward without reading.
This is the key optimization: non-matching records skip I/O entirely.
Auto Trait Implementations§
impl Freeze for LazyWalReader
impl RefUnwindSafe for LazyWalReader
impl Send for LazyWalReader
impl !Sync for LazyWalReader
impl Unpin for LazyWalReader
impl UnsafeUnpin for LazyWalReader
impl UnwindSafe for LazyWalReader
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more