Struct kafka_protocol::messages::vote_request::PartitionData
source · pub struct PartitionData {
pub partition_index: i32,
pub candidate_epoch: i32,
pub candidate_id: BrokerId,
pub last_offset_epoch: i32,
pub last_offset: i64,
pub unknown_tagged_fields: BTreeMap<i32, Vec<u8>>,
}
Expand description
Valid versions: 0
Fields§
§partition_index: i32
The partition index.
Supported API versions: 0
candidate_epoch: i32
The bumped epoch of the candidate sending the request
Supported API versions: 0
candidate_id: BrokerId
The ID of the voter sending the request
Supported API versions: 0
last_offset_epoch: i32
The epoch of the last record written to the metadata log
Supported API versions: 0
last_offset: i64
The offset of the last record written to the metadata log
Supported API versions: 0
unknown_tagged_fields: BTreeMap<i32, Vec<u8>>
Other tagged fields
Trait Implementations§
source§impl Clone for PartitionData
impl Clone for PartitionData
source§fn clone(&self) -> PartitionData
fn clone(&self) -> PartitionData
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 PartitionData
impl Debug for PartitionData
source§impl Decodable for PartitionData
impl Decodable for PartitionData
source§impl Default for PartitionData
impl Default for PartitionData
source§impl Encodable for PartitionData
impl Encodable for PartitionData
source§fn encode<B: ByteBufMut>(
&self,
buf: &mut B,
version: i16
) -> Result<(), EncodeError>
fn encode<B: ByteBufMut>(
&self,
buf: &mut B,
version: i16
) -> Result<(), EncodeError>
Encode the message into the target buffer.
source§fn compute_size(&self, version: i16) -> Result<usize, EncodeError>
fn compute_size(&self, version: i16) -> Result<usize, EncodeError>
Compute the total size of the message when encoded.
source§impl Message for PartitionData
impl Message for PartitionData
source§const VERSIONS: VersionRange = _
const VERSIONS: VersionRange = _
The valid versions for this message.