neutron 0.0.2

A Rust client library for Pulsar
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

#[derive(Debug, Clone)]
pub enum NeutronError {
    Disconnected,
    OperationTimeout,
    UnsupportedCommand,
    DecodeFailed,
    EncodeFailed,
    ChannelTerminated,
    Unresolvable,
    Io,
    DeserializationFailed,
    SerializationFailed,
    AuthenticationFailed(String),
    ConnectionFailed,
    InvalidUrl,
    PulsarError(String),
}

impl NeutronError {
    pub fn is_disconnect(&self) -> bool {
        matches!(
            self,
            NeutronError::Disconnected | NeutronError::ChannelTerminated
        )
    }
}

impl std::fmt::Display for NeutronError {
    fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
        match self {
            NeutronError::Disconnected => write!(f, "Disconnected"),
            NeutronError::OperationTimeout => write!(f, "Operation timeout"),
            NeutronError::UnsupportedCommand => write!(f, "Unsupported command"),
            NeutronError::DecodeFailed => write!(f, "Decode failed"),
            NeutronError::EncodeFailed => write!(f, "Encode failed"),
            NeutronError::ChannelTerminated => write!(f, "Channel terminated"),
            NeutronError::Unresolvable => write!(f, "Unresolvable"),
            NeutronError::Io => write!(f, "IO error"),
            NeutronError::DeserializationFailed => write!(f, "Deserialization failed"),
            NeutronError::SerializationFailed => write!(f, "Serialization failed"),
            NeutronError::AuthenticationFailed(e) => write!(f, "Authentication failed: {}", e),
            NeutronError::ConnectionFailed => write!(f, "Connection failed"),
            NeutronError::InvalidUrl => write!(f, "Invalid URL"),
            NeutronError::PulsarError(e) => write!(f, "Pulsar error: {}", e),
        }
    }
}

impl std::error::Error for NeutronError {}