kacrab_protocol/generated/
delete_share_group_offsets_response.rs

1//! Generated from DeleteShareGroupOffsetsResponse.json - DO NOT EDIT
2#![allow(
3    missing_docs,
4    clippy::all,
5    clippy::pedantic,
6    clippy::nursery,
7    clippy::arithmetic_side_effects,
8    reason = "Generated protocol modules mirror Kafka's schema shape and intentionally trade \
9              hand-written lint style for reproducible wire-code output."
10)]
11use bytes::{Bytes, BytesMut};
12
13use crate::*;
14
15#[derive(Debug, Clone, PartialEq)]
16pub struct DeleteShareGroupOffsetsResponseData {
17    /// The duration in milliseconds for which the request was throttled due to a quota violation,
18    /// or zero if the request did not violate any quota.
19    pub throttle_time_ms: i32,
20    /// The top-level error code, or 0 if there was no error.
21    pub error_code: i16,
22    /// The top-level error message, or null if there was no error.
23    pub error_message: Option<KafkaString>,
24    /// The results for each topic.
25    pub responses: Vec<DeleteShareGroupOffsetsResponseTopic>,
26    pub _unknown_tagged_fields: Vec<RawTaggedField>,
27}
28impl Default for DeleteShareGroupOffsetsResponseData {
29    fn default() -> Self {
30        Self {
31            throttle_time_ms: 0_i32,
32            error_code: 0_i16,
33            error_message: None,
34            responses: Vec::new(),
35            _unknown_tagged_fields: Vec::new(),
36        }
37    }
38}
39impl DeleteShareGroupOffsetsResponseData {
40    pub fn with_throttle_time_ms(mut self, value: i32) -> Self {
41        self.throttle_time_ms = value;
42        self
43    }
44    pub fn with_error_code(mut self, value: i16) -> Self {
45        self.error_code = value;
46        self
47    }
48    pub fn with_error_message(mut self, value: Option<KafkaString>) -> Self {
49        self.error_message = value;
50        self
51    }
52    pub fn with_responses(mut self, value: Vec<DeleteShareGroupOffsetsResponseTopic>) -> Self {
53        self.responses = value;
54        self
55    }
56    pub fn read(buf: &mut Bytes, version: i16) -> Result<Self> {
57        if version < 0 || version > 0 {
58            return Err(UnsupportedVersion::new(92, version).into());
59        }
60        let throttle_time_ms;
61        let error_code;
62        let error_message;
63        let responses;
64        let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
65        throttle_time_ms = read_i32(buf)?;
66        error_code = read_i16(buf)?;
67        error_message = read_compact_nullable_string(buf)?;
68        responses = {
69            let len = read_compact_array_length(buf)?;
70            let mut arr = Vec::with_capacity(array_read_capacity(len, (buf).len()));
71            for _ in 0..len {
72                arr.push(DeleteShareGroupOffsetsResponseTopic::read(buf, version)?);
73            }
74            arr
75        };
76        let tagged_fields = read_tagged_fields(buf)?;
77        for field in &tagged_fields {
78            match field.tag {
79                _ => {
80                    _unknown_tagged_fields.push(field.clone());
81                },
82            }
83        }
84        Ok(Self {
85            throttle_time_ms,
86            error_code,
87            error_message,
88            responses,
89            _unknown_tagged_fields,
90        })
91    }
92    pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()> {
93        if version < 0 || version > 0 {
94            return Err(UnsupportedVersion::new(92, version).into());
95        }
96        write_i32(buf, self.throttle_time_ms);
97        write_i16(buf, self.error_code);
98        write_compact_nullable_string(buf, self.error_message.as_ref())?;
99        write_compact_array_length(buf, self.responses.len() as i32);
100        for el in &self.responses {
101            el.write(buf, version)?;
102        }
103        let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
104        all_tags.sort_by_key(|f| f.tag);
105        write_tagged_fields(buf, &all_tags)?;
106        Ok(())
107    }
108    pub fn encoded_len(&self, version: i16) -> Result<usize> {
109        if version < 0 || version > 0 {
110            return Err(UnsupportedVersion::new(92, version).into());
111        }
112        let mut len: usize = 0;
113        len += 4;
114        len += 2;
115        len += compact_nullable_string_len(self.error_message.as_ref())?;
116        len += compact_array_length_len(self.responses.len() as i32);
117        for el in &self.responses {
118            len += el.encoded_len(version)?;
119        }
120        let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
121        all_tags.sort_by_key(|f| f.tag);
122        len += tagged_fields_len(&all_tags)?;
123        Ok(len)
124    }
125}
126#[derive(Debug, Clone, PartialEq)]
127pub struct DeleteShareGroupOffsetsResponseTopic {
128    /// The topic name.
129    pub topic_name: KafkaString,
130    /// The unique topic ID.
131    pub topic_id: KafkaUuid,
132    /// The topic-level error code, or 0 if there was no error.
133    pub error_code: i16,
134    /// The topic-level error message, or null if there was no error.
135    pub error_message: Option<KafkaString>,
136    pub _unknown_tagged_fields: Vec<RawTaggedField>,
137}
138impl Default for DeleteShareGroupOffsetsResponseTopic {
139    fn default() -> Self {
140        Self {
141            topic_name: KafkaString::default(),
142            topic_id: KafkaUuid::ZERO,
143            error_code: 0_i16,
144            error_message: None,
145            _unknown_tagged_fields: Vec::new(),
146        }
147    }
148}
149impl DeleteShareGroupOffsetsResponseTopic {
150    pub fn with_topic_name(mut self, value: KafkaString) -> Self {
151        self.topic_name = value;
152        self
153    }
154    pub fn with_topic_id(mut self, value: KafkaUuid) -> Self {
155        self.topic_id = value;
156        self
157    }
158    pub fn with_error_code(mut self, value: i16) -> Self {
159        self.error_code = value;
160        self
161    }
162    pub fn with_error_message(mut self, value: Option<KafkaString>) -> Self {
163        self.error_message = value;
164        self
165    }
166    pub fn read(buf: &mut Bytes, _version: i16) -> Result<Self> {
167        let topic_name;
168        let topic_id;
169        let error_code;
170        let error_message;
171        let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
172        topic_name = read_compact_string(buf)?;
173        topic_id = read_uuid(buf)?;
174        error_code = read_i16(buf)?;
175        error_message = read_compact_nullable_string(buf)?;
176        let tagged_fields = read_tagged_fields(buf)?;
177        for field in &tagged_fields {
178            match field.tag {
179                _ => {
180                    _unknown_tagged_fields.push(field.clone());
181                },
182            }
183        }
184        Ok(Self {
185            topic_name,
186            topic_id,
187            error_code,
188            error_message,
189            _unknown_tagged_fields,
190        })
191    }
192    pub fn write(&self, buf: &mut BytesMut, _version: i16) -> Result<()> {
193        write_compact_string(buf, &self.topic_name)?;
194        write_uuid(buf, &self.topic_id);
195        write_i16(buf, self.error_code);
196        write_compact_nullable_string(buf, self.error_message.as_ref())?;
197        let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
198        all_tags.sort_by_key(|f| f.tag);
199        write_tagged_fields(buf, &all_tags)?;
200        Ok(())
201    }
202    pub fn encoded_len(&self, _version: i16) -> Result<usize> {
203        let mut len: usize = 0;
204        len += compact_string_len(&self.topic_name)?;
205        len += 16;
206        len += 2;
207        len += compact_nullable_string_len(self.error_message.as_ref())?;
208        let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
209        all_tags.sort_by_key(|f| f.tag);
210        len += tagged_fields_len(&all_tags)?;
211        Ok(len)
212    }
213}
kacrab_protocol/generated/delete_share_group_offsets_response.rs

kacrab_protocol/generated/
delete_share_group_offsets_response.rs
