e0acd48944
* Write bench-tps in terms of client * Add transactions_addr method for logging * Move cluster config outside do_bench_tps * Add BankClient test
45 lines
1.1 KiB
Rust
45 lines
1.1 KiB
Rust
use crate::transaction::TransactionError;
|
|
use std::error;
|
|
use std::fmt;
|
|
use std::io;
|
|
|
|
#[derive(Debug)]
|
|
pub enum TransportError {
|
|
IoError(io::Error),
|
|
TransactionError(TransactionError),
|
|
}
|
|
|
|
impl error::Error for TransportError {}
|
|
impl fmt::Display for TransportError {
|
|
fn fmt(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
match self {
|
|
TransportError::IoError(err) => write!(formatter, "{:?}", err),
|
|
TransportError::TransactionError(err) => write!(formatter, "{:?}", err),
|
|
}
|
|
}
|
|
}
|
|
|
|
impl TransportError {
|
|
pub fn unwrap(&self) -> TransactionError {
|
|
if let TransportError::TransactionError(err) = self {
|
|
err.clone()
|
|
} else {
|
|
panic!("unexpected transport error")
|
|
}
|
|
}
|
|
}
|
|
|
|
impl From<io::Error> for TransportError {
|
|
fn from(err: io::Error) -> TransportError {
|
|
TransportError::IoError(err)
|
|
}
|
|
}
|
|
|
|
impl From<TransactionError> for TransportError {
|
|
fn from(err: TransactionError) -> TransportError {
|
|
TransportError::TransactionError(err)
|
|
}
|
|
}
|
|
|
|
pub type Result<T> = std::result::Result<T, TransportError>;
|