Struct mz_persist_client::internal::state_versions::StateVersionsIter

pub struct StateVersionsIter<T> {
    cfg: PersistConfig,
    metrics: Arc<Metrics>,
    state: State<T>,
    diffs: Vec<VersionedData>,
    key_codec: String,
    val_codec: String,
    diff_codec: String,
    validator: ReferencedBlobValidator<T>,
}

An iterator over consecutive versions of State.

Fields

cfg: PersistConfig

metrics: Arc<Metrics>

state: State<T>

diffs: Vec<VersionedData>

key_codec: String

val_codec: String

diff_codec: String

validator: ReferencedBlobValidator<T>

Implementations

impl<T: Timestamp + Lattice + Codec64> StateVersionsIter<T>

fn new( cfg: PersistConfig, metrics: Arc<Metrics>, state: State<T>, diffs: Vec<VersionedData>, key_codec: String, val_codec: String, diff_codec: String, ) -> Self

pub fn len(&self) -> usize

pub fn next<F: for<'a> FnMut(InspectDiff<'a, T>)>( &mut self, inspect_diff_fn: F, ) -> Option<&State<T>>

Advances first to some starting state (in practice, usually the first live state), and then through each successive state, for as many diffs as this iterator was initialized with.

The inspect_diff_fn callback can be used to inspect diffs directly as they are applied. The first call to next returns a InspectDiff::FromInitial representing a diff from the initial state.

pub fn state(&self) -> &State<T>

pub fn into_rollup_proto_without_diffs(&self) -> impl Serialize