Enum hedwig::googlepubsub::PublishError [−][src]
pub enum PublishError<M: EncodableMessage, E> {
Publish {
cause: PubSubError,
messages: Vec<M>,
},
Response(E),
InvalidMessage {
cause: M::Error,
message: M,
},
}
This is supported on crate feature
google
only.Expand description
Errors which can occur while publishing a message
Variants
An error from publishing
Fields of Publish
cause: PubSubError
The cause of the error
messages: Vec<M>
The batch of messages which failed to be published
An error from submitting a successfully published message to the user-provided response sink
An error from validating the given message
Fields of InvalidMessage
Trait Implementations
impl<M: Debug + EncodableMessage, E: Debug> Debug for PublishError<M, E> where
M::Error: Debug,
impl<M: Debug + EncodableMessage, E: Debug> Debug for PublishError<M, E> where
M::Error: Debug,
impl<M: EncodableMessage, E> Display for PublishError<M, E> where
M::Error: Display,
E: Display,
impl<M: EncodableMessage, E> Display for PublishError<M, E> where
M::Error: Display,
E: Display,
impl<M: EncodableMessage, E> Error for PublishError<M, E> where
M: Debug,
M::Error: StdError + 'static,
E: StdError + 'static,
impl<M: EncodableMessage, E> Error for PublishError<M, E> where
M: Debug,
M::Error: StdError + 'static,
E: StdError + 'static,
Auto Trait Implementations
impl<M, E> !RefUnwindSafe for PublishError<M, E>
impl<M, E> Send for PublishError<M, E> where
E: Send,
M: Send,
<M as EncodableMessage>::Error: Send,
impl<M, E> Sync for PublishError<M, E> where
E: Sync,
M: Sync,
<M as EncodableMessage>::Error: Sync,
impl<M, E> Unpin for PublishError<M, E> where
E: Unpin,
M: Unpin,
<M as EncodableMessage>::Error: Unpin,
impl<M, E> !UnwindSafe for PublishError<M, E>
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
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