Skip to main content

zimq_impl/
error.rs

1use thiserror::Error;
2
3use crate::message::Message;
4
5#[derive(Error, Debug)]
6pub enum ZimqError {
7    #[error("IO Error : {0}")]
8    IOError(#[from] std::io::Error),
9
10    #[error("InitError : {0}")]
11    InitError(String),
12
13    #[error("UninitializedError : {0}")]
14    UninitializedError(String),
15
16    #[error("InvalidMessageError : {0}")]
17    InvalidMessageError(String),
18
19    #[error("InvalidBinlogPathError : {0}")]
20    InvalidBinlogPathError(String),
21
22    #[error("DuplicatedMessageError : {0}")]
23    DuplicatedMessageError(String),
24
25    #[error("SerializeError : {0}")]
26    SerializeError(String),
27
28    #[error("SendError : {0}")]
29    SendError(#[from] tokio::sync::mpsc::error::SendError<Message>),
30
31
32
33}