krabka_protocol/owned/
offset_commit_key.rs

1// AUTO-GENERATED by krabka-protocol-codegen against a9ce3221537b8653448750697915607dc7936cf3. Do not edit.
2include!(concat!(
3    env!("CARGO_MANIFEST_DIR"),
4    "/generated/OffsetCommitKey.owned.rs"
5));
6#[cfg(test)]
7mod tests {
8    use assert2::assert;
9    use bytes::BytesMut;
10
11    use super::*;
12    use crate::{Decode, Encode};
13    fn roundtrip(msg: &OffsetCommitKey, v: i16) {
14        let mut buf = BytesMut::new();
15        msg.encode(&mut buf, v).unwrap();
16        assert!(msg.encoded_len(v) == buf.len());
17        let bytes = buf.freeze();
18        let mut cur = &bytes[..];
19        let decoded = OffsetCommitKey::decode(&mut cur, v).unwrap();
20        assert!(cur.is_empty());
21        let mut reencoded = BytesMut::new();
22        decoded.encode(&mut reencoded, v).unwrap();
23        assert!(&reencoded[..] == &bytes[..]);
24        let _ = default_json(v);
25    }
26    #[test]
27    fn default_roundtrips_all_versions() {
28        for v in MIN_VERSION..=MAX_VERSION {
29            roundtrip(&OffsetCommitKey::default(), v);
30        }
31    }
32    #[test]
33    fn populated_roundtrips_all_versions() {
34        for v in MIN_VERSION..=MAX_VERSION {
35            roundtrip(&OffsetCommitKey::populated(v), v);
36        }
37    }
38}
krabka_protocol/owned/offset_commit_key.rs

krabka_protocol/owned/
offset_commit_key.rs
