Struct TableWatermarks

pub struct TableWatermarks {
    pub watermarks: Vec<(HummockEpoch, Arc<[VnodeWatermark]>)>,
    pub direction: WatermarkDirection,
}

Fields

watermarks: Vec<(HummockEpoch, Arc<[VnodeWatermark]>)>

direction: WatermarkDirection

Implementations

impl TableWatermarks

pub fn single_epoch( epoch: HummockEpoch, watermarks: Vec<VnodeWatermark>, direction: WatermarkDirection, ) -> Self

pub fn add_new_epoch_watermarks( &mut self, epoch: HummockEpoch, watermarks: Arc<[VnodeWatermark]>, direction: WatermarkDirection, )

fn vnode_count(&self) -> Option<usize>

Vnode count derived from existing watermarks. Returns None if there is no watermark.

pub fn from_protobuf(pb: &PbTableWatermarks) -> Self

impl TableWatermarks

pub fn apply_new_table_watermarks( &mut self, newly_added_watermarks: &TableWatermarks, )

pub fn clear_stale_epoch_watermark(&mut self, safe_epoch: u64)

impl TableWatermarks

pub fn estimated_encode_len(&self) -> usize

pub fn to_protobuf(&self) -> PbTableWatermarks

Trait Implementations

impl Clone for TableWatermarks

fn clone(&self) -> TableWatermarks

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TableWatermarks

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

Formats the value using the given formatter.

impl From<&TableWatermarks> for TableWatermarks

fn from(pb: &PbTableWatermarks) -> Self

Converts to this type from the input type.

impl From<&TableWatermarks> for TableWatermarks

fn from(table_watermarks: &TableWatermarks) -> Self

Converts to this type from the input type.

impl From<TableWatermarks> for TableWatermarks

fn from(pb: PbTableWatermarks) -> Self

Converts to this type from the input type.

impl From<TableWatermarks> for TableWatermarks

fn from(table_watermarks: TableWatermarks) -> Self

Converts to this type from the input type.

impl PartialEq for TableWatermarks

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for TableWatermarks