Struct persist::client::DecodedSnapshot

pub struct DecodedSnapshot<K, V> {
    snap: ArrangementSnapshot,
    _phantom: PhantomData<(K, V)>,
}

A consistent snapshot of all data currently stored for an id, with keys and vals decoded.

Fields

snap: ArrangementSnapshot

_phantom: PhantomData<(K, V)>

Implementations

impl<K: Codec, V: Codec> DecodedSnapshot<K, V>

pub(crate) fn new(snap: ArrangementSnapshot) -> Self

pub fn seqno(&self) -> SeqNo

Returns the SeqNo at which this snapshot was run.

All writes assigned a seqno < this are included.

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

Returns the since frontier of this snapshot.

All updates at times less than this frontier must be forwarded to some time in this frontier.

pub fn get_seal(&self) -> Antichain<u64>

A logical upper bound on the times that had been added to the collection when this snapshot was taken

Trait Implementations

impl<K: Debug, V: Debug> Debug for DecodedSnapshot<K, V>

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

Formats the value using the given formatter.

impl<K: Codec, V: Codec> Snapshot<K, V> for DecodedSnapshot<K, V>

type Iter = DecodedSnapshotIter<K, V>

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.