Struct RateDetector 

pub struct RateDetector { /* private fields */ }

Fires when at least count matching events occur within window.

On each check():

• If event is Some and the filter accepts it, push the current timestamp.
• Expire timestamps older than window.
• Return true if the remaining count >= threshold.

Implementations

impl RateDetector

pub fn new( filter: Arc<dyn Fn(&SessionEvent) -> bool + Send + Sync>, count: u32, window: Duration, ) -> Self

Create a new rate detector.

• filter: predicate to select which events count.
• count: number of matching events required.
• window: sliding time window.

Trait Implementations

impl PatternDetector for RateDetector

fn check( &self, _state: &State, event: Option<&SessionEvent>, now: Instant, ) -> bool

Evaluate whether the pattern is currently triggered.

fn reset(&self)

Reset the detector’s internal state (counters, timestamps, etc.).

fn needs_timer(&self) -> bool

Whether this detector requires periodic timer checks.