Struct RetryPolicy 

pub struct RetryPolicy {
    pub max_attempts: u32,
    pub backoff_ms: u64,
}

Policy controlling how many times a failing node operation should be retried and how long to wait between attempts.

The inter-attempt sleep uses exponential backoff: attempt n (0-indexed) sleeps for backoff_ms * 2^n milliseconds before being made.

Example

use oximedia_graph::processing_graph::RetryPolicy;

// Three attempts total, starting with a 10 ms back-off.
let policy = RetryPolicy { max_attempts: 3, backoff_ms: 10 };

Fields

max_attempts: u32

Maximum number of attempts (including the first). A value of 1 means “try once; do not retry”.

backoff_ms: u64

Base back-off in milliseconds. The sleep before attempt n is backoff_ms * 2^(n-1) ms (so the first retry sleeps backoff_ms ms, the second sleeps 2 * backoff_ms ms, and so on).

Implementations

impl RetryPolicy

pub fn execute<T, E, F>(&self, f: F) -> Result<T, E>

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

Executes f up to max_attempts times, returning the first Ok(T).

If f returns an Err(e) where e.is_transient() returns true and there are remaining attempts, the function sleeps for an exponentially increasing duration and then calls f again.

If f returns an Err(e) where e.is_transient() returns false, the error is returned immediately (no further retries are made).

If all max_attempts are exhausted the last error is returned.

Trait Implementations

impl Clone for RetryPolicy

fn clone(&self) -> RetryPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryPolicy

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

Formats the value using the given formatter.

impl Default for RetryPolicy

fn default() -> Self

Returns the “default value” for a type.