Skip to main content

Attempt

Struct Attempt 

Source
#[non_exhaustive]
pub struct Attempt<'a> { pub failures: u32, pub error: Option<&'a (dyn Error + 'static)>, pub rebuilding: Rebuilding, }
Expand description

The state a ReconnectPolicy decides on.

Non-exhaustive: it gains fields as the backend learns to report more, and an existing policy keeps compiling.

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.
§failures: u32

Consecutive failures so far, resetting on every success.

0 on the first attempt after a drop, when nothing has failed yet: a policy that returns Duration::ZERO for 0 retries immediately, which is what BackoffPolicy does, because a failover is often complete by the time the client notices.

§error: Option<&'a (dyn Error + 'static)>

What failed last, or None when failures is 0.

Deliberately a plain std::error::Error rather than a concrete type: the two Rebuilding cases fail with different error types, and a policy that wants the detail can downcast_ref to lapin::Error or queuey_core::Error. Most policies only read failures.

§rebuilding: Rebuilding

Which of the two things is being rebuilt.

Implementations§

Source§

impl<'a> Attempt<'a>

Source

pub fn first(rebuilding: Rebuilding) -> Self

An attempt that has not failed yet.

The backend builds these; they are public so you can unit-test a ReconnectPolicy of your own. This type is #[non_exhaustive], so these constructors are the only way to make one.

Source

pub fn after( rebuilding: Rebuilding, failures: u32, error: &'a (dyn Error + 'static), ) -> Self

An attempt after failures consecutive failures, the last being error.

Trait Implementations§

Source§

impl<'a> Clone for Attempt<'a>

Source§

fn clone(&self) -> Attempt<'a>

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
Source§

impl<'a> Copy for Attempt<'a>

Source§

impl<'a> Debug for Attempt<'a>

Source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<'a> !RefUnwindSafe for Attempt<'a>

§

impl<'a> !Send for Attempt<'a>

§

impl<'a> !Sync for Attempt<'a>

§

impl<'a> !UnwindSafe for Attempt<'a>

§

impl<'a> Freeze for Attempt<'a>

§

impl<'a> Unpin for Attempt<'a>

§

impl<'a> UnsafeUnpin for Attempt<'a>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<'a, T, E> AsTaggedExplicit<'a, E> for T
where T: 'a,

Source§

fn explicit(self, class: Class, tag: u32) -> TaggedParser<'a, Explicit, Self, E>

Source§

impl<'a, T, E> AsTaggedImplicit<'a, E> for T
where T: 'a,

Source§

fn implicit( self, class: Class, constructed: bool, tag: u32, ) -> TaggedParser<'a, Implicit, Self, E>

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> CompatExt for T

Source§

fn compat(self) -> Compat<T>
where T: Sized,

Applies the Compat adapter by value. Read more
Source§

fn compat_ref(&self) -> Compat<&T>

Applies the Compat adapter by shared reference. Read more
Source§

fn compat_mut(&mut self) -> Compat<&mut T>

Applies the Compat adapter by mutable reference. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more