Struct TraceEnter

pub struct TraceEnter<Tr: TraceReader, TInner, F, G> { /* private fields */ }

Wrapper to provide trace to nested scope.

Each wrapped update is presented with a timestamp determined by logic.

At the same time, we require a method prior that can “invert” timestamps, and which will be applied to compaction frontiers as they are communicated back to the wrapped traces. A better explanation is pending, and until that happens use this construct at your own peril!

Implementations

impl<Tr, TInner, F, G> TraceEnter<Tr, TInner, F, G>

where Tr: TraceReader, TInner: Refines<Tr::Time> + Lattice,

pub fn make_from(trace: Tr, logic: F, prior: G) -> Self

Makes a new trace wrapper

Trait Implementations

impl<Tr, TInner, F, G> Clone for TraceEnter<Tr, TInner, F, G>

where Tr: TraceReader + Clone, F: Clone, G: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Tr, TInner, F, G> TraceReader for TraceEnter<Tr, TInner, F, G>

where Tr: TraceReader<Batch: Clone>, TInner: Refines<Tr::Time> + Lattice, F: 'static + FnMut(Tr::Key<'_>, Tr::Val<'_>, Tr::TimeGat<'_>) -> TInner + Clone, G: FnMut(&TInner) -> Tr::Time + Clone + 'static,

type Batch = BatchEnter<<Tr as TraceReader>::Batch, TInner, F>

The type of an immutable collection of updates.

type Storage = <Tr as TraceReader>::Storage

Storage type for Self::Cursor. Likely related to Self::Batch.

type Cursor = CursorEnter<<Tr as TraceReader>::Cursor, TInner, F>

The type used to enumerate the collections contents.

fn map_batches<F2: FnMut(&Self::Batch)>(&self, f: F2)

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

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

Advances the frontier that constrains logical compaction.

fn get_logical_compaction(&mut self) -> AntichainRef<'_, TInner>

Reports the logical compaction frontier.

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

Advances the frontier that constrains physical compaction.

fn get_physical_compaction(&mut self) -> AntichainRef<'_, TInner>

Reports the physical compaction frontier.

fn cursor_through( &mut self, upper: AntichainRef<'_, TInner>, ) -> Option<(Self::Cursor, Self::Storage)>

Acquires a cursor to the restriction of the collection’s contents to updates at times not greater or equal to an element of upper.

fn cursor(&mut self) -> (Self::Cursor, Self::Storage)

Provides a cursor over updates contained in the trace.

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 by any empty batches.

impl<Tr, TInner, F, G> WithLayout for TraceEnter<Tr, TInner, F, G>

where Tr: TraceReader<Batch: Clone>, TInner: Refines<Tr::Time> + Lattice, F: Clone, G: Clone,

type Layout = (<<Tr as WithLayout>::Layout as Layout>::KeyContainer, <<Tr as WithLayout>::Layout as Layout>::ValContainer, Vec<TInner>, <<Tr as WithLayout>::Layout as Layout>::DiffContainer, <<Tr as WithLayout>::Layout as Layout>::OffsetContainer)

The layout.