crabka_protocol/owned/
txn_offset_commit_request.rs1#![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/TxnOffsetCommitRequest.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: &TxnOffsetCommitRequest, 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 = TxnOffsetCommitRequest::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(&TxnOffsetCommitRequest::default(), v);
47 }
48 }
49 #[test]
50 fn populated_roundtrips_all_versions() {
51 for v in MIN_VERSION..=MAX_VERSION {
52 roundtrip(&TxnOffsetCommitRequest::populated(v), v);
53 }
54 }
55}