kafka_protocol/messages/
snapshot_header_record.rs

1//! SnapshotHeaderRecord
2//!
3//! See the schema for this message [here](https://github.com/apache/kafka/blob/trunk/clients/src/main/resources/common/message/SnapshotHeaderRecord.json).
4// WARNING: the items of this module are generated and should not be edited directly
5#![allow(unused)]
6
7use std::borrow::Borrow;
8use std::collections::BTreeMap;
9
10use anyhow::{bail, Result};
11use bytes::Bytes;
12use uuid::Uuid;
13
14use crate::protocol::{
15    buf::{ByteBuf, ByteBufMut},
16    compute_unknown_tagged_fields_size, types, write_unknown_tagged_fields, Decodable, Decoder,
17    Encodable, Encoder, HeaderVersion, Message, StrBytes, VersionRange,
18};
19
20/// Valid versions: 0
21#[non_exhaustive]
22#[derive(Debug, Clone, PartialEq)]
23pub struct SnapshotHeaderRecord {
24    /// The version of the snapshot header record
25    ///
26    /// Supported API versions: 0
27    pub version: i16,
28
29    /// The append time of the last record from the log contained in this snapshot
30    ///
31    /// Supported API versions: 0
32    pub last_contained_log_timestamp: i64,
33
34    /// Other tagged fields
35    pub unknown_tagged_fields: BTreeMap<i32, Bytes>,
36}
37
38impl SnapshotHeaderRecord {
39    /// Sets `version` to the passed value.
40    ///
41    /// The version of the snapshot header record
42    ///
43    /// Supported API versions: 0
44    pub fn with_version(mut self, value: i16) -> Self {
45        self.version = value;
46        self
47    }
48    /// Sets `last_contained_log_timestamp` to the passed value.
49    ///
50    /// The append time of the last record from the log contained in this snapshot
51    ///
52    /// Supported API versions: 0
53    pub fn with_last_contained_log_timestamp(mut self, value: i64) -> Self {
54        self.last_contained_log_timestamp = value;
55        self
56    }
57    /// Sets unknown_tagged_fields to the passed value.
58    pub fn with_unknown_tagged_fields(mut self, value: BTreeMap<i32, Bytes>) -> Self {
59        self.unknown_tagged_fields = value;
60        self
61    }
62    /// Inserts an entry into unknown_tagged_fields.
63    pub fn with_unknown_tagged_field(mut self, key: i32, value: Bytes) -> Self {
64        self.unknown_tagged_fields.insert(key, value);
65        self
66    }
67}
68
69impl Encodable for SnapshotHeaderRecord {
70    fn encode<B: ByteBufMut>(&self, buf: &mut B, version: i16) -> Result<()> {
71        types::Int16.encode(buf, &self.version)?;
72        types::Int64.encode(buf, &self.last_contained_log_timestamp)?;
73        let num_tagged_fields = self.unknown_tagged_fields.len();
74        if num_tagged_fields > std::u32::MAX as usize {
75            bail!(
76                "Too many tagged fields to encode ({} fields)",
77                num_tagged_fields
78            );
79        }
80        types::UnsignedVarInt.encode(buf, num_tagged_fields as u32)?;
81
82        write_unknown_tagged_fields(buf, 0.., &self.unknown_tagged_fields)?;
83        Ok(())
84    }
85    fn compute_size(&self, version: i16) -> Result<usize> {
86        let mut total_size = 0;
87        total_size += types::Int16.compute_size(&self.version)?;
88        total_size += types::Int64.compute_size(&self.last_contained_log_timestamp)?;
89        let num_tagged_fields = self.unknown_tagged_fields.len();
90        if num_tagged_fields > std::u32::MAX as usize {
91            bail!(
92                "Too many tagged fields to encode ({} fields)",
93                num_tagged_fields
94            );
95        }
96        total_size += types::UnsignedVarInt.compute_size(num_tagged_fields as u32)?;
97
98        total_size += compute_unknown_tagged_fields_size(&self.unknown_tagged_fields)?;
99        Ok(total_size)
100    }
101}
102
103impl Decodable for SnapshotHeaderRecord {
104    fn decode<B: ByteBuf>(buf: &mut B, version: i16) -> Result<Self> {
105        let version = types::Int16.decode(buf)?;
106        let last_contained_log_timestamp = types::Int64.decode(buf)?;
107        let mut unknown_tagged_fields = BTreeMap::new();
108        let num_tagged_fields = types::UnsignedVarInt.decode(buf)?;
109        for _ in 0..num_tagged_fields {
110            let tag: u32 = types::UnsignedVarInt.decode(buf)?;
111            let size: u32 = types::UnsignedVarInt.decode(buf)?;
112            let unknown_value = buf.try_get_bytes(size as usize)?;
113            unknown_tagged_fields.insert(tag as i32, unknown_value);
114        }
115        Ok(Self {
116            version,
117            last_contained_log_timestamp,
118            unknown_tagged_fields,
119        })
120    }
121}
122
123impl Default for SnapshotHeaderRecord {
124    fn default() -> Self {
125        Self {
126            version: 0,
127            last_contained_log_timestamp: 0,
128            unknown_tagged_fields: BTreeMap::new(),
129        }
130    }
131}
132
133impl Message for SnapshotHeaderRecord {
134    const VERSIONS: VersionRange = VersionRange { min: 0, max: 0 };
135    const DEPRECATED_VERSIONS: Option<VersionRange> = None;
136}
kafka_protocol/messages/snapshot_header_record.rs

kafka_protocol/messages/
snapshot_header_record.rs
