fluvio_protocol/core/
mod.rs

1mod bytebuf;
2mod decoder;
3mod encoder;
4mod varint;
5mod zerocopy;
6
7pub use self::bytebuf::ByteBuf;
8pub use self::decoder::Decoder;
9pub use self::decoder::DecoderVarInt;
10pub use self::encoder::Encoder;
11pub use self::encoder::EncoderVarInt;
12
13pub type Version = i16;
14
15#[cfg(test)]
16#[allow(unused)]
17mod tests {
18    use super::*;
19
20    #[derive(Default)]
21    struct MyMessage {
22        value1: [u8; 2],
23        value2: [u8; 4], // u32
24    }
25
26    impl MyMessage {
27        fn value1(&self) -> i16 {
28            i16::from_be_bytes(self.value1)
29        }
30
31        fn set_value1(&mut self, val: i16) {
32            self.value1 = val.to_be_bytes()
33        }
34    }
35
36    #[test]
37    fn test_message() {
38        let mut m = MyMessage::default();
39
40        m.set_value1(10);
41        let bytes = m.value1;
42        assert_eq!(bytes[0], 0);
43        assert_eq!(bytes[1], 10);
44    }
45}
fluvio_protocol/core/mod.rs

fluvio_protocol/core/
mod.rs
