converge-analytics 3.7.2

Analytics and ML pipeline for Converge agents
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

use converge_pack::gate::GateResult as Result;
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RankItem {
    pub id: String,
    pub scores: Vec<f64>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RankingInput {
    pub items: Vec<RankItem>,
    pub weights: Vec<f64>,
    pub higher_is_better: Vec<bool>,
    pub top_k: Option<usize>,
}

impl RankingInput {
    pub fn validate(&self) -> Result<()> {
        if self.items.is_empty() {
            return Err(converge_pack::GateError::invalid_input(
                "At least one item required",
            ));
        }
        let dim = self.weights.len();
        if dim == 0 {
            return Err(converge_pack::GateError::invalid_input(
                "At least one criterion required",
            ));
        }
        if self.higher_is_better.len() != dim {
            return Err(converge_pack::GateError::invalid_input(format!(
                "higher_is_better length {} must match weights length {}",
                self.higher_is_better.len(),
                dim
            )));
        }
        for weight in &self.weights {
            if *weight < 0.0 {
                return Err(converge_pack::GateError::invalid_input(
                    "All weights must be >= 0",
                ));
            }
        }
        for (i, item) in self.items.iter().enumerate() {
            if item.scores.len() != dim {
                return Err(converge_pack::GateError::invalid_input(format!(
                    "Item {} has {} scores, expected {}",
                    i,
                    item.scores.len(),
                    dim
                )));
            }
        }
        if let Some(top_k) = self.top_k {
            if top_k == 0 {
                return Err(converge_pack::GateError::invalid_input(
                    "top_k must be >= 1",
                ));
            }
        }
        Ok(())
    }
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RankedItem {
    pub id: String,
    pub rank: usize,
    pub composite_score: f64,
    pub normalized_scores: Vec<f64>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RankingOutput {
    pub ranked: Vec<RankedItem>,
    pub total_items: usize,
}

impl RankingOutput {
    pub fn summary(&self) -> String {
        format!(
            "Ranked {} items, top: {}",
            self.total_items,
            self.ranked.first().map(|r| r.id.as_str()).unwrap_or("none")
        )
    }
}