Struct BudgetMonitor 

pub struct BudgetMonitor { /* private fields */ }

Tracks budget violations over time windows for alerting.

The monitor aggregates violations per task and checks against configurable thresholds. When a task exceeds its threshold, an alert is generated.

Example

use laminar_core::budget::BudgetMonitor;
use std::time::Duration;

let mut monitor = BudgetMonitor::new(
    Duration::from_secs(60),  // 1 minute window
    10.0,                      // Alert if > 10 violations/sec
);

// Record violations
monitor.record_violation("ring0_event", 0, 100);

// Check for alerts
let alerts = monitor.check_alerts();
for alert in alerts {
    eprintln!("ALERT: {} has {} violations/sec", alert.task, alert.violation_rate);
}

Implementations

impl BudgetMonitor

pub fn new(window: Duration, threshold: f64) -> Self

Create a new budget monitor.

Arguments

• window - Time window for rate calculation (e.g., 60 seconds)
• threshold - Alert threshold in violations per second

pub fn record_violation(&mut self, task: &str, ring: u8, exceeded_by_ns: u64)

Record a budget violation.

Arguments

• task - Task name that violated budget
• ring - Ring number (0, 1, or 2)
• exceeded_by_ns - How much the budget was exceeded in nanoseconds

pub fn check_alerts(&mut self) -> Vec<BudgetAlert>

Check for alerts based on configured threshold.

Returns a list of alerts for tasks exceeding the threshold. Call this periodically (e.g., every second).

pub fn violation_count(&self, task: &str) -> u64

Get current violation count for a task.

pub fn threshold(&self) -> f64

Get the alert threshold (violations per second).

pub fn set_threshold(&mut self, threshold: f64)

Update the alert threshold.

pub fn window(&self) -> Duration

Get the window duration.

pub fn reset(&mut self)

Reset all violation tracking.

pub fn violations(&self) -> &HashMap<String, ViolationWindow>

Get all current violation windows.

Trait Implementations

impl Debug for BudgetMonitor

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

Formats the value using the given formatter.