pub enum NSQEvent {
Message(NSQMessage),
Healthy(),
Unhealthy(),
Ok(),
}
Expand description
An event from an NSQ connection. Includes connection status updates, errors, and actual NSQ messages.
Variants§
Message(NSQMessage)
An NSQ consumer message
Healthy()
Generated when a connection completes a handshake
Unhealthy()
Generated when a connection fails and will be restarted.
Ok()
An acknowledgement for a producer that a message was delivered.
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for NSQEvent
impl Send for NSQEvent
impl Sync for NSQEvent
impl Unpin for NSQEvent
impl !UnwindSafe for NSQEvent
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