crabka-client-core 0.3.1

Connection management and request dispatch for Apache Kafka in Rust
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
60
61
62
63
64
65
66
67
68
69
70

//! Error type for `crabka-client-core`.

use std::net::SocketAddr;
use std::time::Duration;

use thiserror::Error;

/// Errors returned by `Client`, `Connection`, and the broker pool.
#[derive(Debug, Error)]
#[non_exhaustive]
pub enum ClientError {
    #[error("connect to {addr}: {source}")]
    Connect {
        addr: SocketAddr,
        #[source]
        source: std::io::Error,
    },

    #[error("connection closed")]
    Disconnected,

    #[error("request timed out after {0:?}")]
    Timeout(Duration),

    #[error(
        "incompatible version: broker supports {broker_min}..={broker_max}, \
         client wants {client_min}..={client_max} for api_key {api_key}"
    )]
    IncompatibleVersion {
        api_key: i16,
        broker_min: i16,
        broker_max: i16,
        client_min: i16,
        client_max: i16,
    },

    #[error("protocol error from server: {error_code}")]
    Server { error_code: i16 },

    #[error("codec: {0}")]
    Codec(#[from] crabka_protocol::ProtocolError),

    #[error("I/O: {0}")]
    Io(#[from] std::io::Error),
}

#[cfg(test)]
mod tests {
    use super::*;
    use assert2::assert;

    #[test]
    fn display_is_useful() {
        let e = ClientError::Timeout(Duration::from_secs(5));
        assert!(e.to_string() == "request timed out after 5s");
    }

    #[test]
    fn incompatible_version_displays_full_range() {
        let e = ClientError::IncompatibleVersion {
            api_key: 0,
            broker_min: 0,
            broker_max: 5,
            client_min: 7,
            client_max: 10,
        };
        assert!(e.to_string().contains("api_key 0"));
        assert!(e.to_string().contains("broker supports 0..=5"));
    }
}