lightweight
com.atproto.sync.listReposByCollection
whatever
+1
+1
src/http.rs
+1
src/http.rs
···
99
99
let limiter = self.shared.get_or_create_limiter(host);
100
100
while limiter.check().is_err() {
101
101
metrics::gauge!("lightrail_http_host_throttling").increment(1);
102
+
// i think we should be limiter.until_ready_with_jitter().await!
102
103
tokio::time::sleep(self.shared.jittered_interval()).await;
103
104
metrics::gauge!("lightrail_http_host_throttling").decrement(1);
104
105
}