crabka_protocol/owned/
offset_commit_request.rs

1// AUTO-GENERATED by crabka-protocol-codegen against a9ce3221537b8653448750697915607dc7936cf3. Do not edit.
2// Clippy lints that fire on generated code patterns are suppressed here so
3// that regenerating the file does not require manual allow annotations.
4#![allow(
5    clippy::absurd_extreme_comparisons,
6    clippy::cast_possible_truncation,
7    clippy::cast_possible_wrap,
8    clippy::cast_sign_loss,
9    clippy::default_trait_access,
10    clippy::must_use_candidate,
11    clippy::new_without_default,
12    clippy::nonminimal_bool,
13    clippy::too_many_lines,
14    clippy::unnecessary_wraps,
15    clippy::unreadable_literal,
16    unused_mut,
17    unused_variables
18)]
19
20include!(concat!(
21    env!("CARGO_MANIFEST_DIR"),
22    "/generated/OffsetCommitRequest.owned.rs"
23));
24#[cfg(test)]
25mod tests {
26    use assert2::assert;
27    use bytes::BytesMut;
28
29    use super::*;
30    use crate::{Decode, Encode};
31    fn roundtrip(msg: &OffsetCommitRequest, v: i16) {
32        let mut buf = BytesMut::new();
33        msg.encode(&mut buf, v).unwrap();
34        assert!(msg.encoded_len(v) == buf.len());
35        let bytes = buf.freeze();
36        let mut cur = &bytes[..];
37        let decoded = OffsetCommitRequest::decode(&mut cur, v).unwrap();
38        assert!(cur.is_empty());
39        let mut reencoded = BytesMut::new();
40        decoded.encode(&mut reencoded, v).unwrap();
41        assert!(&reencoded[..] == &bytes[..]);
42        let _ = default_json(v);
43    }
44    #[test]
45    fn default_roundtrips_all_versions() {
46        for v in MIN_VERSION..=MAX_VERSION {
47            roundtrip(&OffsetCommitRequest::default(), v);
48        }
49    }
50    #[test]
51    fn populated_roundtrips_all_versions() {
52        for v in MIN_VERSION..=MAX_VERSION {
53            roundtrip(&OffsetCommitRequest::populated(v), v);
54        }
55    }
56}
crabka_protocol/owned/offset_commit_request.rs

crabka_protocol/owned/
offset_commit_request.rs
