crabka_protocol/owned/
offset_commit_response.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/OffsetCommitResponse.owned.rs"
23));
24#[cfg(test)]
25mod tests {
26    use super::*;
27    use crate::{Decode, Encode};
28    use assert2::assert;
29    use bytes::BytesMut;
30    fn roundtrip(msg: &OffsetCommitResponse, v: i16) {
31        let mut buf = BytesMut::new();
32        msg.encode(&mut buf, v).unwrap();
33        assert!(msg.encoded_len(v) == buf.len());
34        let bytes = buf.freeze();
35        let mut cur = &bytes[..];
36        let decoded = OffsetCommitResponse::decode(&mut cur, v).unwrap();
37        assert!(cur.is_empty());
38        let mut reencoded = BytesMut::new();
39        decoded.encode(&mut reencoded, v).unwrap();
40        assert!(&reencoded[..] == &bytes[..]);
41        let _ = default_json(v);
42    }
43    #[test]
44    fn default_roundtrips_all_versions() {
45        for v in MIN_VERSION..=MAX_VERSION {
46            roundtrip(&OffsetCommitResponse::default(), v);
47        }
48    }
49    #[test]
50    fn populated_roundtrips_all_versions() {
51        for v in MIN_VERSION..=MAX_VERSION {
52            roundtrip(&OffsetCommitResponse::populated(v), v);
53        }
54    }
55}
crabka_protocol/owned/offset_commit_response.rs

crabka_protocol/owned/
offset_commit_response.rs
