#[non_exhaustive]pub struct RetryExtension {
pub max_attempts: Option<u32>,
pub dead_letter: Option<String>,
pub retry_destination: Option<String>,
}Expand description
What a registration declared about retrying a failed delivery, rendered under
x-ruststream-retry.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.max_attempts: Option<u32>How many times a delivery is handed to the handler before it is given up on.
dead_letter: Option<String>Where a delivery out of attempts goes. The channel is in the document too, with a send
operation: the traffic is real.
retry_destination: Option<String>Where the registration publishes a deferred copy of a delivery, when the mount site named
a destination for its retry copies. That channel is in the document too, with a send
operation. Absent where the copies go back to the subscription’s own address, which is a
channel the document already carries.
Trait Implementations§
Source§impl Clone for RetryExtension
impl Clone for RetryExtension
Source§impl Debug for RetryExtension
impl Debug for RetryExtension
Auto Trait Implementations§
impl Freeze for RetryExtension
impl RefUnwindSafe for RetryExtension
impl Send for RetryExtension
impl Sync for RetryExtension
impl Unpin for RetryExtension
impl UnsafeUnpin for RetryExtension
impl UnwindSafe for RetryExtension
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
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§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> MessageWire for Twhere
T: Serialize,
impl<T> MessageWire for Twhere
T: Serialize,
Source§type Wire = EncodedWire
type Wire = EncodedWire
The value’s wire:
EncodedWire or SerializedWire.impl<T> PublishedThrough<DefaultSlot> for T
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
Source§impl<R> ReplyShape for R
impl<R> ReplyShape for R
type Body = R
type Headers = ()
Source§type Wire = EncodedReply
type Wire = EncodedReply
The reply’s wire:
EncodedReply or SerializedReply.