Struct mz_persist_client::internal::state_diff::StateDiff

pub struct StateDiff<T> {

    pub(crate) applier_version: Version,
    pub(crate) seqno_from: SeqNo,
    pub(crate) seqno_to: SeqNo,
    pub(crate) walltime_ms: u64,
    pub(crate) latest_rollup_key: PartialRollupKey,
    pub(crate) rollups: Vec<StateFieldDiff<SeqNo, HollowRollup>>,
    pub(crate) hostname: Vec<StateFieldDiff<(), String>>,
    pub(crate) last_gc_req: Vec<StateFieldDiff<(), SeqNo>>,
    pub(crate) leased_readers: Vec<StateFieldDiff<LeasedReaderId, LeasedReaderState<T>>>,
    pub(crate) critical_readers: Vec<StateFieldDiff<CriticalReaderId, CriticalReaderState<T>>>,
    pub(crate) writers: Vec<StateFieldDiff<WriterId, WriterState<T>>>,
    pub(crate) since: Vec<StateFieldDiff<(), Antichain<T>>>,
    pub(crate) spine: Vec<StateFieldDiff<HollowBatch<T>, ()>>,
}

Fields

applier_version: Version

seqno_from: SeqNo

seqno_to: SeqNo

walltime_ms: u64

latest_rollup_key: PartialRollupKey

rollups: Vec<StateFieldDiff<SeqNo, HollowRollup>>

hostname: Vec<StateFieldDiff<(), String>>

last_gc_req: Vec<StateFieldDiff<(), SeqNo>>

leased_readers: Vec<StateFieldDiff<LeasedReaderId, LeasedReaderState<T>>>

critical_readers: Vec<StateFieldDiff<CriticalReaderId, CriticalReaderState<T>>>

writers: Vec<StateFieldDiff<WriterId, WriterState<T>>>

since: Vec<StateFieldDiff<(), Antichain<T>>>

spine: Vec<StateFieldDiff<HollowBatch<T>, ()>>

Implementations

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

pub fn encode<B>(&self, buf: &mut B)where B: BufMut,

pub fn decode(build_version: &Version, buf: Bytes) -> Self

impl<T: Timestamp + Codec64> StateDiff<T>

pub fn new( applier_version: Version, seqno_from: SeqNo, seqno_to: SeqNo, walltime_ms: u64, latest_rollup_key: PartialRollupKey ) -> Self

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

pub fn from_diff(from: &State<T>, to: &State<T>) -> Self

pub(crate) fn map_blob_inserts<F: for<'a> FnMut(HollowBlobRef<'a, T>)>( &self, f: F )

pub(crate) fn map_blob_deletes<F: for<'a> FnMut(HollowBlobRef<'a, T>)>( &self, f: F )

pub fn validate_roundtrip<K, V, D>( metrics: &Metrics, from_state: &TypedState<K, V, T, D>, diff: &Self, to_state: &TypedState<K, V, T, D> ) -> Result<(), String>where K: Codec + Debug, V: Codec + Debug, D: Semigroup + Codec64,

Trait Implementations

impl<T: Clone> Clone for StateDiff<T>

fn clone(&self) -> StateDiff<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for StateDiff<T>

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

Formats the value using the given formatter.

impl<T: PartialEq> PartialEq for StateDiff<T>

fn eq(&self, other: &StateDiff<T>) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T: Timestamp + Codec64> RustType<ProtoStateDiff> for StateDiff<T>

fn into_proto(&self) -> ProtoStateDiff

Convert a Self into a Proto value.

fn from_proto(proto: ProtoStateDiff) -> Result<Self, TryFromProtoError>

Consume and convert a Proto back into a Self value.

impl<T> StructuralPartialEq for StateDiff<T>