Struct FetchWatermarks 

pub struct FetchWatermarks {
    pub log_start: i64,
    pub hw: i64,
    pub lso: i64,
    pub log_end: i64,
    pub deliverable: i64,
}

The partition offsets one Fetch visibility decision reads.

They are one struct because they are five i64 values with five different meanings, and a transposed call site would compile.

Fields

log_start: i64

First offset the log still holds. Below it a fetch is out of range.

hw: i64

High watermark: the exclusive bound of what the ISR has replicated.

lso: i64

Last stable offset: the first offset an open transaction may cover.

log_end: i64

Log end offset: the exclusive bound of what the leader holds.

deliverable: i64

KFC-1 delivery watermark: the first offset that is not due yet.

Trait Implementations

impl Clone for FetchWatermarks

fn clone(&self) -> FetchWatermarks

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for FetchWatermarks

impl Debug for FetchWatermarks

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

Formats the value using the given formatter.

impl Eq for FetchWatermarks

impl PartialEq for FetchWatermarks

fn eq(&self, other: &FetchWatermarks) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for FetchWatermarks