samsa 0.1.8

Rust-native Kafka/Redpanda protocol and client implementation.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

pub mod request;
pub mod response;

#[cfg(test)]
mod test {
    use bytes::Bytes;
    use nombytes::NomBytes;

    use super::*;
    use crate::{encode::ToByte, protocol};

    #[test]
    fn encode() {
        let b = [
            0, 19, 0, 3, 0, 0, 0, 1, 0, 4, 114, 117, 115, 116, 0, 0, 0, 1, 0, 15, 116, 101, 115,
            116, 101, 114, 45, 99, 114, 101, 97, 116, 105, 111, 110, 0, 0, 0, 1, 0, 0, 0, 0, 0, 0,
            0, 0, 0, 0, 0, 0, 7, 208, 0,
        ];

        let correlation_id = 1;
        let client_id = "rust";
        let topic_name = "tester-creation";
        let timeout_ms = 2000;
        let num_partitions = 1;

        let mut req =
            request::CreateTopicsRequest::new(correlation_id, client_id, timeout_ms, false)
                .unwrap();

        req.add(topic_name, num_partitions, 0);

        let mut buffer: Vec<u8> = vec![];

        req.encode(&mut buffer).unwrap();

        assert_eq!(buffer, b);
    }

    #[test]
    fn parse() {
        let b = b"\0\0\0\x01\0\0\0\0\0\0\0\x01\0\x0ftester-creation\0\0\xff\xff";

        let res = response::CreateTopicsResponse {
            header: protocol::HeaderResponse { correlation_id: 1 },
            throttle_time_ms: 0,
            topics: vec![response::Topic {
                name: Bytes::from("tester-creation"),
                error_code: crate::prelude::KafkaCode::None,
                error_message: None,
            }],
        };

        let x = response::parse_create_topics_response(NomBytes::new(Bytes::from_static(b)))
            .unwrap()
            .1;

        assert_eq!(res, x);
    }
}