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
#![deny(missing_docs)]
pub mod commands;
pub struct DiagError(pub String);
impl From<std::io::Error> for DiagError {
fn from(error: std::io::Error) -> Self {
DiagError(format!("io error: {}", error.to_string()))
}
}
impl From<tdiag_connect::ConnectError> for DiagError {
fn from(error: tdiag_connect::ConnectError) -> Self {
match error {
tdiag_connect::ConnectError::IoError(e) => DiagError(format!("io error: {}", e)),
tdiag_connect::ConnectError::Other(e) => DiagError(e),
}
}
}
type LoggingTuple = (std::time::Duration, timely::logging::WorkerIdentifier, timely::logging::TimelyEvent);