Struct PersistentAnomalyzer 

pub struct PersistentAnomalyzer { /* private fields */ }

A thin wrapper that pairs an Anomalyzer with a PersistenceManager.

Every push is durably written to the WAL before the probability is returned, and a snapshot is compacted automatically every snapshot_interval pushes (default 1 000).

Example

use anomalyzer_ts::{AnomalyzerConf, PersistentAnomalyzer};

let conf = AnomalyzerConf {
    active_size: 1,
    n_seasons: 4,
    methods: vec!["magnitude".into(), "highrank".into()],
    ..Default::default()
};

// First run — no prior state, starts fresh.
// Subsequent runs — history is restored from disk automatically.
let mut detector = PersistentAnomalyzer::open("/var/lib/myapp/anomaly", conf)?;

let prob = detector.push(15.0)?;
println!("prob = {prob:.3}");

detector.flush()?; // compact on clean shutdown

Implementations

impl PersistentAnomalyzer

pub fn open(dir: impl AsRef<Path>, conf: AnomalyzerConf) -> Result<Self>

Open the persistence directory, recover history, and return a ready detector. Creates the directory if it does not exist.

pub fn push(&mut self, value: f64) -> Result<f64>

Push a new value, persist it durably, and return the anomaly probability.

pub fn eval(&self) -> f64

Re-evaluate the current windows without pushing a new value.

pub fn flush(&mut self) -> Result<()>

Force a snapshot + WAL truncation immediately. Call on clean shutdown to minimise replay time at next startup.

pub fn wal_size_bytes(&self) -> Result<u64>

Bytes currently accumulated in the WAL.

pub fn pending_wal_entries(&self) -> usize

WAL entries pending since the last snapshot.

pub fn set_snapshot_interval(&mut self, n: usize)

Adjust how often an automatic snapshot is taken (default: 1 000 pushes).