Struct RetryPolicy 

pub struct RetryPolicy { /* private fields */ }

Implementations

impl RetryPolicy

pub fn new() -> Self

pub fn with_config(config: RetryConfig) -> Self

pub fn with_metrics(self, metrics: RetryMetrics) -> Self

pub fn with_retry_budget(self, budget: u32) -> Self

pub fn with_shared_budget(self, budget: Arc<RetryBudget>) -> Self

Attach a shared process-wide retry budget.

pub fn with_limiter(self, limiter: Arc<ConcurrencyLimiter>) -> Self

Attach a concurrency limiter for retries.

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

where F: Fn() -> Fut, Fut: Future<Output = Result<T, E>>, E: Retryable + Error + Send + Sync + 'static + Debug,

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

where F: Fn() -> Result<T, E>, E: Retryable + Error + Send + Sync + 'static + Debug,

Trait Implementations

impl Default for RetryPolicy

fn default() -> Self

Returns the “default value” for a type.