orchestrator-config 0.1.1

Configuration models and loading for the Agent Orchestrator
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

use serde::{Deserialize, Serialize};

/// Configuration for reading a value from a workflow store before step execution.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
pub struct StoreInputConfig {
    /// Store name (WorkflowStore resource)
    pub store: String,
    /// Key to read from the store
    pub key: String,
    /// Pipeline variable name to inject the value into
    pub as_var: String,
    /// If true, a missing key causes the step to fail
    #[serde(default)]
    pub required: bool,
}

/// Configuration for writing a pipeline variable to a workflow store after step execution.
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
pub struct StoreOutputConfig {
    /// Store name (WorkflowStore resource)
    pub store: String,
    /// Key to write in the store
    pub key: String,
    /// Pipeline variable to read the value from
    pub from_var: String,
}

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

    #[test]
    fn store_input_config_serde_round_trip() {
        let cfg = StoreInputConfig {
            store: "metrics".to_string(),
            key: "baseline".to_string(),
            as_var: "baseline_metrics".to_string(),
            required: true,
        };
        let json = serde_json::to_string(&cfg).expect("serialize");
        let back: StoreInputConfig = serde_json::from_str(&json).expect("deserialize");
        assert_eq!(back.store, "metrics");
        assert_eq!(back.key, "baseline");
        assert_eq!(back.as_var, "baseline_metrics");
        assert!(back.required);
    }

    #[test]
    fn store_input_config_required_defaults_false() {
        let json = r#"{"store":"s","key":"k","as_var":"v"}"#;
        let cfg: StoreInputConfig = serde_json::from_str(json).expect("deserialize");
        assert!(!cfg.required);
    }

    #[test]
    fn store_output_config_serde_round_trip() {
        let cfg = StoreOutputConfig {
            store: "results".to_string(),
            key: "final_score".to_string(),
            from_var: "score".to_string(),
        };
        let json = serde_json::to_string(&cfg).expect("serialize");
        let back: StoreOutputConfig = serde_json::from_str(&json).expect("deserialize");
        assert_eq!(back.store, "results");
        assert_eq!(back.key, "final_score");
        assert_eq!(back.from_var, "score");
    }
}