Skip to main content

CommittedTxReader

Struct CommittedTxReader 

Source
pub struct CommittedTxReader { /* private fields */ }
Expand description

Lazily yields committed transactions whose TxBegin LSN is above after and whose commit LSN is at or below upto.

Records past upto are never decoded, so the reader is safe to use while a writer keeps appending to the active segment: everything at or below upto was written to the OS before upto was observed.

Implementations§

Source§

impl CommittedTxReader

Source

pub fn open(dir: &Path, after: Lsn, upto: Lsn) -> Result<Self, WalError>

Source

pub fn next_tx(&mut self) -> Result<Option<CommittedTx>, WalError>

Next committed transaction, or None once upto is reached or the log ends.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.