converge-prism-analytics 2.0.2

Closed-form analytics and inference for Converge agents: feature extraction, inference packs, and fuzzy inference. Training-pipeline concerns live in converge-crucible-models.
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
96
97
98
99
100
101
102
103
104
105
106

use serde::de::{self, Visitor};
use serde::{Deserialize, Deserializer, Serialize, Serializer};
use std::fmt;
pub use std::num::NonZeroUsize;

/// A smoothing or probability factor in [0.0, 1.0].
#[derive(Debug, Clone, Copy, PartialEq, PartialOrd)]
pub struct UnitFraction(f64);

impl UnitFraction {
    pub fn new(v: f64) -> Result<Self, String> {
        if (0.0..=1.0).contains(&v) {
            Ok(Self(v))
        } else {
            Err(format!("{v} is outside [0.0, 1.0]"))
        }
    }
    pub fn value(self) -> f64 {
        self.0
    }
}

impl Serialize for UnitFraction {
    fn serialize<S: Serializer>(&self, s: S) -> Result<S::Ok, S::Error> {
        s.serialize_f64(self.0)
    }
}

struct UnitFractionVisitor;

impl Visitor<'_> for UnitFractionVisitor {
    type Value = UnitFraction;

    fn expecting(&self, f: &mut fmt::Formatter) -> fmt::Result {
        f.write_str("a float in [0.0, 1.0]")
    }

    fn visit_f64<E: de::Error>(self, v: f64) -> Result<UnitFraction, E> {
        UnitFraction::new(v).map_err(de::Error::custom)
    }

    fn visit_i64<E: de::Error>(self, v: i64) -> Result<UnitFraction, E> {
        self.visit_f64(v as f64)
    }

    fn visit_u64<E: de::Error>(self, v: u64) -> Result<UnitFraction, E> {
        self.visit_f64(v as f64)
    }
}

impl<'de> Deserialize<'de> for UnitFraction {
    fn deserialize<D: Deserializer<'de>>(d: D) -> Result<Self, D::Error> {
        d.deserialize_f64(UnitFractionVisitor)
    }
}

/// A positive z-score threshold (> 0.0).
#[derive(Debug, Clone, Copy, PartialEq, PartialOrd)]
pub struct ZScoreThreshold(f64);

impl ZScoreThreshold {
    pub fn new(v: f64) -> Result<Self, String> {
        if v > 0.0 {
            Ok(Self(v))
        } else {
            Err(format!("{v} must be > 0.0"))
        }
    }
    pub fn value(self) -> f64 {
        self.0
    }
}

impl Serialize for ZScoreThreshold {
    fn serialize<S: Serializer>(&self, s: S) -> Result<S::Ok, S::Error> {
        s.serialize_f64(self.0)
    }
}

struct ZScoreThresholdVisitor;

impl Visitor<'_> for ZScoreThresholdVisitor {
    type Value = ZScoreThreshold;

    fn expecting(&self, f: &mut fmt::Formatter) -> fmt::Result {
        f.write_str("a float > 0.0")
    }

    fn visit_f64<E: de::Error>(self, v: f64) -> Result<ZScoreThreshold, E> {
        ZScoreThreshold::new(v).map_err(de::Error::custom)
    }

    fn visit_i64<E: de::Error>(self, v: i64) -> Result<ZScoreThreshold, E> {
        self.visit_f64(v as f64)
    }

    fn visit_u64<E: de::Error>(self, v: u64) -> Result<ZScoreThreshold, E> {
        self.visit_f64(v as f64)
    }
}

impl<'de> Deserialize<'de> for ZScoreThreshold {
    fn deserialize<D: Deserializer<'de>>(d: D) -> Result<Self, D::Error> {
        d.deserialize_f64(ZScoreThresholdVisitor)
    }
}