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 !UnwindSafe for NSQEvent
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more