Struct Paced 

pub struct Paced { /* private fields */ }

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

In-process only; the cross-process limiter (DESIGN §6) is deferred.

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

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).