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 check_event_with_metadata( &self, signature: EventSignature, metadata: EventMetadata, ) -> LimitDecision

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

This method captures event metadata on first occurrence for human-readable summaries.

Note: Only available with the human-readable feature flag.

Arguments

• signature - The event signature
• metadata - Event details (level, message, target, fields)

Returns

A LimitDecision indicating whether to allow or suppress the event.

Fail-Safe Behavior

Same as check_event: fails open if rate limiting operations fail.

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.