use byteorder::WriteBytesExt;
use crate::codec::*;
use crate::IoResult;
#[derive(Debug, Default, Clone)]
pub struct MetadataResponse {
pub throttle_time_ms: i32,
pub brokers: Vec<MetadataResponseBroker>,
pub cluster_id: Option<String>,
pub controller_id: i32,
pub topics: Vec<MetadataResponseTopic>,
pub cluster_authorized_operations: i32,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for MetadataResponse {
fn write<B: WriteBytesExt>(&self, buf: &mut B, version: i16) -> IoResult<()> {
if version >= 3 {
Int32.encode(buf, self.throttle_time_ms)?;
}
NullableArray(Struct(version), version >= 9).encode(buf, self.brokers.as_slice())?;
if version >= 2 {
NullableString(version >= 9).encode(buf, self.cluster_id.as_deref())?;
}
if version >= 1 {
Int32.encode(buf, self.controller_id)?;
}
NullableArray(Struct(version), version >= 9).encode(buf, self.topics.as_slice())?;
if (8..=10).contains(&version) {
Int32.encode(buf, self.cluster_authorized_operations)?;
}
if version >= 9 {
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
}
Ok(())
}
fn calculate_size(&self, version: i16) -> usize {
let mut res = 0;
if version >= 3 {
res += Int32::SIZE; }
res += NullableArray(Struct(version), version >= 9).calculate_size(self.brokers.as_slice());
if version >= 2 {
res += NullableString(version >= 9).calculate_size(self.cluster_id.as_deref());
}
if version >= 1 {
res += Int32::SIZE; }
res += NullableArray(Struct(version), version >= 9).calculate_size(self.topics.as_slice());
if (8..=10).contains(&version) {
res += Int32::SIZE; }
if version >= 9 {
res += RawTaggedFieldList.calculate_size(&self.unknown_tagged_fields);
}
res
}
}
#[derive(Debug, Default, Clone)]
pub struct MetadataResponseBroker {
pub node_id: i32,
pub host: String,
pub port: i32,
pub rack: Option<String>,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for MetadataResponseBroker {
fn write<B: WriteBytesExt>(&self, buf: &mut B, version: i16) -> IoResult<()> {
Int32.encode(buf, self.node_id)?;
NullableString(version >= 9).encode(buf, self.host.as_str())?;
Int32.encode(buf, self.port)?;
if version >= 1 {
NullableString(version >= 9).encode(buf, self.rack.as_deref())?;
}
if version >= 9 {
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
}
Ok(())
}
fn calculate_size(&self, version: i16) -> usize {
let mut res = 0;
res += Int32::SIZE; res += NullableString(version >= 9).calculate_size(self.host.as_str());
res += Int32::SIZE; if version >= 1 {
res += NullableString(version >= 9).calculate_size(self.rack.as_deref());
}
if version >= 9 {
res += RawTaggedFieldList.calculate_size(&self.unknown_tagged_fields);
}
res
}
}
#[derive(Debug, Default, Clone)]
pub struct MetadataResponseTopic {
pub error_code: i16,
pub name: Option<String>,
pub topic_id: uuid::Uuid,
pub is_internal: bool,
pub partitions: Vec<MetadataResponsePartition>,
pub topic_authorized_operations: i32,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for MetadataResponseTopic {
fn write<B: WriteBytesExt>(&self, buf: &mut B, version: i16) -> IoResult<()> {
Int16.encode(buf, self.error_code)?;
match self.name {
None => {
if version >= 12 {
NullableString(true).encode(buf, None)?;
} else {
Err(err_encode_message_null("name"))?;
}
}
Some(ref name) => {
NullableString(version >= 9).encode(buf, name.as_str())?;
}
}
if version >= 10 {
Uuid.encode(buf, self.topic_id)?;
}
if version >= 1 {
Bool.encode(buf, self.is_internal)?;
}
NullableArray(Struct(version), version >= 9).encode(buf, self.partitions.as_slice())?;
if version >= 8 {
Int32.encode(buf, self.topic_authorized_operations)?;
}
if version >= 9 {
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
}
Ok(())
}
fn calculate_size(&self, version: i16) -> usize {
let mut res = 0;
res += Int16::SIZE; res += NullableString(version >= 9).calculate_size(self.name.as_deref());
if version >= 10 {
res += Uuid::SIZE; }
if version >= 1 {
res += Bool::SIZE; }
res +=
NullableArray(Struct(version), version >= 9).calculate_size(self.partitions.as_slice());
if version >= 8 {
res += Int32::SIZE; }
if version >= 9 {
res += RawTaggedFieldList.calculate_size(&self.unknown_tagged_fields);
}
res
}
}
#[derive(Debug, Default, Clone)]
pub struct MetadataResponsePartition {
pub error_code: i16,
pub partition_index: i32,
pub leader_id: i32,
pub leader_epoch: i32,
pub replica_nodes: Vec<i32>,
pub isr_nodes: Vec<i32>,
pub offline_replicas: Vec<i32>,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for MetadataResponsePartition {
fn write<B: WriteBytesExt>(&self, buf: &mut B, version: i16) -> IoResult<()> {
Int16.encode(buf, self.error_code)?;
Int32.encode(buf, self.partition_index)?;
Int32.encode(buf, self.leader_id)?;
if version >= 7 {
Int32.encode(buf, self.leader_epoch)?;
}
NullableArray(Int32, version >= 9).encode(buf, self.replica_nodes.as_slice())?;
NullableArray(Int32, version >= 9).encode(buf, self.isr_nodes.as_slice())?;
if version >= 5 {
NullableArray(Int32, version >= 9).encode(buf, self.offline_replicas.as_slice())?;
}
if version >= 9 {
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
}
Ok(())
}
fn calculate_size(&self, version: i16) -> usize {
let mut res = 0;
res += Int16::SIZE; res += Int32::SIZE; res += Int32::SIZE; if version >= 7 {
res += Int32::SIZE; }
res += NullableArray(Int32, version >= 9).calculate_size(self.replica_nodes.as_slice());
res += NullableArray(Int32, version >= 9).calculate_size(self.isr_nodes.as_slice());
if version >= 5 {
res +=
NullableArray(Int32, version >= 9).calculate_size(self.offline_replicas.as_slice());
}
if version >= 9 {
res += RawTaggedFieldList.calculate_size(&self.unknown_tagged_fields);
}
res
}
}