Struct mz_persist_client::internal::state::ProtoStateFieldDiffs

pub struct ProtoStateFieldDiffs {
    pub fields: Vec<i32>,
    pub diff_types: Vec<i32>,
    pub data_lens: Vec<u64>,
    pub data_bytes: Bytes,
}

A columnar encoding of Vec<StateFieldDiff<K, V>> with heterogeneous K and V.

• The number of diffs (len) == fields.len() == diff_types.len()
• Each diff is encoded into 1 data slice for the key and 1 (Insert, Delete) or 2 (Update) data slices for the val
• These data slices are concatenated together in data_bytes and the corresponding lengths of each slice in data_lens. (So number of data slices == data_lens.len().)
• We store the length of each data_slice, not e.g. an offset into data_bytes. This makes random access slower, but we only ever iterate (random access by diff idx would be tricky anyway because each diff gets a variable number of data slices based on it’s type.) Storing the lengths, OTOH, compresses much better with protobuf varints.

Fields

fields: Vec<i32>

diff_types: Vec<i32>

data_lens: Vec<u64>

data_bytes: Bytes

Implementations

impl ProtoStateFieldDiffs

pub fn fields( &self, ) -> FilterMap<Cloned<Iter<'_, i32>>, fn(_: i32) -> Option<ProtoStateField>>

Returns an iterator which yields the valid enum values contained in fields.

pub fn push_fields(&mut self, value: ProtoStateField)

Appends the provided enum value to fields.

pub fn diff_types( &self, ) -> FilterMap<Cloned<Iter<'_, i32>>, fn(_: i32) -> Option<ProtoStateFieldDiffType>>

Returns an iterator which yields the valid enum values contained in diff_types.

pub fn push_diff_types(&mut self, value: ProtoStateFieldDiffType)

Appends the provided enum value to diff_types.

impl ProtoStateFieldDiffs

pub fn into_writer(self) -> ProtoStateFieldDiffsWriter

pub fn iter<'a>(&'a self) -> ProtoStateFieldDiffsIter<'a>

pub fn validate(&self) -> Result<(), String>

Trait Implementations

impl Clone for ProtoStateFieldDiffs

fn clone(&self) -> ProtoStateFieldDiffs

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ProtoStateFieldDiffs

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

Formats the value using the given formatter.

impl Default for ProtoStateFieldDiffs

fn default() -> Self

Returns the “default value” for a type.

impl Message for ProtoStateFieldDiffs

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for ProtoStateFieldDiffs

fn eq(&self, other: &ProtoStateFieldDiffs) -> bool

Tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for ProtoStateFieldDiffs