chronix-analytics 0.7.0

Analytics engine for Chronix — preprocessing, forecasting, anomaly detection, multivariate analysis, model lifecycle, and streaming analytics on a SIMD/rayon CPU compute core
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78

//! # Chronix Analytics — Real-Time Streaming Analytics
//!
//! Streaming anomaly detection, continuous forecasting, materialized
//! forecast views, alerting, feedback, and forecast accuracy tracking.
//!
//! ## Architecture
//!
//! ```text
//! CDC PointWritten events
//!       │
//!       ├──→ StreamingAnomalyEngine (per-series anomaly detection)
//!       │          └──→ AlertEngine (configurable alert actions)
//!       │
//!       ├──→ ContinuousForecastEngine (incremental model updates)
//!       │          └──→ ForecastCache (materialized forecast views)
//!       │
//!       └──→ AnomalyPrecisionTracker (user feedback)
//!            ForecastAccuracyTracker (retroactive accuracy metrics)
//! ```
//!
//! ## Example
//!
//! ```no_run
//! use chronix_analytics::{
//!     StreamingAnomalyEngine, StreamingAnomalyConfig,
//!     ContinuousForecastEngine, ContinuousForecastConfig,
//! };
//! use chronix_analytics::anomaly::DetectorType;
//! use chronix_analytics::forecast::ModelType;
//!
//! // Set up streaming anomaly detection
//! let anomaly_engine = StreamingAnomalyEngine::new();
//! let config = StreamingAnomalyConfig::new("cpu", DetectorType::ZScore, 3.0);
//! anomaly_engine.enable(config).unwrap();
//!
//! // Set up continuous forecasting
//! let forecast_engine = ContinuousForecastEngine::new();
//! let config = ContinuousForecastConfig::new("cpu", ModelType::Ses);
//! forecast_engine.enable(config).unwrap();
//! ```

#![warn(missing_docs)]
#![deny(unsafe_code)]
// Index-coupled numeric loops (matrix pivots, ACF lags, ring buffers) read
// clearer with explicit indices than iterator chains.
#![allow(clippy::needless_range_loop, clippy::explicit_counter_loop)]

mod accuracy;
mod alerting;
pub mod anomaly;
pub mod compute;
mod continuous_forecast;
pub mod forecast;
pub mod lifecycle;
pub mod multivariate;
pub mod preprocess;

pub mod error;
mod feedback;
mod materialized;
#[cfg(test)]
mod perf;
pub mod registry;
mod streaming_anomaly;
mod util;

pub use accuracy::{
    AccuracyMetrics, ForecastAccuracyTracker, compute_accuracy, compute_accuracy_with_mase, mase,
};
pub use alerting::{AlertAction, AlertConfig, AlertEngine, FiredAlert};
pub use continuous_forecast::{ContinuousForecastConfig, ContinuousForecastEngine, ForecastUpdate};
pub use error::AnalyticsError;
pub use feedback::{AnomalyFeedback, AnomalyPrecisionTracker, FeedbackLabel, PrecisionStats};
pub use materialized::{ForecastCache, MaterializedForecast};
pub use registry::{
    DetectorFactory, ModelFactory, PluginError, PluginInfo, PluginRegistry, global_registry,
};
pub use streaming_anomaly::{ScoredAnomaly, StreamingAnomalyConfig, StreamingAnomalyEngine};