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

//! # chronix-multivariate
//!
//! Multi-series analysis for the Chronix time-series database.
//!
//! ## Capabilities
//!
//! | Feature | Key Types |
//! |---------|-----------|
//! | Series alignment | [`MultiSeriesContext`], [`ColumnarMatrix`] |
//! | Correlation | [`PearsonCorrelation`], [`SpearmanCorrelation`], [`KendallTau`] |
//! | Rolling / lag correlation | [`RollingCorrelation`], [`LagCorrelation`] |
//! | Correlation matrix | [`CrossCorrelationMatrix`] |
//! | Anomaly detection | [`MahalanobisDetector`], [`IsolationForestDetector`], [`PcaAnomalyDetector`] |
//! | Forecasting | [`MultiLinearRegression`], [`VarModel`] |
//! | Derived series | [`ArithmeticExpr`], [`DerivedSeriesEngine`] |
//! | Composite signals | [`CompositeSignalEngine`], [`CompositeSignalRule`] |
//!
//! ## Overview
//!
//! [`MultiSeriesContext`] aligns multiple time-series to a common time grid
//! (via interpolation or forward-fill), producing a [`ColumnarMatrix`] that
//! feeds into correlation, anomaly detection, and forecasting APIs.
//!
//! All multivariate anomaly detectors implement [`MultivariateAnomalyDetector`]
//! and produce [`MultivariateAnomalyScore`] for uniform consumption.
//!
//! [`CompositeSignalEngine`] evaluates boolean rules over multiple series
//! and emits signals via an async channel when conditions are met.

#![warn(missing_docs)]
#![deny(unsafe_code)]

mod composite;
mod context;
mod correlation;
mod derived;
mod error;
/// Standalone Granger causality utilities.
mod mv_anomaly;
mod mv_forecast;

pub use composite::{
    AnalyticsResults, CompositeSignal, CompositeSignalEngine, CompositeSignalRule,
    DEFAULT_SIGNAL_CHANNEL_CAPACITY, SignalReceiver, SignalSender, signal_channel,
};
pub use context::{ColumnarMatrix, MultiSeriesContext};
pub use correlation::{
    CorrelationMethod, CrossCorrelationMatrix, KendallTau, LagCorrelation, PearsonCorrelation,
    RollingCorrelation, SpearmanCorrelation,
};
pub use derived::{
    ArithOp, ArithmeticExpr, DerivedSeriesDefinition, DerivedSeriesEngine, DerivedSeriesExpr,
    LazyDerivedSeries, LogReturnExpr, RollingStat, RollingStatExpr,
};
pub use error::MultivariateError;
pub use mv_anomaly::{
    IsolationForestDetector, MahalanobisDetector, MultivariateAnomalyDetector,
    MultivariateAnomalyScore, PcaAnomalyDetector,
};
pub use mv_forecast::{
    GrangerCausalityResult, MultiLinearRegression, MultivariateForecastModel,
    MultivariateForecastResult, VarModel,
};