Struct RetryWithBackoffPolicy 

pub struct RetryWithBackoffPolicy<P> {
    pub inner: P,
    pub max_retries: u32,
    pub backoff_base_ms: u64,
    pub backoff_cap_ms: Option<u64>,
    pub jitter_ratio: f64,
}

Policy that returns RetryAfterMs with exponential backoff (and optional jitter) for the first max_retries attempts, then Fail. For RateLimited errors with retry_after_ms, uses that value when set.

Fields

inner: P

max_retries: u32

backoff_base_ms: u64

Base delay in ms; actual delay = min(cap, backoff_base_ms * 2^attempt) + jitter.

backoff_cap_ms: Option<u64>

Max delay cap in ms (optional).

jitter_ratio: f64

Jitter ratio in [0.0, 1.0]; added randomness to avoid thundering herd.

Implementations

impl<P: Policy> RetryWithBackoffPolicy<P>

pub fn new(inner: P, max_retries: u32, backoff_ms: u64) -> Self

New with fixed backoff (no exponent, no jitter). Preserves legacy behavior when backoff_base_ms is the only delay.

pub fn with_exponential_backoff( inner: P, max_retries: u32, backoff_base_ms: u64, backoff_cap_ms: Option<u64>, jitter_ratio: f64, ) -> Self

Exponential backoff: base * 2^attempt, capped, plus jitter.

Trait Implementations

impl<P: Policy> Policy for RetryWithBackoffPolicy<P>

fn authorize( &self, run_id: &RunId, action: &Action, ctx: &PolicyCtx, ) -> Result<(), KernelError>

Whether the action is allowed for this run and context.

fn retry_strategy_attempt( &self, err: &ActionError, action: &Action, attempt: u32, ) -> RetryDecision

Retry strategy with attempt count and structured error. Default uses kind: Permanent => Fail, others may be retried by implementations. Applies only to executor Err; ActionResult::Failure is not retried.

fn budget(&self) -> BudgetRules

Optional budget; default is no limits.

fn retry_strategy(&self, err: &dyn Display, _action: &Action) -> RetryDecision

Whether to retry after an error (and optionally after a delay).