Struct RetryBudget 

pub struct RetryBudget { /* private fields */ }

Per-upstream rolling-window retry budget. Share via Arc from the upstream handle; the lock is taken once per proxied request (record) and once per retry decision (reserve) — never per attempt frame.

Implementations

impl RetryBudget

pub fn new() -> Self

New budget on the system clock with the standard window.

pub fn with_clock(window_ms: u64, now_ms: fn() -> u64) -> Self

New budget with a caller-supplied millisecond clock (Unix epoch). Intended for tests; production keeps the system clock.

pub fn record_request(&self)

Record one proxied request (the denominator of the budget ratio). Called once per request, never per attempt.

pub fn try_reserve_retry(&self, percent: u32) -> bool

Whether a retry may be issued under percent, charging it atomically (check + record under one lock acquisition) so the in-window invariant retries * 100 <= percent * requests is never exceeded, even under concurrent retries. requests counts the ORIGINAL proxied requests only (retry events are excluded from the denominator — the budget bounds retries as a share of real traffic). The candidate retry is charged BEFORE it runs: allowing requires (retries + 1) * 100 <= percent * requests to hold already, so a fresh window with little volume grants few or no retries rather than a burst.

pub fn totals(&self) -> usize

In-window totals (observability/tests).

pub fn retries(&self) -> usize

In-window retries (observability/tests).

Trait Implementations

impl Debug for RetryBudget

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

Formats the value using the given formatter.

impl Default for RetryBudget

fn default() -> Self

Returns the “default value” for a type.