Struct mz_persist_client::internal::trace::Trace

pub struct Trace<T> {
    spine: Spine<T>,
}

An append-only collection of compactable update batches.

In an effort to keep our fork of Spine as close as possible to the original, we push as many changes as possible into this wrapper.

Fields

spine: Spine<T>

Implementations

impl<T> Trace<T>

pub fn since(&self) -> &Antichain<T>

pub fn upper(&self) -> &Antichain<T>

pub fn map_batches<'a, F: FnMut(&'a HollowBatch<T>)>(&'a self, f: F)

pub fn batches<'a>(&'a self) -> impl IntoIterator<Item = &'a HollowBatch<T>>

pub fn num_spine_batches(&self) -> usize

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

pub fn downgrade_since(&mut self, since: &Antichain<T>)

pub fn push_batch(&mut self, batch: HollowBatch<T>) -> Vec<FueledMergeReq<T>>

pub(crate) fn push_batch_no_merge_reqs(&mut self, batch: HollowBatch<T>)

The same as Self::push_batch but without the FueledMergeReqs, which account for a surprising amount of cpu in prod. #18368

pub fn validate(&self) -> Result<(), String>

Validates invariants.

See Spine::validate for details.

pub fn apply_merge_res(&mut self, res: &FueledMergeRes<T>) -> ApplyMergeResult

pub(crate) fn all_fueled_merge_reqs(&self) -> Vec<FueledMergeReq<T>>

fn remove_redundant_merge_reqs( merge_reqs: Vec<FueledMergeReq<T>> ) -> Vec<FueledMergeReq<T>>

pub fn describe(&self) -> String

Trait Implementations

impl<T: Clone> Clone for Trace<T>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Trace<T>

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

Formats the value using the given formatter.

impl<T: Timestamp + Lattice> Default for Trace<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: PartialEq> PartialEq for Trace<T>

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl<T: Timestamp + Lattice + Codec64> RustType<ProtoTrace> for Trace<T>

fn into_proto(&self) -> ProtoTrace

Convert a Self into a Proto value.

fn from_proto(proto: ProtoTrace) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.