Struct RateMeter 

#[repr(align(64))]
pub struct RateMeter { /* private fields */ }

Ultra-fast rate meter with sliding window calculations

Tracks events per second/minute/hour with minimal overhead. Cache-line aligned to prevent false sharing.

Implementations

impl RateMeter

pub fn new() -> Self

Create new rate meter with 1-second window

pub fn with_window(window: Duration) -> Self

Create rate meter with custom window size

pub fn tick(&self)

Record an event - THE FASTEST PATH

This is optimized for maximum speed:

• Single atomic increment for total
• Lazy window updates only when needed
• Branch prediction friendly

pub fn try_tick(&self) -> Result<()>

Try to record a single event with overflow checks

Returns Err(MetricsError::Overflow) if incrementing the total or any current window counter would overflow. On success returns Ok(()).

Example

use metrics_lib::{RateMeter, MetricsError};
let m = RateMeter::new();
m.try_tick().unwrap();
assert_eq!(m.total(), 1);

pub fn tick_n(&self, n: u32)

Record N events at once

pub fn try_tick_n(&self, n: u32) -> Result<()>

Try to record N events at once with overflow checks

• Returns Ok(()) on success.
• Returns Err(MetricsError::Overflow) if incrementing any of the involved counters would overflow (total_events, current_second_events, current_minute_events, or current_hour_events).

Example

use metrics_lib::{RateMeter, MetricsError};
let m = RateMeter::new();
assert!(m.try_tick_n(5).is_ok());
assert_eq!(m.total(), 5);

pub fn rate(&self) -> f64

Get current rate (events per second in current window)

pub fn rate_per_second(&self) -> f64

Get rate per second

pub fn rate_per_minute(&self) -> f64

Get rate per minute

pub fn rate_per_hour(&self) -> f64

Get rate per hour

pub fn total(&self) -> u64

Get total events since creation

pub fn exceeds_rate(&self, limit: f64) -> bool

Check if rate exceeds limit

pub fn can_allow(&self, n: u32, limit: f64) -> bool

Check if we can allow N more events without exceeding limit

pub fn tick_if_under_limit(&self, limit: f64) -> bool

Rate limiting - tick only if under limit

pub fn try_tick_if_under_limit(&self, limit: f64) -> Result<bool>

Try to tick if under limit, with overflow checks

Attempts to record a single event only if the current rate would not exceed limit. Returns:

• Ok(true) if the event was recorded.
• Ok(false) if the event would exceed the limit (no change made).
• Err(MetricsError::Overflow) if counters would overflow while recording.

Example

use metrics_lib::RateMeter;
let m = RateMeter::new();
assert!(m.try_tick_if_under_limit(10.0).unwrap());

pub fn tick_burst_if_under_limit(&self, n: u32, limit: f64) -> bool

Burst rate limiting - allow N events if under limit

pub fn reset(&self)

Reset all counters

pub fn stats(&self) -> RateStats

Get comprehensive statistics

pub fn age(&self) -> Duration

Get age since creation

pub fn is_empty(&self) -> bool

Check if rate meter is empty (no events recorded)

Trait Implementations

impl Debug for RateMeter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RateMeter

fn default() -> Self

Returns the “default value” for a type.

impl Display for RateMeter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Send for RateMeter

impl Sync for RateMeter