Struct RateLimiter 

pub struct RateLimiter<S>
where
    S: Storage<EventSignature, EventState> + Clone,
{ /* private fields */ }

Coordinates rate limiting decisions.

Implementations

impl<S> RateLimiter<S>

where S: Storage<EventSignature, EventState> + Clone,

pub fn new( registry: SuppressionRegistry<S>, metrics: Metrics, circuit_breaker: Arc<CircuitBreaker>, ) -> Self

Create a new rate limiter.

Arguments

• registry - The suppression registry (which contains the clock)
• metrics - Metrics tracker
• circuit_breaker - Circuit breaker for fail-safe operation

pub fn check_event(&self, signature: EventSignature) -> LimitDecision

Process an event and decide whether to allow or suppress it.

Arguments

• signature - The event signature

Returns

A LimitDecision indicating whether to allow or suppress the event.

Fail-Safe Behavior

If rate limiting operations fail (circuit breaker open), this method fails open and allows all events through to preserve observability.

Performance

This method is designed for the hot path:

• Fast hash lookup in sharded map
• Lock-free atomic operations where possible
• No allocations in common case

pub fn registry(&self) -> &SuppressionRegistry<S>

Get a reference to the registry.

pub fn metrics(&self) -> &Metrics

Get a reference to the metrics.

pub fn circuit_breaker(&self) -> &Arc<CircuitBreaker>

Get a reference to the circuit breaker.

Trait Implementations

impl<S> Clone for RateLimiter<S>

where S: Storage<EventSignature, EventState> + Clone + Clone,

fn clone(&self) -> RateLimiter<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.