Struct mz_persist_client::internal::encoding::Rollup

pub struct Rollup<T> {
    pub(crate) state: UntypedState<T>,
    pub(crate) diffs: Option<InlinedDiffs>,
}

A struct that maps 1:1 with ProtoRollup.

Contains State, and optionally the diffs between (state.latest_rollup.seqno, state.seqno]

diffs is always expected to be Some when writing new rollups, but may be None when deserializing rollups that were persisted before we started inlining diffs.

Fields

state: UntypedState<T>

diffs: Option<InlinedDiffs>

Implementations

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

pub(crate) fn from(state: UntypedState<T>, diffs: Vec<VersionedData>) -> Self

Creates a StateRollup from a state and diffs from its last rollup.

The diffs must span the seqno range (state.last_rollup().seqno, state.seqno].

pub(crate) fn from_untyped_state_without_diffs(state: UntypedState<T>) -> Self

pub(crate) fn from_state_without_diffs( state: State<T>, key_codec: String, val_codec: String, ts_codec: String, diff_codec: String, ) -> Self

Trait Implementations

impl<T: Debug> Debug for Rollup<T>

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

Formats the value using the given formatter.

impl<T: Timestamp + Lattice + Codec64> RustType<ProtoRollup> for Rollup<T>

fn into_proto(&self) -> ProtoRollup

Convert a Self into a Proto value.

fn from_proto(x: ProtoRollup) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

fn into_proto_owned(self) -> Proto

A zero clone version of Self::into_proto that types can optionally implement, otherwise, the default implementation delegates to Self::into_proto.