Struct TraceFrontier 

pub struct TraceFrontier<Tr: TraceReader> { /* private fields */ }

Wrapper to provide trace to nested scope.

Implementations

impl<Tr: TraceReader> TraceFrontier<Tr>

pub fn make_from( trace: Tr, since: AntichainRef<'_, Tr::Time>, until: AntichainRef<'_, Tr::Time>, ) -> Self

Makes a new trace wrapper

Trait Implementations

impl<Tr: TraceReader + Clone> Clone for TraceFrontier<Tr>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Tr: TraceReader> TraceReader for TraceFrontier<Tr>

type Time = <Tr as TraceReader>::Time

The timestamp type of the trace’s updates.

type Batch = BatchFrontier<<Tr as TraceReader>::Batch, <Tr as TraceReader>::Time>

The batches of updates the trace’s spans carry.

fn map_spans<F: FnMut(&Span<Tr::Time, Self::Batch>)>(&self, f: F)

Maps logic across the non-empty sequence of spans in the trace.

fn set_logical_compaction(&mut self, frontier: AntichainRef<'_, Tr::Time>)

Advances the frontier that constrains logical compaction.

fn get_logical_compaction(&mut self) -> AntichainRef<'_, Tr::Time>

Reports the logical compaction frontier.

fn set_physical_compaction(&mut self, frontier: AntichainRef<'_, Tr::Time>)

Advances the frontier that constrains physical compaction.

fn get_physical_compaction(&mut self) -> AntichainRef<'_, Tr::Time>

Reports the physical compaction frontier.

fn spans_through( &mut self, upper: AntichainRef<'_, Tr::Time>, ) -> Option<Vec<Span<Tr::Time, Self::Batch>>>

Acquires the non-empty sequence of spans covering updates at times not greater or equal to an element of upper.

fn batches_through( &mut self, upper: AntichainRef<'_, Self::Time>, ) -> Option<Vec<Self::Batch>>

Acquires the batches of the spans covering times not greater or equal to an element of upper.

fn read_upper(&mut self, target: &mut Antichain<Self::Time>)

Reads the upper frontier of committed times.

fn advance_upper(&mut self, upper: &mut Antichain<Self::Time>)

Advances upper across any spans with no updates.