#[non_exhaustive]pub struct StopReplicaRequest {
pub controller_id: BrokerId,
pub is_k_raft_controller: bool,
pub controller_epoch: i32,
pub broker_epoch: i64,
pub delete_partitions: bool,
pub ungrouped_partitions: Vec<StopReplicaPartitionV0>,
pub topics: Vec<StopReplicaTopicV1>,
pub topic_states: Vec<StopReplicaTopicState>,
pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
}
Expand description
Valid versions: 0-4
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.controller_id: BrokerId
The controller id.
Supported API versions: 0-4
is_k_raft_controller: bool
If KRaft controller id is used during migration. See KIP-866
Supported API versions: 4
controller_epoch: i32
The controller epoch.
Supported API versions: 0-4
broker_epoch: i64
The broker epoch.
Supported API versions: 1-4
delete_partitions: bool
Whether these partitions should be deleted.
Supported API versions: 0-2
ungrouped_partitions: Vec<StopReplicaPartitionV0>
The partitions to stop.
Supported API versions: 0
topics: Vec<StopReplicaTopicV1>
The topics to stop.
Supported API versions: 1-2
topic_states: Vec<StopReplicaTopicState>
Each topic.
Supported API versions: 3-4
unknown_tagged_fields: BTreeMap<i32, Bytes>
Other tagged fields
Implementations§
Source§impl StopReplicaRequest
impl StopReplicaRequest
Sourcepub fn with_controller_id(self, value: BrokerId) -> Self
pub fn with_controller_id(self, value: BrokerId) -> Self
Sets controller_id
to the passed value.
The controller id.
Supported API versions: 0-4
Sourcepub fn with_is_k_raft_controller(self, value: bool) -> Self
pub fn with_is_k_raft_controller(self, value: bool) -> Self
Sets is_k_raft_controller
to the passed value.
If KRaft controller id is used during migration. See KIP-866
Supported API versions: 4
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-4
Sourcepub fn with_broker_epoch(self, value: i64) -> Self
pub fn with_broker_epoch(self, value: i64) -> Self
Sets broker_epoch
to the passed value.
The broker epoch.
Supported API versions: 1-4
Sourcepub fn with_delete_partitions(self, value: bool) -> Self
pub fn with_delete_partitions(self, value: bool) -> Self
Sets delete_partitions
to the passed value.
Whether these partitions should be deleted.
Supported API versions: 0-2
Sourcepub fn with_ungrouped_partitions(
self,
value: Vec<StopReplicaPartitionV0>,
) -> Self
pub fn with_ungrouped_partitions( self, value: Vec<StopReplicaPartitionV0>, ) -> Self
Sets ungrouped_partitions
to the passed value.
The partitions to stop.
Supported API versions: 0
Sourcepub fn with_topics(self, value: Vec<StopReplicaTopicV1>) -> Self
pub fn with_topics(self, value: Vec<StopReplicaTopicV1>) -> Self
Sets topics
to the passed value.
The topics to stop.
Supported API versions: 1-2
Sourcepub fn with_topic_states(self, value: Vec<StopReplicaTopicState>) -> Self
pub fn with_topic_states(self, value: Vec<StopReplicaTopicState>) -> Self
Sets topic_states
to the passed value.
Each topic.
Supported API versions: 3-4
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 StopReplicaRequest
impl Clone for StopReplicaRequest
Source§fn clone(&self) -> StopReplicaRequest
fn clone(&self) -> StopReplicaRequest
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreSource§impl Debug for StopReplicaRequest
impl Debug for StopReplicaRequest
Source§impl Decodable for StopReplicaRequest
Available on crate feature broker
only.
impl Decodable for StopReplicaRequest
broker
only.Source§impl Default for StopReplicaRequest
impl Default for StopReplicaRequest
Source§impl Encodable for StopReplicaRequest
Available on crate feature client
only.
impl Encodable for StopReplicaRequest
client
only.Source§impl From<StopReplicaRequest> for RequestKind
Available on crate feature messages_enums
only.
impl From<StopReplicaRequest> for RequestKind
messages_enums
only.Source§fn from(value: StopReplicaRequest) -> RequestKind
fn from(value: StopReplicaRequest) -> RequestKind
Source§impl HeaderVersion for StopReplicaRequest
impl HeaderVersion for StopReplicaRequest
Source§fn header_version(version: i16) -> i16
fn header_version(version: i16) -> i16
Source§impl Message for StopReplicaRequest
impl Message for StopReplicaRequest
Source§const VERSIONS: VersionRange
const VERSIONS: VersionRange
Source§const DEPRECATED_VERSIONS: Option<VersionRange> = None
const DEPRECATED_VERSIONS: Option<VersionRange> = None
Source§impl PartialEq for StopReplicaRequest
impl PartialEq for StopReplicaRequest
Source§impl Request for StopReplicaRequest
Available on crate features client
and broker
only.
impl Request for StopReplicaRequest
client
and broker
only.