Struct DhtRateLimiter 

pub struct DhtRateLimiter(/* private fields */);

Three-layer rate limiter for inbound cdn/dht/v1 requests. Newtype over the shared ThreeLayerRateLimiter that injects the DHT metrics sink.

Implementations

impl DhtRateLimiter

pub fn new(cfg: &DhtRateLimitConfig, metrics: Arc<Metrics>) -> Self

Build a limiter from the resolved DHT config snapshot.

pub fn from_resolved(resolved: &ResolvedDht, metrics: Arc<Metrics>) -> Self

Build a limiter straight from the resolved [dht.rate_limit] section.

Prefer this over Self::new at wiring sites: DhtRateLimitConfig is an alias of the shared RateLimitConfig, so new cannot tell a config mapped from [dht.rate_limit] from one mapped out of [probe.rate_limit]. Taking &ResolvedDht makes the wrong pairing a type error (#1457); see crate::handlers::probe_rate_limit::ProbeRateLimiter::from_resolved for the direction that actually loosens a cap.

pub fn check( &self, peer_node_id: &NodeId, peer_ip: Option<IpAddr>, ) -> Result<(), DhtRejectLayer>

Try to admit one inbound DHT request. See ThreeLayerRateLimiter::check.

pub fn admit_batch_extra( &self, peer_node_id: &NodeId, peer_ip: Option<IpAddr>, extra: usize, ) -> usize

Stage 2 of batch admission. See ThreeLayerRateLimiter::admit_batch_extra.

pub fn gc_per_ip(&self) -> Option<(usize, usize)>

Periodic GC sweep for the per-IP keyed map (#645).

pub fn gc_per_peer(&self) -> Option<(usize, usize)>

Periodic GC sweep for the per-peer keyed map (#645).

pub fn per_ip_tracked(&self) -> usize

Current tracked-key count for the per-IP keyed map (#645).

pub fn per_peer_tracked(&self) -> usize

Current tracked-key count for the per-peer keyed map (#645).