#[non_exhaustive]pub struct PartitionData {
pub partition_index: i32,
pub error_code: i16,
pub error_message: Option<StrBytes>,
pub leader_id: BrokerId,
pub leader_epoch: i32,
pub high_watermark: i64,
pub current_voters: Vec<ReplicaState>,
pub observers: Vec<ReplicaState>,
pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}
Expand description
Valid versions: 0-2
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. }
syntax; cannot be matched against without a wildcard ..
; and struct update syntax will not work.partition_index: i32
The partition index.
Supported API versions: 0-2
error_code: i16
Supported API versions: 0-2
error_message: Option<StrBytes>
The error message, or null if there was no error.
Supported API versions: 2
leader_id: BrokerId
The ID of the current leader or -1 if the leader is unknown.
Supported API versions: 0-2
leader_epoch: i32
The latest known leader epoch
Supported API versions: 0-2
high_watermark: i64
Supported API versions: 0-2
current_voters: Vec<ReplicaState>
Supported API versions: 0-2
observers: Vec<ReplicaState>
Supported API versions: 0-2
unknown_tagged_fields: BTreeMap<i32, Bytes>
Other tagged fields
Implementations§
Source§impl PartitionData
impl PartitionData
Sourcepub fn with_partition_index(self, value: i32) -> Self
pub fn with_partition_index(self, value: i32) -> Self
Sets partition_index
to the passed value.
The partition index.
Supported API versions: 0-2
Sourcepub fn with_error_code(self, value: i16) -> Self
pub fn with_error_code(self, value: i16) -> Self
Sets error_code
to the passed value.
Supported API versions: 0-2
Sourcepub fn with_error_message(self, value: Option<StrBytes>) -> Self
pub fn with_error_message(self, value: Option<StrBytes>) -> Self
Sets error_message
to the passed value.
The error message, or null if there was no error.
Supported API versions: 2
Sourcepub fn with_leader_id(self, value: BrokerId) -> Self
pub fn with_leader_id(self, value: BrokerId) -> Self
Sets leader_id
to the passed value.
The ID of the current leader or -1 if the leader is unknown.
Supported API versions: 0-2
Sourcepub fn with_leader_epoch(self, value: i32) -> Self
pub fn with_leader_epoch(self, value: i32) -> Self
Sets leader_epoch
to the passed value.
The latest known leader epoch
Supported API versions: 0-2
Sourcepub fn with_high_watermark(self, value: i64) -> Self
pub fn with_high_watermark(self, value: i64) -> Self
Sets high_watermark
to the passed value.
Supported API versions: 0-2
Sourcepub fn with_current_voters(self, value: Vec<ReplicaState>) -> Self
pub fn with_current_voters(self, value: Vec<ReplicaState>) -> Self
Sets current_voters
to the passed value.
Supported API versions: 0-2
Sourcepub fn with_observers(self, value: Vec<ReplicaState>) -> Self
pub fn with_observers(self, value: Vec<ReplicaState>) -> Self
Sets observers
to the passed value.
Supported API versions: 0-2
Sourcepub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self
pub fn with_unknown_tagged_fields(self, value: BTreeMap<i32, Bytes>) -> Self
Sets unknown_tagged_fields to the passed value.
Sourcepub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self
pub fn with_unknown_tagged_field(self, key: i32, value: Bytes) -> Self
Inserts an entry into unknown_tagged_fields.
Trait Implementations§
Source§impl Clone for PartitionData
impl Clone for PartitionData
Source§fn clone(&self) -> PartitionData
fn clone(&self) -> PartitionData
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for PartitionData
impl Debug for PartitionData
Source§impl Decodable for PartitionData
Available on crate feature client
only.
impl Decodable for PartitionData
client
only.Source§impl Default for PartitionData
impl Default for PartitionData
Source§impl Encodable for PartitionData
Available on crate feature broker
only.
impl Encodable for PartitionData
broker
only.