pub enum SiftStreamTrySendError<T> {
EncodeError(Error),
Channel(TrySendError<T>),
}Expand description
Returned by SiftStream::try_send when immediate
delivery fails.
This is the top-level error type for the non-blocking send API. It distinguishes encode-time failures from channel-level failures so callers can handle them differently.
Variants§
EncodeError(Error)
The message could not be encoded before it was sent.
This typically indicates a schema mismatch or an invalid value in the message. Retrying the same message without correcting the schema will not succeed.
Channel(TrySendError<T>)
The backing channel was full or closed.
The inner TrySendError carries the undelivered message. Inspect the variant
to distinguish between a transient backpressure condition (Full) and a permanent
shutdown (Closed). See TrySendError for recovery guidance.
Trait Implementations§
Source§impl<T: Debug> Debug for SiftStreamTrySendError<T>
impl<T: Debug> Debug for SiftStreamTrySendError<T>
Source§impl<T: Debug> Display for SiftStreamTrySendError<T>
impl<T: Debug> Display for SiftStreamTrySendError<T>
Source§impl<T: Debug> Error for SiftStreamTrySendError<T>
impl<T: Debug> Error for SiftStreamTrySendError<T>
1.30.0 · 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<T> Freeze for SiftStreamTrySendError<T>where
T: Freeze,
impl<T> !RefUnwindSafe for SiftStreamTrySendError<T>
impl<T> Send for SiftStreamTrySendError<T>where
T: Send,
impl<T> Sync for SiftStreamTrySendError<T>where
T: Sync,
impl<T> Unpin for SiftStreamTrySendError<T>where
T: Unpin,
impl<T> UnsafeUnpin for SiftStreamTrySendError<T>where
T: UnsafeUnpin,
impl<T> !UnwindSafe for SiftStreamTrySendError<T>
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::RequestSource§impl<T> RetryExt for T
impl<T> RetryExt for T
Source§fn retrying(self, cfg: RetryConfig) -> Retrying<Self>
fn retrying(self, cfg: RetryConfig) -> Retrying<Self>
Wraps
self in a Retrying adapter with the given configuration.