Struct kafka_protocol::messages::list_partition_reassignments_response::OngoingTopicReassignment
source · pub struct OngoingTopicReassignment {
pub name: TopicName,
pub partitions: Vec<OngoingPartitionReassignment>,
pub unknown_tagged_fields: BTreeMap<i32, Vec<u8>>,
}
Expand description
Valid versions: 0
Fields§
§name: TopicName
The topic name.
Supported API versions: 0
partitions: Vec<OngoingPartitionReassignment>
The ongoing reassignments for each partition.
Supported API versions: 0
unknown_tagged_fields: BTreeMap<i32, Vec<u8>>
Other tagged fields
Trait Implementations§
source§impl Clone for OngoingTopicReassignment
impl Clone for OngoingTopicReassignment
source§fn clone(&self) -> OngoingTopicReassignment
fn clone(&self) -> OngoingTopicReassignment
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 OngoingTopicReassignment
impl Debug for OngoingTopicReassignment
source§impl Decodable for OngoingTopicReassignment
impl Decodable for OngoingTopicReassignment
source§impl Default for OngoingTopicReassignment
impl Default for OngoingTopicReassignment
source§impl Encodable for OngoingTopicReassignment
impl Encodable for OngoingTopicReassignment
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 OngoingTopicReassignment
impl Message for OngoingTopicReassignment
source§const VERSIONS: VersionRange = _
const VERSIONS: VersionRange = _
The valid versions for this message.