Struct EProcessThrottle 

pub struct EProcessThrottle { /* private fields */ }

Anytime-valid recompute throttle using e-process (test martingale) control.

See module-level docs for the mathematical model and guarantees.

Implementations

impl EProcessThrottle

pub fn new(config: ThrottleConfig) -> Self

Create a new throttle with the given configuration.

pub fn new_at(config: ThrottleConfig, now: Instant) -> Self

Create a new throttle at a specific time (for deterministic testing).

pub fn observe(&mut self, matched: bool) -> ThrottleDecision

Observe a single event. matched indicates whether this observation is evidence for recomputation (e.g., the log line matched the query).

Returns a ThrottleDecision indicating whether to recompute.

pub fn observe_at(&mut self, matched: bool, now: Instant) -> ThrottleDecision

Observe at a specific time (for deterministic testing).

pub fn reset(&mut self)

Manually trigger a recompute (e.g., when the query changes). Resets the e-process state.

pub fn reset_at(&mut self, now: Instant)

Reset at a specific time (for testing).

pub fn set_mu_0(&mut self, mu_0: f64)

Update the null hypothesis match rate μ₀.

Call this when the baseline match rate changes (e.g., new query with different selectivity). Resets the e-process.

pub fn wealth(&self) -> f64

Current wealth (e-value).

pub fn lambda(&self) -> f64

Current adaptive lambda.

pub fn empirical_match_rate(&self) -> f64

Empirical match rate over the sliding window.

pub fn threshold(&self) -> f64

E-value threshold (1/α).

pub fn observation_count(&self) -> u64

Total observation count.

pub fn stats(&self) -> ThrottleStats

Get aggregate statistics.

pub fn logs(&self) -> &[ThrottleLog]

Get decision logs (if logging enabled).

pub fn clear_logs(&mut self)

Clear decision logs.

Trait Implementations

impl Debug for EProcessThrottle

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

Formats the value using the given formatter.