pub enum Error {
Zmq(ZmqError),
Wire(Error),
HandshakeTimeout {
stage: &'static str,
pending: Vec<u16>,
timeout: Duration,
},
Handshake(String),
InvalidRequest(String),
DuplicateRequestId(String),
SendTimeout {
engine_index: u16,
timeout: Duration,
},
Unavailable(StreamError),
}Expand description
An error from connecting to the engines or submitting a request.
Variants§
Zmq(ZmqError)
A socket operation failed.
Wire(Error)
A message did not match the wire schema.
HandshakeTimeout
Not every engine finished a handshake stage in time.
Fields
Handshake(String)
An engine broke the handshake protocol.
InvalidRequest(String)
The request cannot be submitted as given.
DuplicateRequestId(String)
A request with this id is already in flight.
SendTimeout
The engine did not accept the message in time.
Fields
The engines are gone; see StreamError for why.
Trait Implementations§
Source§impl Error for Error
impl Error for Error
Source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
1.0.0 · Source§fn description(&self) -> &str
fn description(&self) -> &str
👎Deprecated since 1.42.0:
use the Display impl or to_string()
Auto Trait Implementations§
impl !RefUnwindSafe for Error
impl !UnwindSafe for Error
impl Freeze for Error
impl Send for Error
impl Sync for Error
impl Unpin for Error
impl UnsafeUnpin for Error
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more