rocketmq_client/
error.rs

1//!
2//! Define client side errors.
3//!
4use std::io;
5use thiserror::Error;
6
7#[derive(Error, Debug)]
8pub enum ClientError {
9    #[error("Bad endpoint address `{0}`")]
10    BadAddress(String),
11
12    #[error("Timeout when establishing connections")]
13    ConnectTimeout(#[from] io::Error),
14
15    #[error("Connect reset by peer")]
16    ConnectionReset,
17
18    #[error("Invalid frame `{0}`")]
19    InvalidFrame(String),
20
21    #[error("unknown data store error")]
22    Unknown,
23}