Struct ProbeRateLimiter 

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

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

Implementations

impl ProbeRateLimiter

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

Build a limiter from the resolved probe config snapshot.

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

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

Prefer this over Self::new at wiring sites. ProbeRateLimitConfig is an alias of the shared RateLimitConfig, so new accepts a config mapped from either protocol’s resolved section — building the probe limiter from [dht.rate_limit] type-checks fine and would quietly quadruple the per-peer probe cap (ADR 022’s 20/sec in place of ADR 005’s 5/sec). Taking &ResolvedProbe makes that a type error instead (#1457).

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

Try to admit one inbound probe. See ThreeLayerRateLimiter::check.

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