Struct EProcess 

pub struct EProcess { /* private fields */ }

Running anytime-valid evidence against one null hypothesis, in log space. Multiplicative absorption of conditionally-valid e-values; Ville’s inequality converts the running product into a sequential test that survives optional stopping. Serializable so evidence is resumable across corpus shards (#973): persist, reload, keep absorbing.

Implementations

impl EProcess

pub fn new() -> Self

pub fn absorb(&mut self, e_value: f64) -> Result<(), String>

Absorb one conditionally-valid e-value (NOT in log space; must be ≥ 0; E[e | past] ≤ 1 under H0 is the caller’s contract — e.g. a universal-inference batch ratio or a fixed-prior Bayes factor).

pub fn absorb_log(&mut self, log_e_value: f64) -> Result<(), String>

Absorb a batch e-value supplied in log space (the only numerically honest interface for long streams).

pub fn log_evidence(&self) -> f64

pub fn steps(&self) -> usize

pub fn rejects_at(&self, alpha: f64) -> bool

Anytime-valid rejection at level α: by Ville, P_{H0}(sup_t E_t ≥ 1/α) ≤ α, so crossing 1/α at ANY time — including data-dependent stopping times — proves the claim with type-I error ≤ α. Uses the running supremum: once crossed, always rejected.

pub fn current_e_value_log(&self) -> f64

The e-value to hand to e_benjamini_hochberg for the dictionary-level FDR certificate (current evidence, not the sup — e-BH’s guarantee is stated for e-values at the chosen stopping time).

Trait Implementations

impl Clone for EProcess

fn clone(&self) -> EProcess

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EProcess

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

Formats the value using the given formatter.

impl Default for EProcess

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EProcess

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EProcess

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.