kestrel-chartkit 0.11.3

High-performance Rust technical analysis library for indicator math, market regime classification, composite scoring, and SVG visualization.
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

use crate::model::MarketRegime;
use crate::signal::{CompositeSignal, TriggerAction};
use std::collections::HashMap;

#[cfg(feature = "serde")]
use serde::{Deserialize, Serialize};

/// Exportable snapshot record of features, regime, and signal outputs for research or logging sinks.
#[derive(Debug, Clone, PartialEq)]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
pub struct FeatureRecord {
    pub timestamp: i64,
    pub symbol: String,
    pub regime: MarketRegime,
    pub indicator_values: HashMap<String, f64>,
    pub subscores: HashMap<String, f64>,
    pub trigger: TriggerAction,
    pub score: f64,
    pub agreement: f64,
}

/// Feature and research dataset exporter.
#[derive(Debug, Clone, Default)]
pub struct FeatureExporter;

impl FeatureExporter {
    pub fn new() -> Self {
        Self
    }

    /// Builds a sink-independent `FeatureRecord` snapshot.
    pub fn export_record(
        &self,
        timestamp: i64,
        symbol: &str,
        regime: MarketRegime,
        indicator_values: HashMap<String, f64>,
        signal: &CompositeSignal,
    ) -> FeatureRecord {
        let mut subscores = HashMap::new();
        for sub in &signal.per_indicator {
            subscores.insert(sub.indicator.clone(), sub.score);
        }

        FeatureRecord {
            timestamp,
            symbol: symbol.to_string(),
            regime,
            indicator_values,
            subscores,
            trigger: signal.trigger,
            score: signal.score,
            agreement: signal.agreement,
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::signal::PermissionGrade;

    #[test]
    fn test_feature_exporter() {
        let exporter = FeatureExporter::new();
        let signal = CompositeSignal {
            score: 0.85,
            direction: crate::signal::SignalDirection::Bullish,
            permission: PermissionGrade::ClearToTrade,
            trigger: TriggerAction::Buy,
            target_zone: None,
            invalidation_zone: None,
            setup_duration: None,
            risk_plan: None,
            heat_score: 0.5,
            sr_zones: Vec::new(),
            per_indicator: Vec::new(),
            reasons: Vec::new(),
            explanation: "test".to_string(),
            agreement: 0.9,
            regime: MarketRegime::BullishExpansion,
        };

        let rec = exporter.export_record(
            1000,
            "BTCUSD",
            MarketRegime::BullishExpansion,
            HashMap::from([("rsi".to_string(), 65.0)]),
            &signal,
        );

        assert_eq!(rec.symbol, "BTCUSD");
        assert_eq!(rec.indicator_values["rsi"], 65.0);
    }
}