1use bytes::BufMut;
4
5use crate::primitives::fixed::{get_i16, get_i32, get_i64, put_i16, put_i32, put_i64};
6use crate::primitives::string_bytes::{
7 compact_nullable_string_len, compact_string_len, nullable_string_len,
8 put_compact_nullable_string, put_compact_string, put_nullable_string, put_string,
9 string_len,
10};
11use crate::primitives::string_bytes_borrowed::{
12 get_compact_nullable_string_borrowed, get_compact_string_borrowed,
13 get_nullable_string_borrowed, get_string_borrowed,
14};
15use crate::tagged_fields::{read_tagged_fields, tagged_fields_len, WriteTaggedFields};
16use crate::{DecodeBorrow, Encode, ProtocolError, UnknownTaggedFields};
17
18pub const API_KEY: i16 = 90;
19pub const MIN_VERSION: i16 = 0;
20pub const MAX_VERSION: i16 = 1;
21pub const FLEXIBLE_MIN: i16 = 0;
22
23#[inline]
24fn is_flexible(version: i16) -> bool { version >= FLEXIBLE_MIN }
25
26#[derive(Debug, Clone, PartialEq, Eq)]
27pub struct DescribeShareGroupOffsetsResponse<'a> {
28 pub throttle_time_ms: i32,
29 pub groups: Vec<DescribeShareGroupOffsetsResponseGroup<'a>>,
30 pub unknown_tagged_fields: UnknownTaggedFields,
31}
32
33impl<'a> Default for DescribeShareGroupOffsetsResponse<'a> {
34 fn default() -> Self {
35 Self {
36 throttle_time_ms: 0i32,
37 groups: Vec::new(),
38 unknown_tagged_fields: Default::default(),
39 }
40 }
41}
42
43impl<'a> DescribeShareGroupOffsetsResponse<'a> {
44 pub fn to_owned(&self) -> crate::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponse {
45 crate::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponse {
46 throttle_time_ms: (self.throttle_time_ms),
47 groups: (self.groups).iter().map(|it| it.to_owned()).collect(),
48 unknown_tagged_fields: self.unknown_tagged_fields.clone(),
49 }
50 }
51}
52
53impl<'a> Encode for DescribeShareGroupOffsetsResponse<'a> {
54 fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> Result<(), ProtocolError> {
55 if !(MIN_VERSION..=MAX_VERSION).contains(&version) {
56 return Err(ProtocolError::UnsupportedVersion { api_key: API_KEY, version });
57 }
58 let flex = is_flexible(version);
59 if version >= 0 { put_i32(buf, self.throttle_time_ms) }
60 if version >= 0 { { crate::primitives::array::put_array_len(buf, (self.groups).len(), flex); for it in &self.groups { it.encode(buf, version)?; } } }
61 if flex {
62 let tagged = WriteTaggedFields::new();
63 tagged.write(buf, &self.unknown_tagged_fields);
64 }
65 Ok(())
66 }
67 fn encoded_len(&self, version: i16) -> usize {
68 let flex = is_flexible(version);
69 let mut n: usize = 0;
70 if version >= 0 { n += 4; }
71 if version >= 0 { n += { let prefix = crate::primitives::array::array_len_prefix_len((self.groups).len(), flex); let body: usize = (self.groups).iter().map(|it| it.encoded_len(version)).sum(); prefix + body }; }
72 if flex {
73 let known_pairs: Vec<(u32, usize)> = Vec::new();
74 n += tagged_fields_len(&known_pairs, &self.unknown_tagged_fields);
75 }
76 n
77 }
78}
79
80impl<'de> DecodeBorrow<'de> for DescribeShareGroupOffsetsResponse<'de> {
81 fn decode_borrow(buf: &mut &'de [u8], version: i16) -> Result<Self, ProtocolError> {
82 if !(MIN_VERSION..=MAX_VERSION).contains(&version) {
83 return Err(ProtocolError::UnsupportedVersion { api_key: API_KEY, version });
84 }
85 let flex = is_flexible(version);
86 let mut out = Self::default();
87 if version >= 0 { out.throttle_time_ms = get_i32(buf)?; }
88 if version >= 0 { out.groups = { let n = crate::primitives::array::get_array_len(buf, flex)?; let mut v = Vec::with_capacity(n); for _ in 0..n { v.push(DescribeShareGroupOffsetsResponseGroup::decode_borrow(buf, version)?); } v }; }
89 if flex {
90 out.unknown_tagged_fields = read_tagged_fields(buf, |_tag, _payload| {
91 Ok(false)
92 })?;
93 }
94 Ok(out)
95 }
96}
97
98#[derive(Debug, Clone, PartialEq, Eq)]
99pub struct DescribeShareGroupOffsetsResponseGroup<'a> {
100 pub group_id: &'a str,
101 pub topics: Vec<DescribeShareGroupOffsetsResponseTopic<'a>>,
102 pub error_code: i16,
103 pub error_message: Option<&'a str>,
104 pub unknown_tagged_fields: UnknownTaggedFields,
105}
106
107impl<'a> Default for DescribeShareGroupOffsetsResponseGroup<'a> {
108 fn default() -> Self {
109 Self {
110 group_id: "",
111 topics: Vec::new(),
112 error_code: 0i16,
113 error_message: None,
114 unknown_tagged_fields: Default::default(),
115 }
116 }
117}
118
119impl<'a> DescribeShareGroupOffsetsResponseGroup<'a> {
120 pub fn to_owned(&self) -> crate::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponseGroup {
121 crate::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponseGroup {
122 group_id: (self.group_id).to_string(),
123 topics: (self.topics).iter().map(|it| it.to_owned()).collect(),
124 error_code: (self.error_code),
125 error_message: (self.error_message).map(|s| s.to_string()),
126 unknown_tagged_fields: self.unknown_tagged_fields.clone(),
127 }
128 }
129}
130
131impl<'a> Encode for DescribeShareGroupOffsetsResponseGroup<'a> {
132 fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> Result<(), ProtocolError> {
133 let flex = version >= 0;
134 if version >= 0 { if flex { put_compact_string(buf, self.group_id) } else { put_string(buf, self.group_id) } }
135 if version >= 0 { { crate::primitives::array::put_array_len(buf, (self.topics).len(), flex); for it in &self.topics { it.encode(buf, version)?; } } }
136 if version >= 0 { put_i16(buf, self.error_code) }
137 if version >= 0 { if flex { put_compact_nullable_string(buf, self.error_message) } else { put_nullable_string(buf, self.error_message) } }
138 if flex {
139 let tagged = WriteTaggedFields::new();
140 tagged.write(buf, &self.unknown_tagged_fields);
141 }
142 Ok(())
143 }
144 fn encoded_len(&self, version: i16) -> usize {
145 let flex = version >= 0;
146 let mut n: usize = 0;
147 if version >= 0 { n += if flex { compact_string_len(self.group_id) } else { string_len(self.group_id) }; }
148 if version >= 0 { n += { let prefix = crate::primitives::array::array_len_prefix_len((self.topics).len(), flex); let body: usize = (self.topics).iter().map(|it| it.encoded_len(version)).sum(); prefix + body }; }
149 if version >= 0 { n += 2; }
150 if version >= 0 { n += if flex { compact_nullable_string_len(self.error_message) } else { nullable_string_len(self.error_message) }; }
151 if flex {
152 let known_pairs: Vec<(u32, usize)> = Vec::new();
153 n += tagged_fields_len(&known_pairs, &self.unknown_tagged_fields);
154 }
155 n
156 }
157}
158
159impl<'de> DecodeBorrow<'de> for DescribeShareGroupOffsetsResponseGroup<'de> {
160 fn decode_borrow(buf: &mut &'de [u8], version: i16) -> Result<Self, ProtocolError> {
161 let flex = version >= 0;
162 let mut out = Self::default();
163 if version >= 0 { out.group_id = if flex { get_compact_string_borrowed(buf)? } else { get_string_borrowed(buf)? }; }
164 if version >= 0 { out.topics = { let n = crate::primitives::array::get_array_len(buf, flex)?; let mut v = Vec::with_capacity(n); for _ in 0..n { v.push(DescribeShareGroupOffsetsResponseTopic::decode_borrow(buf, version)?); } v }; }
165 if version >= 0 { out.error_code = get_i16(buf)?; }
166 if version >= 0 { out.error_message = if flex { get_compact_nullable_string_borrowed(buf)? } else { get_nullable_string_borrowed(buf)? }; }
167 if flex {
168 out.unknown_tagged_fields = read_tagged_fields(buf, |_tag, _payload| {
169 Ok(false)
170 })?;
171 }
172 Ok(out)
173 }
174}
175
176#[derive(Debug, Clone, PartialEq, Eq)]
177pub struct DescribeShareGroupOffsetsResponseTopic<'a> {
178 pub topic_name: &'a str,
179 pub topic_id: crate::primitives::uuid::Uuid,
180 pub partitions: Vec<DescribeShareGroupOffsetsResponsePartition<'a>>,
181 pub unknown_tagged_fields: UnknownTaggedFields,
182}
183
184impl<'a> Default for DescribeShareGroupOffsetsResponseTopic<'a> {
185 fn default() -> Self {
186 Self {
187 topic_name: "",
188 topic_id: Default::default(),
189 partitions: Vec::new(),
190 unknown_tagged_fields: Default::default(),
191 }
192 }
193}
194
195impl<'a> DescribeShareGroupOffsetsResponseTopic<'a> {
196 pub fn to_owned(&self) -> crate::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponseTopic {
197 crate::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponseTopic {
198 topic_name: (self.topic_name).to_string(),
199 topic_id: (self.topic_id),
200 partitions: (self.partitions).iter().map(|it| it.to_owned()).collect(),
201 unknown_tagged_fields: self.unknown_tagged_fields.clone(),
202 }
203 }
204}
205
206impl<'a> Encode for DescribeShareGroupOffsetsResponseTopic<'a> {
207 fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> Result<(), ProtocolError> {
208 let flex = version >= 0;
209 if version >= 0 { if flex { put_compact_string(buf, self.topic_name) } else { put_string(buf, self.topic_name) } }
210 if version >= 0 { crate::primitives::uuid::put_uuid(buf, self.topic_id) }
211 if version >= 0 { { crate::primitives::array::put_array_len(buf, (self.partitions).len(), flex); for it in &self.partitions { it.encode(buf, version)?; } } }
212 if flex {
213 let tagged = WriteTaggedFields::new();
214 tagged.write(buf, &self.unknown_tagged_fields);
215 }
216 Ok(())
217 }
218 fn encoded_len(&self, version: i16) -> usize {
219 let flex = version >= 0;
220 let mut n: usize = 0;
221 if version >= 0 { n += if flex { compact_string_len(self.topic_name) } else { string_len(self.topic_name) }; }
222 if version >= 0 { n += 16; }
223 if version >= 0 { n += { let prefix = crate::primitives::array::array_len_prefix_len((self.partitions).len(), flex); let body: usize = (self.partitions).iter().map(|it| it.encoded_len(version)).sum(); prefix + body }; }
224 if flex {
225 let known_pairs: Vec<(u32, usize)> = Vec::new();
226 n += tagged_fields_len(&known_pairs, &self.unknown_tagged_fields);
227 }
228 n
229 }
230}
231
232impl<'de> DecodeBorrow<'de> for DescribeShareGroupOffsetsResponseTopic<'de> {
233 fn decode_borrow(buf: &mut &'de [u8], version: i16) -> Result<Self, ProtocolError> {
234 let flex = version >= 0;
235 let mut out = Self::default();
236 if version >= 0 { out.topic_name = if flex { get_compact_string_borrowed(buf)? } else { get_string_borrowed(buf)? }; }
237 if version >= 0 { out.topic_id = crate::primitives::uuid::get_uuid(buf)?; }
238 if version >= 0 { out.partitions = { let n = crate::primitives::array::get_array_len(buf, flex)?; let mut v = Vec::with_capacity(n); for _ in 0..n { v.push(DescribeShareGroupOffsetsResponsePartition::decode_borrow(buf, version)?); } v }; }
239 if flex {
240 out.unknown_tagged_fields = read_tagged_fields(buf, |_tag, _payload| {
241 Ok(false)
242 })?;
243 }
244 Ok(out)
245 }
246}
247
248#[derive(Debug, Clone, PartialEq, Eq)]
249pub struct DescribeShareGroupOffsetsResponsePartition<'a> {
250 pub partition_index: i32,
251 pub start_offset: i64,
252 pub leader_epoch: i32,
253 pub lag: i64,
254 pub error_code: i16,
255 pub error_message: Option<&'a str>,
256 pub unknown_tagged_fields: UnknownTaggedFields,
257}
258
259impl<'a> Default for DescribeShareGroupOffsetsResponsePartition<'a> {
260 fn default() -> Self {
261 Self {
262 partition_index: 0i32,
263 start_offset: 0i64,
264 leader_epoch: 0i32,
265 lag: -1i64,
266 error_code: 0i16,
267 error_message: None,
268 unknown_tagged_fields: Default::default(),
269 }
270 }
271}
272
273impl<'a> DescribeShareGroupOffsetsResponsePartition<'a> {
274 pub fn to_owned(&self) -> crate::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponsePartition {
275 crate::owned::describe_share_group_offsets_response::DescribeShareGroupOffsetsResponsePartition {
276 partition_index: (self.partition_index),
277 start_offset: (self.start_offset),
278 leader_epoch: (self.leader_epoch),
279 lag: (self.lag),
280 error_code: (self.error_code),
281 error_message: (self.error_message).map(|s| s.to_string()),
282 unknown_tagged_fields: self.unknown_tagged_fields.clone(),
283 }
284 }
285}
286
287impl<'a> Encode for DescribeShareGroupOffsetsResponsePartition<'a> {
288 fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> Result<(), ProtocolError> {
289 let flex = version >= 0;
290 if version >= 0 { put_i32(buf, self.partition_index) }
291 if version >= 0 { put_i64(buf, self.start_offset) }
292 if version >= 0 { put_i32(buf, self.leader_epoch) }
293 if version >= 1 { put_i64(buf, self.lag) }
294 if version >= 0 { put_i16(buf, self.error_code) }
295 if version >= 0 { if flex { put_compact_nullable_string(buf, self.error_message) } else { put_nullable_string(buf, self.error_message) } }
296 if flex {
297 let tagged = WriteTaggedFields::new();
298 tagged.write(buf, &self.unknown_tagged_fields);
299 }
300 Ok(())
301 }
302 fn encoded_len(&self, version: i16) -> usize {
303 let flex = version >= 0;
304 let mut n: usize = 0;
305 if version >= 0 { n += 4; }
306 if version >= 0 { n += 8; }
307 if version >= 0 { n += 4; }
308 if version >= 1 { n += 8; }
309 if version >= 0 { n += 2; }
310 if version >= 0 { n += if flex { compact_nullable_string_len(self.error_message) } else { nullable_string_len(self.error_message) }; }
311 if flex {
312 let known_pairs: Vec<(u32, usize)> = Vec::new();
313 n += tagged_fields_len(&known_pairs, &self.unknown_tagged_fields);
314 }
315 n
316 }
317}
318
319impl<'de> DecodeBorrow<'de> for DescribeShareGroupOffsetsResponsePartition<'de> {
320 fn decode_borrow(buf: &mut &'de [u8], version: i16) -> Result<Self, ProtocolError> {
321 let flex = version >= 0;
322 let mut out = Self::default();
323 if version >= 0 { out.partition_index = get_i32(buf)?; }
324 if version >= 0 { out.start_offset = get_i64(buf)?; }
325 if version >= 0 { out.leader_epoch = get_i32(buf)?; }
326 if version >= 1 { out.lag = get_i64(buf)?; }
327 if version >= 0 { out.error_code = get_i16(buf)?; }
328 if version >= 0 { out.error_message = if flex { get_compact_nullable_string_borrowed(buf)? } else { get_nullable_string_borrowed(buf)? }; }
329 if flex {
330 out.unknown_tagged_fields = read_tagged_fields(buf, |_tag, _payload| {
331 Ok(false)
332 })?;
333 }
334 Ok(out)
335 }
336}