Struct Paced 

pub struct Paced { /* private fields */ }

Spaces request starts at least min_interval apart, across all tasks sharing it, and optionally limits requests in flight. Slots are handed out in arrival order, so waiting is fair.

With shared pacing, slots come from a store that every process using it shares (the cache file), so parallel processes keep to one rate between them; if the store fails, pacing falls back to this process alone.

Logs each request (at info, target aspero::http) with the provider label, status, duration and time spent waiting for a slot.

Implementations

impl Paced

pub fn new( label: impl Into<String>, inner: Arc<dyn HttpClient>, min_interval: Duration, ) -> Self

pub fn max_in_flight(self, n: usize) -> Self

Keeps at most n requests in flight at once (0: no limit), for providers that refuse concurrent requests rather than fast ones.

pub fn shared(self, pacing: Arc<dyn Pacing>) -> Self

Paces with every other process using pacing.

Trait Implementations

impl HttpClient for Paced

fn send<'life0, 'async_trait>( &'life0 self, request: HttpRequest, ) -> Pin<Box<dyn Future<Output = Result<HttpResponse, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Sends one request. Ok for every HTTP status; Err only for transport failures (Network, Timeout).