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
50
51
52
53
54
55
56
57
58
59
60
use std::io::Error as IoError;
use engine_traits::Error as EngineTraitsError;
use kvproto::errorpb::Error as ErrorHeader;
use raftstore::Error as RaftstoreError;
use thiserror::Error;
use tikv::storage::kv::{Error as EngineError, ErrorInner as EngineErrorInner};
use tikv::storage::mvcc::{Error as MvccError, ErrorInner as MvccErrorInner};
use tikv::storage::txn::{Error as TxnError, ErrorInner as TxnErrorInner};
use txn_types::Error as TxnTypesError;
#[derive(Debug, Error)]
pub enum Error {
#[error("IO error {0}")]
Io(#[from] IoError),
#[error("Engine error {0}")]
Engine(#[from] EngineError),
#[error("Transaction error {0}")]
Txn(#[from] TxnError),
#[error("Mvcc error {0}")]
Mvcc(#[from] MvccError),
#[error("Request error {0:?}")]
Request(Box<ErrorHeader>),
#[error("Engine traits error {0}")]
EngineTraits(#[from] EngineTraitsError),
#[error("Txn types error {0}")]
TxnTypes(#[from] TxnTypesError),
#[error("Raftstore error {0}")]
Raftstore(#[from] RaftstoreError),
#[error("Other error {0}")]
Other(#[from] Box<dyn std::error::Error + Sync + Send>),
}
impl Error {
pub fn request(err: ErrorHeader) -> Error {
Error::Request(Box::new(err))
}
pub fn extract_error_header(self) -> ErrorHeader {
match self {
Error::Engine(EngineError(box EngineErrorInner::Request(e)))
| Error::Txn(TxnError(box TxnErrorInner::Engine(EngineError(
box EngineErrorInner::Request(e),
))))
| Error::Txn(TxnError(box TxnErrorInner::Mvcc(MvccError(
box MvccErrorInner::Engine(EngineError(box EngineErrorInner::Request(e))),
))))
| Error::Request(box e) => e,
other => {
let mut e = ErrorHeader::default();
e.set_message(format!("{:?}", other));
e
}
}
}
}
pub type Result<T> = std::result::Result<T, Error>;