Struct Governor 

pub struct Governor { /* private fields */ }

PSI-based system stress governor with background monitoring thread.

Implementations

impl Governor

pub fn new( max_load: f64, hydration_delay_ms: u64, psi_io_limit: f64, psi_cpu_limit: f64, ) -> Self

Create a new governor with the given stress thresholds.

pub fn current_stress_score(&self) -> f64

Lock-free stress score read with failure-rate boost. Called ~320 times/second across all workers – must be contention-free.

pub fn is_system_stressed(&self) -> bool

Return true if the system is under enough stress to throttle.

pub fn current_memory_usage_pct(&self) -> f64

Lock-free memory usage read.

pub fn pace_hydration(&self)

Sleep proportionally to system stress before hydration work.

pub async fn pace_hydration_async(&self)

Async variant of [pace_hydration] for callers running on the tokio executor.

Uses tokio::time::sleep instead of std::thread::sleep to avoid blocking a tokio worker thread. Use this from async fn contexts (e.g., process_hydration_job). For sync callers on dedicated std::threads (e.g., full_scan, execute_frontier_scan), use the sync [pace_hydration] instead.