krabka_protocol/opt/rustwide/workdir/generated/
InitProducerIdResponse.borrowed.rs

1// AUTO-GENERATED by krabka-protocol-codegen against a9ce3221537b8653448750697915607dc7936cf3. Do not edit.
2use bytes::BufMut;
3
4use crate::{
5    DecodeBorrow, Encode, ProtocolError, UnknownTaggedFields,
6    primitives::fixed::{get_i16, get_i32, get_i64, put_i16, put_i32, put_i64},
7    tagged_fields::{WriteTaggedFields, read_tagged_fields, tagged_fields_len},
8};
9pub const API_KEY: i16 = 22;
10pub const MIN_VERSION: i16 = 0;
11pub const MAX_VERSION: i16 = 6;
12pub const FLEXIBLE_MIN: i16 = 2;
13#[inline]
14#[must_use]
15pub fn is_flexible(version: i16) -> bool {
16    version >= FLEXIBLE_MIN
17}
18#[derive(Debug, Clone, PartialEq, Eq)]
19pub struct InitProducerIdResponse {
20    pub throttle_time_ms: i32,
21    pub error_code: i16,
22    pub producer_id: i64,
23    pub producer_epoch: i16,
24    pub ongoing_txn_producer_id: i64,
25    pub ongoing_txn_producer_epoch: i16,
26    pub unknown_tagged_fields: UnknownTaggedFields,
27}
28impl Default for InitProducerIdResponse {
29    fn default() -> Self {
30        Self {
31            throttle_time_ms: 0i32,
32            error_code: 0i16,
33            producer_id: -1i64,
34            producer_epoch: 0i16,
35            ongoing_txn_producer_id: -1i64,
36            ongoing_txn_producer_epoch: -1i16,
37            unknown_tagged_fields: UnknownTaggedFields::default(),
38        }
39    }
40}
41impl InitProducerIdResponse {
42    /// # Panics
43    ///
44    /// Panics if a records field contains an invalid encoded record batch.
45    #[must_use]
46    pub fn to_owned(&self) -> crate::owned::init_producer_id_response::InitProducerIdResponse {
47        crate::owned::init_producer_id_response::InitProducerIdResponse {
48            throttle_time_ms: (self.throttle_time_ms),
49            error_code: (self.error_code),
50            producer_id: (self.producer_id),
51            producer_epoch: (self.producer_epoch),
52            ongoing_txn_producer_id: (self.ongoing_txn_producer_id),
53            ongoing_txn_producer_epoch: (self.ongoing_txn_producer_epoch),
54            unknown_tagged_fields: self.unknown_tagged_fields.clone(),
55        }
56    }
57}
58impl Encode for InitProducerIdResponse {
59    fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> Result<(), ProtocolError> {
60        if !(MIN_VERSION..=MAX_VERSION).contains(&version) {
61            return Err(ProtocolError::UnsupportedVersion {
62                api_key: API_KEY,
63                version,
64            });
65        }
66        let flex = is_flexible(version);
67        if version >= 0 {
68            put_i32(buf, self.throttle_time_ms);
69        }
70        if version >= 0 {
71            put_i16(buf, self.error_code);
72        }
73        if version >= 0 {
74            put_i64(buf, self.producer_id);
75        }
76        if version >= 0 {
77            put_i16(buf, self.producer_epoch);
78        }
79        if version >= 6 {
80            put_i64(buf, self.ongoing_txn_producer_id);
81        }
82        if version >= 6 {
83            put_i16(buf, self.ongoing_txn_producer_epoch);
84        }
85        if flex {
86            let tagged = WriteTaggedFields::new();
87            tagged.write(buf, &self.unknown_tagged_fields);
88        }
89        Ok(())
90    }
91    fn encoded_len(&self, version: i16) -> usize {
92        let flex = is_flexible(version);
93        let mut n: usize = 0;
94        if version >= 0 {
95            n += 4;
96        }
97        if version >= 0 {
98            n += 2;
99        }
100        if version >= 0 {
101            n += 8;
102        }
103        if version >= 0 {
104            n += 2;
105        }
106        if version >= 6 {
107            n += 8;
108        }
109        if version >= 6 {
110            n += 2;
111        }
112        if flex {
113            let known_pairs: Vec<(u32, usize)> = Vec::new();
114            n += tagged_fields_len(&known_pairs, &self.unknown_tagged_fields);
115        }
116        n
117    }
118}
119impl<'de> DecodeBorrow<'de> for InitProducerIdResponse {
120    fn decode_borrow(buf: &mut &'de [u8], version: i16) -> Result<Self, ProtocolError> {
121        if !(MIN_VERSION..=MAX_VERSION).contains(&version) {
122            return Err(ProtocolError::UnsupportedVersion {
123                api_key: API_KEY,
124                version,
125            });
126        }
127        let flex = is_flexible(version);
128        let mut out = Self::default();
129        if version >= 0 {
130            out.throttle_time_ms = get_i32(buf)?;
131        }
132        if version >= 0 {
133            out.error_code = get_i16(buf)?;
134        }
135        if version >= 0 {
136            out.producer_id = get_i64(buf)?;
137        }
138        if version >= 0 {
139            out.producer_epoch = get_i16(buf)?;
140        }
141        if version >= 6 {
142            out.ongoing_txn_producer_id = get_i64(buf)?;
143        }
144        if version >= 6 {
145            out.ongoing_txn_producer_epoch = get_i16(buf)?;
146        }
147        if flex {
148            out.unknown_tagged_fields = read_tagged_fields(buf, |_tag, _payload| Ok(false))?;
149        }
150        Ok(out)
151    }
152}
153#[cfg(test)]
154impl InitProducerIdResponse {
155    #[must_use]
156    pub fn populated(version: i16) -> Self {
157        let mut m = Self::default();
158        if version >= 0 {
159            m.throttle_time_ms = 1i32;
160        }
161        if version >= 0 {
162            m.error_code = 1i16;
163        }
164        if version >= 0 {
165            m.producer_id = 1i64;
166        }
167        if version >= 0 {
168            m.producer_epoch = 1i16;
169        }
170        if version >= 6 {
171            m.ongoing_txn_producer_id = 1i64;
172        }
173        if version >= 6 {
174            m.ongoing_txn_producer_epoch = 1i16;
175        }
176        m
177    }
178}
krabka_protocol/opt/rustwide/workdir/generated/InitProducerIdResponse.borrowed.rs

krabka_protocol/opt/rustwide/workdir/generated/
InitProducerIdResponse.borrowed.rs
