kacrab_protocol/generated/
renew_delegation_token_request.rs

1//! Generated from RenewDelegationTokenRequest.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 RenewDelegationTokenRequestData {
17    /// The HMAC of the delegation token to be renewed.
18    pub hmac: Bytes,
19    /// The renewal time period in milliseconds.
20    pub renew_period_ms: i64,
21    pub _unknown_tagged_fields: Vec<RawTaggedField>,
22}
23impl Default for RenewDelegationTokenRequestData {
24    fn default() -> Self {
25        Self {
26            hmac: Bytes::new(),
27            renew_period_ms: 0_i64,
28            _unknown_tagged_fields: Vec::new(),
29        }
30    }
31}
32impl RenewDelegationTokenRequestData {
33    pub fn with_hmac(mut self, value: Bytes) -> Self {
34        self.hmac = value;
35        self
36    }
37    pub fn with_renew_period_ms(mut self, value: i64) -> Self {
38        self.renew_period_ms = value;
39        self
40    }
41    pub fn read(buf: &mut Bytes, version: i16) -> Result<Self> {
42        if version < 1 || version > 2 {
43            return Err(UnsupportedVersion::new(39, version).into());
44        }
45        let hmac;
46        let renew_period_ms;
47        let mut _unknown_tagged_fields: Vec<RawTaggedField> = Vec::new();
48        if version >= 2 {
49            hmac = read_compact_bytes(buf)?;
50        } else {
51            hmac = read_bytes(buf)?;
52        }
53        renew_period_ms = read_i64(buf)?;
54        if version >= 2 {
55            let tagged_fields = read_tagged_fields(buf)?;
56            for field in &tagged_fields {
57                match field.tag {
58                    _ => {
59                        _unknown_tagged_fields.push(field.clone());
60                    },
61                }
62            }
63        }
64        Ok(Self {
65            hmac,
66            renew_period_ms,
67            _unknown_tagged_fields,
68        })
69    }
70    pub fn write(&self, buf: &mut BytesMut, version: i16) -> Result<()> {
71        if version < 1 || version > 2 {
72            return Err(UnsupportedVersion::new(39, version).into());
73        }
74        if version >= 2 {
75            write_compact_bytes(buf, &self.hmac)?;
76        } else {
77            write_bytes(buf, &self.hmac)?;
78        }
79        write_i64(buf, self.renew_period_ms);
80        if version >= 2 {
81            let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
82            all_tags.sort_by_key(|f| f.tag);
83            write_tagged_fields(buf, &all_tags)?;
84        }
85        Ok(())
86    }
87    pub fn encoded_len(&self, version: i16) -> Result<usize> {
88        if version < 1 || version > 2 {
89            return Err(UnsupportedVersion::new(39, version).into());
90        }
91        let mut len: usize = 0;
92        if version >= 2 {
93            len += compact_bytes_len(&self.hmac)?;
94        } else {
95            len += bytes_len(&self.hmac)?;
96        }
97        len += 8;
98        if version >= 2 {
99            let mut all_tags: Vec<RawTaggedField> = self._unknown_tagged_fields.clone();
100            all_tags.sort_by_key(|f| f.tag);
101            len += tagged_fields_len(&all_tags)?;
102        }
103        Ok(len)
104    }
105}
kacrab_protocol/generated/renew_delegation_token_request.rs

kacrab_protocol/generated/
renew_delegation_token_request.rs
