Struct mz_persist_client::internal::state::ProtoHollowBatchPart
source · pub struct ProtoHollowBatchPart {
pub ts_rewrite: Option<ProtoU64Antichain>,
pub encoded_size_bytes: u64,
pub key_lower: Bytes,
pub structured_key_lower: Option<Bytes>,
pub diffs_sum: Option<i64>,
pub schema_id: Option<u64>,
pub key_stats: Option<Bytes>,
pub deprecated_schema_id: Option<u64>,
pub kind: Option<Kind>,
pub format: Option<Format>,
}
Fields§
§ts_rewrite: Option<ProtoU64Antichain>
§encoded_size_bytes: u64
Only set when Kind is Key or RunRef
key_lower: Bytes
§structured_key_lower: Option<Bytes>
§diffs_sum: Option<i64>
§schema_id: Option<u64>
§key_stats: Option<Bytes>
§deprecated_schema_id: Option<u64>
§kind: Option<Kind>
§format: Option<Format>
Implementations§
source§impl ProtoHollowBatchPart
impl ProtoHollowBatchPart
sourcepub fn diffs_sum(&self) -> i64
pub fn diffs_sum(&self) -> i64
Returns the value of diffs_sum
, or the default value if diffs_sum
is unset.
sourcepub fn deprecated_schema_id(&self) -> u64
pub fn deprecated_schema_id(&self) -> u64
Returns the value of deprecated_schema_id
, or the default value if deprecated_schema_id
is unset.
sourcepub fn structured_key_lower(&self) -> &[u8] ⓘ
pub fn structured_key_lower(&self) -> &[u8] ⓘ
Returns the value of structured_key_lower
, or the default value if structured_key_lower
is unset.
Trait Implementations§
source§impl Clone for ProtoHollowBatchPart
impl Clone for ProtoHollowBatchPart
source§fn clone(&self) -> ProtoHollowBatchPart
fn clone(&self) -> ProtoHollowBatchPart
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for ProtoHollowBatchPart
impl Debug for ProtoHollowBatchPart
source§impl Default for ProtoHollowBatchPart
impl Default for ProtoHollowBatchPart
source§impl<'de> Deserialize<'de> for ProtoHollowBatchPart
impl<'de> Deserialize<'de> for ProtoHollowBatchPart
source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
source§impl Message for ProtoHollowBatchPart
impl Message for ProtoHollowBatchPart
source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message to a buffer. Read more
source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message to a newly allocated buffer.
source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message with a length-delimiter to a buffer. Read more
source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message with a length-delimiter to a newly allocated buffer.
source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes an instance of the message from a buffer. Read more
source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes a length-delimited instance of the message from the buffer.
source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
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
. Read moresource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
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
.source§impl PartialEq for ProtoHollowBatchPart
impl PartialEq for ProtoHollowBatchPart
source§impl<T: Timestamp + Codec64> RustType<ProtoHollowBatchPart> for BatchPart<T>
impl<T: Timestamp + Codec64> RustType<ProtoHollowBatchPart> for BatchPart<T>
source§fn into_proto(&self) -> ProtoHollowBatchPart
fn into_proto(&self) -> ProtoHollowBatchPart
Convert a
Self
into a Proto
value.source§fn from_proto(proto: ProtoHollowBatchPart) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoHollowBatchPart) -> Result<Self, TryFromProtoError>
source§fn into_proto_owned(self) -> Proto
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
.source§impl<T: Timestamp + Codec64> RustType<ProtoHollowBatchPart> for HollowRunRef<T>
impl<T: Timestamp + Codec64> RustType<ProtoHollowBatchPart> for HollowRunRef<T>
source§fn into_proto(&self) -> ProtoHollowBatchPart
fn into_proto(&self) -> ProtoHollowBatchPart
Convert a
Self
into a Proto
value.source§fn from_proto(proto: ProtoHollowBatchPart) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoHollowBatchPart) -> Result<Self, TryFromProtoError>
source§fn into_proto_owned(self) -> Proto
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
.source§impl<T: Timestamp + Codec64> RustType<ProtoHollowBatchPart> for RunPart<T>
impl<T: Timestamp + Codec64> RustType<ProtoHollowBatchPart> for RunPart<T>
source§fn into_proto(&self) -> ProtoHollowBatchPart
fn into_proto(&self) -> ProtoHollowBatchPart
Convert a
Self
into a Proto
value.source§fn from_proto(proto: ProtoHollowBatchPart) -> Result<Self, TryFromProtoError>
fn from_proto(proto: ProtoHollowBatchPart) -> Result<Self, TryFromProtoError>
source§fn into_proto_owned(self) -> Proto
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
.source§impl Serialize for ProtoHollowBatchPart
impl Serialize for ProtoHollowBatchPart
impl StructuralPartialEq for ProtoHollowBatchPart
Auto Trait Implementations§
impl !Freeze for ProtoHollowBatchPart
impl RefUnwindSafe for ProtoHollowBatchPart
impl Send for ProtoHollowBatchPart
impl Sync for ProtoHollowBatchPart
impl Unpin for ProtoHollowBatchPart
impl UnwindSafe for ProtoHollowBatchPart
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§default unsafe fn clone_to_uninit(&self, dst: *mut T)
default unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)source§impl<T> FutureExt for T
impl<T> FutureExt for T
source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T
in a tonic::Request
Creates a shared type from an unshared type.
source§impl<T> Pointable for T
impl<T> Pointable for T
source§impl<T> ProgressEventTimestamp for T
impl<T> ProgressEventTimestamp for T
source§impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
impl<P, R> ProtoType<R> for Pwhere
R: RustType<P>,
source§fn into_rust(self) -> Result<R, TryFromProtoError>
fn into_rust(self) -> Result<R, TryFromProtoError>
See
RustType::from_proto
.source§fn from_rust(rust: &R) -> P
fn from_rust(rust: &R) -> P
See
RustType::into_proto
.source§impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
impl<'a, S, T> Semigroup<&'a S> for Twhere
T: Semigroup<S>,
source§fn plus_equals(&mut self, rhs: &&'a S)
fn plus_equals(&mut self, rhs: &&'a S)
The method of
std::ops::AddAssign
, for types that do not implement AddAssign
.