pub enum MessageRetryStrategy {
RetryForever,
Count(usize),
NoRetry,
}Expand description
The retry strategy for a RetriableMessage.
Variants§
RetryForever
Retry the message forever, without limit.
IMPORTANT: This requires that some other mode is provided
to mark messages as eventually being completed(), be it
discarding or it being successfully handled. Otherwise the
message may spin-lock in your factory, never succeeding, and
constantly being retried
Count(usize)
Retry up to the provided number of times
NoRetry
No retries (or used to track if retries have been used internally)
Trait Implementations§
Auto Trait Implementations§
impl Freeze for MessageRetryStrategy
impl RefUnwindSafe for MessageRetryStrategy
impl Send for MessageRetryStrategy
impl Sync for MessageRetryStrategy
impl Unpin for MessageRetryStrategy
impl UnwindSafe for MessageRetryStrategy
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> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage