nsq_async_rs/
error.rs

1use std::io;
2use thiserror::Error;
3use tokio::time::error::Elapsed;
4
5use crate::protocol::ProtocolError;
6
7/// NSQ客户端库错误类型
8#[derive(Debug, Error)]
9pub enum Error {
10    /// IO错误
11    #[error("IO错误: {0}")]
12    Io(#[from] io::Error),
13
14    /// 序列化错误
15    #[error("序列化错误: {0}")]
16    Serialize(#[from] serde_json::Error),
17
18    /// 连接错误
19    #[error("连接错误: {0}")]
20    Connection(String),
21
22    /// 协议错误
23    #[error("协议错误: {0}")]
24    Protocol(#[from] ProtocolError),
25
26    /// 超时错误
27    #[error("操作超时: {0}")]
28    Timeout(String),
29
30    /// tokio 超时错误
31    #[error("操作超时")]
32    TimedOut(#[from] Elapsed),
33
34    /// 认证错误
35    #[error("认证失败: {0}")]
36    Auth(String),
37
38    /// 消息处理错误
39    #[error("消息处理错误: {0}")]
40    MessageHandling(String),
41
42    /// 配置错误
43    #[error("配置错误: {0}")]
44    Config(String),
45
46    /// HTTP错误
47    #[error("HTTP错误: {0}")]
48    Http(#[from] reqwest::Error),
49
50    /// 其他错误
51    #[error("其他错误: {0}")]
52    Other(String),
53}
54
55impl From<backoff::Error<Error>> for Error {
56    fn from(err: backoff::Error<Error>) -> Self {
57        match err {
58            backoff::Error::Permanent(e) => e,
59            backoff::Error::Transient { err, .. } => err,
60        }
61    }
62}
63
64/// Result类型别名，用于NSQ客户端库
65pub type Result<T> = std::result::Result<T, Error>;
nsq_async_rs/error.rs

nsq_async_rs/
error.rs
