Struct Pacer 

pub struct Pacer { /* private fields */ }

Implementations

impl Pacer

pub fn new(pacing: PacingLimits) -> Self

pub const fn pacing(&self) -> &PacingLimits

pub async fn acquire_patiently( &self, host: &str, budget: Duration, ) -> Result<RequestPermit, PausedHost>

@docgen The breaker is fail-fast, so without waiting out its own pause a single refusal turns a whole zone unknown.

pub async fn acquire(&self, host: &str) -> Result<RequestPermit, PausedHost>

pub async fn record_success(&self, host: &str)

@docgen Concurrency climbs one step per run of successes but is cut hard on any refusal, so recovery cannot re-trigger a block.

pub async fn record_refusal(&self, host: &str, refusal: &Refusal) -> Duration

pub async fn breaker(&self, host: &str) -> BreakerState

pub async fn paused(&self, host: &str) -> Option<PausedHost>

pub async fn paused_hosts(&self) -> Vec<PausedHost>

pub async fn host_concurrency(&self, host: &str) -> usize

pub async fn prune_settled_hosts(&self)

@docgen A long sweep would otherwise keep a map entry for every endpoint it ever touched.

Trait Implementations

impl Debug for Pacer

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

Formats the value using the given formatter.