Struct pulsar::message::proto::MessageIdData
source · pub struct MessageIdData {
pub ledger_id: u64,
pub entry_id: u64,
pub partition: Option<i32>,
pub batch_index: Option<i32>,
pub ack_set: Vec<i64>,
pub batch_size: Option<i32>,
pub first_chunk_message_id: Option<Box<MessageIdData>>,
}
Fields§
§ledger_id: u64
§entry_id: u64
§partition: Option<i32>
§batch_index: Option<i32>
§ack_set: Vec<i64>
§batch_size: Option<i32>
§first_chunk_message_id: Option<Box<MessageIdData>>
For the chunk message id, we need to specify the first chunk message id.
Implementations§
source§impl MessageIdData
impl MessageIdData
sourcepub fn partition(&self) -> i32
pub fn partition(&self) -> i32
Returns the value of partition
, or the default value if partition
is unset.
sourcepub fn batch_index(&self) -> i32
pub fn batch_index(&self) -> i32
Returns the value of batch_index
, or the default value if batch_index
is unset.
sourcepub fn batch_size(&self) -> i32
pub fn batch_size(&self) -> i32
Returns the value of batch_size
, or the default value if batch_size
is unset.
Trait Implementations§
source§impl Clone for MessageIdData
impl Clone for MessageIdData
source§fn clone(&self) -> MessageIdData
fn clone(&self) -> MessageIdData
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 MessageIdData
impl Debug for MessageIdData
source§impl Default for MessageIdData
impl Default for MessageIdData
source§impl Hash for MessageIdData
impl Hash for MessageIdData
source§impl Message for MessageIdData
impl Message for MessageIdData
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<B>(&self, buf: &mut B) -> Result<(), EncodeError>
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>
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<B>(&self, buf: &mut B) -> Result<(), EncodeError>
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>
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<B>(buf: B) -> Result<Self, DecodeError>
fn decode<B>(buf: B) -> Result<Self, DecodeError>
Decodes an instance of the message from a buffer. Read more
source§fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>
Decodes a length-delimited instance of the message from the buffer.
source§fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>
Decodes an instance of the message from a buffer, and merges it into
self
. Read moresource§fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>
Decodes a length-delimited instance of the message from buffer, and
merges it into
self
.source§impl PartialEq for MessageIdData
impl PartialEq for MessageIdData
source§fn eq(&self, other: &MessageIdData) -> bool
fn eq(&self, other: &MessageIdData) -> bool
This method tests for
self
and other
values to be equal, and is used
by ==
.impl Eq for MessageIdData
impl StructuralPartialEq for MessageIdData
Auto Trait Implementations§
impl Freeze for MessageIdData
impl RefUnwindSafe for MessageIdData
impl Send for MessageIdData
impl Sync for MessageIdData
impl Unpin for MessageIdData
impl UnwindSafe for MessageIdData
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<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.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> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more