use std::io;
use bytes::BufMut;
use crate::{codec::*, err_encode_message_unsupported};
#[derive(Debug, Default, Clone)]
pub struct OffsetFetchResponse {
pub throttle_time_ms: i32,
pub topics: Vec<OffsetFetchResponseTopic>,
pub error_code: i16,
pub groups: Vec<OffsetFetchResponseGroup>,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for OffsetFetchResponse {
fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> io::Result<()> {
if version >= 3 {
Int32.encode(buf, self.throttle_time_ms)?;
}
if version <= 7 {
NullableArray(Struct(version), version >= 6).encode(buf, self.topics.as_slice())?;
}
if (2..=7).contains(&version) {
Int16.encode(buf, self.error_code)?;
}
if version >= 8 {
NullableArray(Struct(version), true).encode(buf, self.groups.as_slice())?;
}
if version >= 6 {
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
}
Ok(())
}
}
#[derive(Debug, Default, Clone)]
pub struct OffsetFetchResponseTopic {
pub name: String,
pub partitions: Vec<OffsetFetchResponsePartition>,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for OffsetFetchResponseTopic {
fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> io::Result<()> {
if version > 7 {
Err(err_encode_message_unsupported(
version,
"OffsetFetchResponseTopic",
))?
}
NullableString(version >= 6).encode(buf, self.name.as_str())?;
NullableArray(Struct(version), version >= 6).encode(buf, self.partitions.as_slice())?;
if version >= 6 {
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
}
Ok(())
}
}
#[derive(Debug, Default, Clone)]
pub struct OffsetFetchResponsePartition {
pub partition_index: i32,
pub committed_offset: i32,
pub committed_leader_epoch: i32,
pub metadata: Option<String>,
pub error_code: i16,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for OffsetFetchResponsePartition {
fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> io::Result<()> {
Int32.encode(buf, self.partition_index)?;
Int32.encode(buf, self.committed_offset)?;
if version >= 5 {
Int32.encode(buf, self.committed_leader_epoch)?;
}
NullableString(version >= 6).encode(buf, self.metadata.as_deref())?;
Int16.encode(buf, self.error_code)?;
if version >= 6 {
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
}
Ok(())
}
}
#[derive(Debug, Default, Clone)]
pub struct OffsetFetchResponseGroup {
pub group_id: String,
pub topics: Vec<OffsetFetchResponseTopics>,
pub error_code: i16,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for OffsetFetchResponseGroup {
fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> io::Result<()> {
if version < 8 {
Err(err_encode_message_unsupported(
version,
"OffsetFetchResponseGroup",
))?
}
NullableString(true).encode(buf, self.group_id.as_str())?;
NullableArray(Struct(version), true).encode(buf, self.topics.as_slice())?;
Int16.encode(buf, self.error_code)?;
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
Ok(())
}
}
#[derive(Debug, Default, Clone)]
pub struct OffsetFetchResponseTopics {
pub name: String,
pub partitions: Vec<OffsetFetchResponsePartitions>,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for OffsetFetchResponseTopics {
fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> io::Result<()> {
NullableString(true).encode(buf, self.name.as_str())?;
NullableArray(Struct(version), true).encode(buf, self.partitions.as_slice())?;
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
Ok(())
}
}
#[derive(Debug, Default, Clone)]
pub struct OffsetFetchResponsePartitions {
pub partition_index: i32,
pub committed_offset: i64,
pub committed_leader_epoch: i32,
pub metadata: Option<String>,
pub error_code: i16,
pub unknown_tagged_fields: Vec<RawTaggedField>,
}
impl Encodable for OffsetFetchResponsePartitions {
fn encode<B: BufMut>(&self, buf: &mut B, _version: i16) -> io::Result<()> {
Int32.encode(buf, self.partition_index)?;
Int64.encode(buf, self.committed_offset)?;
Int32.encode(buf, self.committed_leader_epoch)?;
NullableString(true).encode(buf, self.metadata.as_deref())?;
Int16.encode(buf, self.error_code)?;
RawTaggedFieldList.encode(buf, &self.unknown_tagged_fields)?;
Ok(())
}
}