Struct mz_persist_client::internal::trace::FuelingMerge

pub struct FuelingMerge<T> {
    pub(crate) since: Antichain<T>,
    pub(crate) remaining_work: usize,
}

Fields

since: Antichain<T>

remaining_work: usize

Implementations

impl<T: Timestamp + Lattice> FuelingMerge<T>

fn work(&mut self, _: &[SpineBatch<T>], fuel: &mut isize)

Perform some amount of work, decrementing fuel.

If fuel is non-zero after the call, the merging is complete and one should call done to extract the merged results.

fn done( self, bs: ArrayVec<SpineBatch<T>, BATCHES_PER_LEVEL>, log: &mut SpineLog<'_, T>, ) -> Option<SpineBatch<T>>

Extracts merged results.

This method should only be called after work has been called and has not brought fuel to zero. Otherwise, the merge is still in progress.

Trait Implementations

impl<T: Clone> Clone for FuelingMerge<T>

fn clone(&self) -> FuelingMerge<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for FuelingMerge<T>

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

Formats the value using the given formatter.

impl<T: PartialEq> PartialEq for FuelingMerge<T>

fn eq(&self, other: &FuelingMerge<T>) -> 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<T> Serialize for FuelingMerge<T>

where T: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T> StructuralPartialEq for FuelingMerge<T>