Struct RetryHandler 

pub struct RetryHandler { /* private fields */ }

Retry handler with exponential backoff.

Implementations

impl RetryHandler

pub fn new(config: &RetryConfig) -> Self

Create a new retry handler from configuration.

pub fn default_handler() -> Self

Create with default configuration.

pub async fn execute<F, Fut, T>(&self, operation: F) -> PhyTraceResult<T>

where F: FnMut() -> Fut, Fut: Future<Output = PhyTraceResult<T>>,

Execute an async operation with retries.

pub async fn execute_with_stats<F, Fut, T>( &self, operation: F, ) -> (PhyTraceResult<T>, RetryStats)

where F: FnMut() -> Fut, Fut: Future<Output = PhyTraceResult<T>>,

Execute with retries and return attempt count.

pub fn should_retry(&self, result: &SendResult) -> bool

Check if a send result indicates a retryable failure.

pub fn calculate_delay(&self, attempt: u32) -> Duration

Calculate delay for a given attempt number.

pub fn max_retries(&self) -> u32

Get the maximum number of retries.

pub fn initial_backoff(&self) -> Duration

Get the initial backoff duration.

Trait Implementations

impl Clone for RetryHandler

fn clone(&self) -> RetryHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RetryHandler

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

Formats the value using the given formatter.