#[non_exhaustive]pub struct LeaderAndIsrPartitionState {Show 13 fields
pub topic_name: TopicName,
pub partition_index: i32,
pub controller_epoch: i32,
pub leader: BrokerId,
pub leader_epoch: i32,
pub isr: Vec<BrokerId>,
pub partition_epoch: i32,
pub replicas: Vec<BrokerId>,
pub adding_replicas: Vec<BrokerId>,
pub removing_replicas: Vec<BrokerId>,
pub is_new: bool,
pub leader_recovery_state: i8,
pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}
Expand description
Valid versions: 0-7
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.topic_name: TopicName
The topic name. This is only present in v0 or v1.
Supported API versions: 0-1
partition_index: i32
The partition index.
Supported API versions: 0-7
controller_epoch: i32
The controller epoch.
Supported API versions: 0-7
leader: BrokerId
The broker ID of the leader.
Supported API versions: 0-7
leader_epoch: i32
The leader epoch.
Supported API versions: 0-7
isr: Vec<BrokerId>
The in-sync replica IDs.
Supported API versions: 0-7
partition_epoch: i32
The current epoch for the partition. The epoch is a monotonically increasing value which is incremented after every partition change. (Since the LeaderAndIsr request is only used by the legacy controller, this corresponds to the zkVersion)
Supported API versions: 0-7
replicas: Vec<BrokerId>
The replica IDs.
Supported API versions: 0-7
adding_replicas: Vec<BrokerId>
The replica IDs that we are adding this partition to, or null if no replicas are being added.
Supported API versions: 3-7
removing_replicas: Vec<BrokerId>
The replica IDs that we are removing this partition from, or null if no replicas are being removed.
Supported API versions: 3-7
is_new: bool
Whether the replica should have existed on the broker or not.
Supported API versions: 1-7
leader_recovery_state: i8
1 if the partition is recovering from an unclean leader election; 0 otherwise.
Supported API versions: 6-7
unknown_tagged_fields: BTreeMap<i32, Bytes>
Other tagged fields
Implementations§
Source§impl LeaderAndIsrPartitionState
impl LeaderAndIsrPartitionState
Sourcepub fn with_topic_name(self, value: TopicName) -> Self
pub fn with_topic_name(self, value: TopicName) -> Self
Sets topic_name
to the passed value.
The topic name. This is only present in v0 or v1.
Supported API versions: 0-1
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-7
Sourcepub fn with_controller_epoch(self, value: i32) -> Self
pub fn with_controller_epoch(self, value: i32) -> Self
Sets controller_epoch
to the passed value.
The controller epoch.
Supported API versions: 0-7
Sourcepub fn with_leader(self, value: BrokerId) -> Self
pub fn with_leader(self, value: BrokerId) -> Self
Sets leader
to the passed value.
The broker ID of the leader.
Supported API versions: 0-7
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 leader epoch.
Supported API versions: 0-7
Sourcepub fn with_isr(self, value: Vec<BrokerId>) -> Self
pub fn with_isr(self, value: Vec<BrokerId>) -> Self
Sets isr
to the passed value.
The in-sync replica IDs.
Supported API versions: 0-7
Sourcepub fn with_partition_epoch(self, value: i32) -> Self
pub fn with_partition_epoch(self, value: i32) -> Self
Sets partition_epoch
to the passed value.
The current epoch for the partition. The epoch is a monotonically increasing value which is incremented after every partition change. (Since the LeaderAndIsr request is only used by the legacy controller, this corresponds to the zkVersion)
Supported API versions: 0-7
Sourcepub fn with_replicas(self, value: Vec<BrokerId>) -> Self
pub fn with_replicas(self, value: Vec<BrokerId>) -> Self
Sets replicas
to the passed value.
The replica IDs.
Supported API versions: 0-7
Sourcepub fn with_adding_replicas(self, value: Vec<BrokerId>) -> Self
pub fn with_adding_replicas(self, value: Vec<BrokerId>) -> Self
Sets adding_replicas
to the passed value.
The replica IDs that we are adding this partition to, or null if no replicas are being added.
Supported API versions: 3-7
Sourcepub fn with_removing_replicas(self, value: Vec<BrokerId>) -> Self
pub fn with_removing_replicas(self, value: Vec<BrokerId>) -> Self
Sets removing_replicas
to the passed value.
The replica IDs that we are removing this partition from, or null if no replicas are being removed.
Supported API versions: 3-7
Sourcepub fn with_is_new(self, value: bool) -> Self
pub fn with_is_new(self, value: bool) -> Self
Sets is_new
to the passed value.
Whether the replica should have existed on the broker or not.
Supported API versions: 1-7
Sourcepub fn with_leader_recovery_state(self, value: i8) -> Self
pub fn with_leader_recovery_state(self, value: i8) -> Self
Sets leader_recovery_state
to the passed value.
1 if the partition is recovering from an unclean leader election; 0 otherwise.
Supported API versions: 6-7
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 LeaderAndIsrPartitionState
impl Clone for LeaderAndIsrPartitionState
Source§fn clone(&self) -> LeaderAndIsrPartitionState
fn clone(&self) -> LeaderAndIsrPartitionState
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for LeaderAndIsrPartitionState
impl Debug for LeaderAndIsrPartitionState
Source§impl Decodable for LeaderAndIsrPartitionState
Available on crate feature broker
only.
impl Decodable for LeaderAndIsrPartitionState
broker
only.Source§impl Default for LeaderAndIsrPartitionState
impl Default for LeaderAndIsrPartitionState
Source§impl Encodable for LeaderAndIsrPartitionState
Available on crate feature client
only.
impl Encodable for LeaderAndIsrPartitionState
client
only.