topiq-core 0.1.3

Core types for the topiq message broker
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

use thiserror::Error;

/// Errors that can occur in the topiq system.
#[derive(Debug, Error)]
pub enum TopiqError {
    #[error("invalid subject: {reason}")]
    InvalidSubject { reason: String },

    #[error("protocol error: {0}")]
    Protocol(String),

    #[error("unsupported protocol version: {version}")]
    UnsupportedVersion { version: u8 },

    #[error("frame too large: {size} bytes (max {max})")]
    FrameTooLarge { size: usize, max: usize },

    #[error("transport error: {0}")]
    Transport(#[from] std::io::Error),

    #[error("codec error: {0}")]
    Codec(String),

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

    #[error("request timed out")]
    Timeout,

    #[error("buffer full for subscription {sid}")]
    Backpressure { sid: u64 },
}

pub type Result<T> = std::result::Result<T, TopiqError>;