Struct ReaderWatermark

pub struct ReaderWatermark {
    pub checkpoint_hi_inclusive: u64,
    pub reader_lo: u64,
}

Represents the inclusive lower bound of available data in the Store for some pipeline.

Fields

checkpoint_hi_inclusive: u64

Within the framework, this value is used to determine the new reader_lo.

reader_lo: u64

Within the framework, this value is used to check whether to actually make an update transaction to the database.

Trait Implementations

impl Clone for ReaderWatermark

fn clone(&self) -> ReaderWatermark

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReaderWatermark

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for ReaderWatermark

fn default() -> ReaderWatermark

Returns the “default value” for a type.

impl Copy for ReaderWatermark