Struct RetryExecutor 

pub struct RetryExecutor { /* private fields */ }

A retry executor that runs a fallible operation with configured retry behavior.

Implementations

impl RetryExecutor

pub fn new(config: RetryStrategyConfig) -> Self

Create a new retry executor with the given configuration.

pub fn from_policy(policy: RetryPolicy) -> Self

Create a retry executor from a predefined policy.

pub fn run<T, E, F>(&self, operation: F) -> Result<T, E>

where F: FnMut(u32) -> Result<T, E>,

Execute a fallible operation with retry behavior.

The operation receives the current attempt number (starting at 1). Return Ok(T) on success, Err(E) on failure.

Example

use shipper_retry::{RetryExecutor, RetryPolicy};

let executor = RetryExecutor::from_policy(RetryPolicy::Default);
let result = executor.run(|attempt| {
    // Your fallible operation here
    if attempt < 3 {
        Err("transient error")
    } else {
        Ok("success")
    }
});

pub fn run_with_classification<T, E, F>(&self, operation: F) -> Result<T, E>

where F: FnMut(u32) -> Result<(T, bool), E>,

Execute a fallible operation with retry behavior and custom error classification.

The operation returns a tuple of (result, should_retry). This allows the operation to indicate whether an error is retryable.