Trait paxakos::retry::RetryPolicy

pub trait RetryPolicy: 'static {
    type Invocation: Invocation;
    type Error;
    type StaticError;
    fn eval<'life0, 'async_trait>(
        &'life0 mut self, 
        error: AppendError<Self::Invocation>
    ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>
    where
        'life0: 'async_trait,
        Self: 'async_trait;
}

Policy that determines whether an append should be retried.

Associated Types

type Invocation: Invocation

Parametrization of the paxakos algorithm.

type Error

Type of error produced by this policy.

type StaticError

Union of Self::Error and ShutDown.

See Node::append_static.

Required methods

fn eval<'life0, 'async_trait>(
    &'life0 mut self,
    error: AppendError<Self::Invocation>
) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Determines wheter another attempt to append should be made.

The given error is the reason the latest attempt failed. Returning Ok(()) implies that another attempt should be made.

Implementations on Foreign Types

impl<I: Invocation, E: 'static, F: 'static> RetryPolicy for Box<dyn RetryPolicy<Invocation = I, Error = E, StaticError = F> + Send>

type Invocation = I

type Error = E

type StaticError = F

fn eval<'life0, 'async_trait>(
    &'life0 mut self,
    error: AppendError<Self::Invocation>
) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Implementors

impl<B: Backoff + Send + 'static, I: Invocation + Send> RetryPolicy for RetryWithBackoff<B, I>

type Invocation = I

type Error = AbortedError<I>

type StaticError = AbortedError<I>

impl<I: Invocation> RetryPolicy for RetryIndefinitely<I>

type Invocation = I

type Error = Infallible

type StaticError = ShutDown

impl<I: Invocation> RetryPolicy for DoNotRetry<I>

type Invocation = I

type Error = AppendError<Self::Invocation>

type StaticError = AppendError<Self::Invocation>