Struct CommitterWatermark

pub struct CommitterWatermark {
    pub epoch_hi_inclusive: u64,
    pub checkpoint_hi_inclusive: u64,
    pub tx_hi: u64,
    pub timestamp_ms_hi_inclusive: u64,
}

Represents the highest checkpoint for some pipeline that has been processed by the indexer framework. When read from the Store, this represents the inclusive upper bound checkpoint of data that has been written to the Store for a pipeline.

Fields

epoch_hi_inclusive: u64

checkpoint_hi_inclusive: u64

tx_hi: u64

timestamp_ms_hi_inclusive: u64

Implementations

impl CommitterWatermark

pub fn timestamp(&self) -> DateTime<Utc>

pub fn new_for_testing(checkpoint_hi_inclusive: u64) -> Self

Convenience function for testing, instantiates a CommitterWatermark with the given checkpoint_hi_inclusive and sets all other values to 0.

Trait Implementations

impl Clone for CommitterWatermark

fn clone(&self) -> CommitterWatermark

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CommitterWatermark

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

Formats the value using the given formatter.

impl Default for CommitterWatermark

fn default() -> CommitterWatermark

Returns the “default value” for a type.

impl Copy for CommitterWatermark