crabka_protocol/opt/rustwide/workdir/generated/common/owned/
TaskOffset.owned.rs

1// AUTO-GENERATED by crabka-protocol-codegen against a9ce3221537b8653448750697915607dc7936cf3. Do not edit.
2
3use bytes::{Buf, BufMut};
4
5use crate::primitives::fixed::{get_i32, get_i64, put_i32, put_i64};
6use crate::primitives::string_bytes::{
7    compact_string_len, get_compact_string_owned, get_string_owned,
8    put_compact_string, put_string, string_len,
9};
10use crate::tagged_fields::{read_tagged_fields, tagged_fields_len, WriteTaggedFields};
11use crate::{Decode, Encode, ProtocolError, UnknownTaggedFields};
12
13#[derive(Debug, Clone, PartialEq, Eq, Default)]
14pub struct TaskOffset {
15    pub subtopology_id: String,
16    pub partition: i32,
17    pub offset: i64,
18    pub unknown_tagged_fields: UnknownTaggedFields,
19}
20
21impl Encode for TaskOffset {
22    fn encode<B: BufMut>(&self, buf: &mut B, version: i16) -> Result<(), ProtocolError> {
23        let flex = version >= 0;
24        if version >= 0 { if flex { put_compact_string(buf, &self.subtopology_id) } else { put_string(buf, &self.subtopology_id) } }
25        if version >= 0 { put_i32(buf, self.partition) }
26        if version >= 0 { put_i64(buf, self.offset) }
27        if flex {
28            let tagged = WriteTaggedFields::new();
29            tagged.write(buf, &self.unknown_tagged_fields);
30        }
31        Ok(())
32    }
33    fn encoded_len(&self, version: i16) -> usize {
34        let flex = version >= 0;
35        let mut n: usize = 0;
36        if version >= 0 { n += if flex { compact_string_len(&self.subtopology_id) } else { string_len(&self.subtopology_id) }; }
37        if version >= 0 { n += 4; }
38        if version >= 0 { n += 8; }
39        if flex {
40            let known_pairs: Vec<(u32, usize)> = Vec::new();
41            n += tagged_fields_len(&known_pairs, &self.unknown_tagged_fields);
42        }
43        n
44    }
45}
46
47impl<'de> Decode<'de> for TaskOffset {
48    fn decode<B: Buf>(buf: &mut B, version: i16) -> Result<Self, ProtocolError> {
49        let flex = version >= 0;
50        let mut out = Self::default();
51        if version >= 0 { out.subtopology_id = if flex { get_compact_string_owned(buf)? } else { get_string_owned(buf)? }; }
52        if version >= 0 { out.partition = get_i32(buf)?; }
53        if version >= 0 { out.offset = get_i64(buf)?; }
54        if flex {
55            out.unknown_tagged_fields = read_tagged_fields(buf, |_tag, _payload| {
56                Ok(false)
57            })?;
58        }
59        Ok(out)
60    }
61}
crabka_protocol/opt/rustwide/workdir/generated/common/owned/TaskOffset.owned.rs

crabka_protocol/opt/rustwide/workdir/generated/common/owned/
TaskOffset.owned.rs
