Struct BocpdDetector 

pub struct BocpdDetector { /* private fields */ }

Bayesian Online Change-Point Detection for regime classification.

Maintains a truncated run-length posterior and computes the probability of being in burst vs steady regime.

Implementations

impl BocpdDetector

pub fn new(config: BocpdConfig) -> Self

Create a new BOCPD detector with the given configuration.

pub fn with_defaults() -> Self

Create with default configuration.

pub fn p_burst(&self) -> f64

Get current burst probability.

pub fn run_length_posterior(&self) -> &[f64]

Get the run-length posterior distribution.

Returns a slice where element i is P(r_t = i | x_1:t). The length is bounded by max_run_length + 1.

pub fn regime(&self) -> BocpdRegime

Get current classified regime.

pub fn expected_run_length(&self) -> f64

Get the expected run-length (mean of posterior).

pub fn last_evidence(&self) -> Option<&BocpdEvidence>

Get the last evidence.

pub fn set_decision_context( &mut self, steady_delay_ms: u64, burst_delay_ms: u64, hard_deadline_forced: bool, )

Update the last evidence with decision context (delay + deadline).

Call this after a decision is made (e.g., in the coalescer) to include chosen delay and hard-deadline forcing in JSONL logs.

pub fn evidence_jsonl(&self) -> Option<String>

Return the latest JSONL evidence entry if logging is enabled.

pub fn decision_log_jsonl( &self, steady_delay_ms: u64, burst_delay_ms: u64, hard_deadline_forced: bool, ) -> Option<String>

Return JSONL evidence with decision context applied.

pub fn observation_count(&self) -> u64

Get observation count.

pub fn config(&self) -> &BocpdConfig

Get configuration.

pub fn observe_event(&mut self, now: Instant) -> BocpdRegime

Process a new resize event.

Call this when a resize event occurs. Returns the classified regime.

pub fn reset(&mut self)

Reset the detector to initial state.

pub fn recommended_delay( &self, steady_delay_ms: u64, burst_delay_ms: u64, ) -> u64

Compute recommended coalesce delay based on current regime.

Interpolates between steady_delay and burst_delay based on p_burst.

Trait Implementations

impl Clone for BocpdDetector

fn clone(&self) -> BocpdDetector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BocpdDetector

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

Formats the value using the given formatter.

impl Default for BocpdDetector

fn default() -> Self

Returns the “default value” for a type.