Struct mz_storage_client::util::antichain::MutableOffsetAntichain

pub struct MutableOffsetAntichain {
    inner: MutableAntichain<PartitionOffset>,
}

A wrapper around MutableAntichain that allows adding (inserting all contents with a +1) and subtracting (inserting all contents with a -1) of whole OffsetAntichains.

The frontier of this mutable antichain can be revealed in the form of an OffsetAntichain.

Fields

inner: MutableAntichain<PartitionOffset>

Implementations

impl MutableOffsetAntichain

pub fn new() -> Self

Creates a new, empty MutableOffsetAntichain.

pub fn add(&mut self, offsets: &OffsetAntichain)

Inserts all partition/offset pairs contained in the given OffsetAntichain into this MutableOffsetAntichain, with a diff of +1.

In laymans terms, this adds the contained partition/offset pairs.

pub fn subtract(&mut self, offsets: &OffsetAntichain)

Inserts all partition/offset pairs contained in the given OffsetAntichain into this MutableOffsetAntichain, with a diff of -1.

In laymans terms, this subtracts the contained partition/offset pairs.

pub fn update_iter<I>(&mut self, updates: I)where
    I: IntoIterator<Item = ((PartitionId, MzOffset), Diff)>,

pub fn frontier(&self) -> OffsetAntichain

Reveals the minimal elements with positive count.

In laymans terms, this returns an OffsetAntichain that contains all partitions with positive counts, and their respective minimal offset.

Trait Implementations

impl Debug for MutableOffsetAntichain

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

Formats the value using the given formatter.