Struct apalis_core::layers::retry::DefaultRetryPolicy

pub struct DefaultRetryPolicy;

Available on crate feature retry only.

Retries a job instantly until max_attempts

Trait Implementations

impl Clone for DefaultRetryPolicy

fn clone(&self) -> DefaultRetryPolicy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for DefaultRetryPolicy

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

Formats the value using the given formatter.

impl<T> Policy<JobRequest<T>, JobResult, JobError> for DefaultRetryPolicywhere
    T: Clone,

type Future = Ready<DefaultRetryPolicy>

The Future type returned by Policy::retry.

fn retry(
    &self,
    req: &JobRequest<T>,
    result: Result<&JobResult, &JobError>
) -> Option<Self::Future>

Check the policy if a certain request should be retried.

fn clone_request(&self, req: &JobRequest<T>) -> Option<JobRequest<T>>

Tries to clone a request before being passed to the inner service.