Struct persist::indexed::arrangement::TraceSnapshot

pub struct TraceSnapshot {
    pub ts_upper: Antichain<u64>,
    pub since: Antichain<u64>,
    batches: Vec<PFuture<Arc<BlobTraceBatch>>>,
}

A consistent snapshot of the data that is currently physically in the trace bucket of a persistent Arrangement.

Fields

ts_upper: Antichain<u64>

An open upper bound on the times of contained updates.

since: Antichain<u64>

Since frontier of the given updates.

All updates not at times greater than this frontier must be advanced to a time that is equivalent to this frontier.

batches: Vec<PFuture<Arc<BlobTraceBatch>>>

Trait Implementations

impl Debug for TraceSnapshot

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

Formats the value using the given formatter.

impl Snapshot<Vec<u8, Global>, Vec<u8, Global>> for TraceSnapshot

type Iter = TraceSnapshotIter

The kind of iterator we are turning this into.

fn into_iters(self, num_iters: NonZeroUsize) -> Vec<Self::Iter>

Returns a set of num_iters Iterators that each output roughly 1/num_iters of the data represented by this snapshot.

fn into_iter(self) -> Self::Iter

Returns a single Iterator that outputs the data represented by this snapshot.