synth-ai-core 0.3.0

Rust core for Synth AI SDKs - API client, streaming, tracing, and tunnels
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
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};
use serde_json::Value;
use std::collections::HashMap;

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq, Hash)]
#[serde(rename_all = "snake_case")]
pub enum ScopeKind {
    Org,
    System,
    Run,
    Branch,
    Iteration,
    Candidate,
    Stage,
    Seed,
    Rollout,
    Evaluation,
    Custom,
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq, Hash)]
pub struct ScopeKey {
    pub kind: ScopeKind,
    pub id: String,
}

impl ScopeKey {
    pub fn new(kind: ScopeKind, id: impl Into<String>) -> Self {
        Self {
            kind,
            id: id.into(),
        }
    }
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
#[serde(rename_all = "snake_case")]
pub enum LeverKind {
    Prompt,
    Context,
    Code,
    Constraint,
    Note,
    Spec,
    GraphYaml,
    Variable,
    Experiment,
    Custom,
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
#[serde(rename_all = "snake_case")]
pub enum LeverFormat {
    Text,
    Json,
    Yaml,
    File,
    Custom,
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
#[serde(rename_all = "snake_case")]
pub enum LeverMutability {
    Optimizer,
    Human,
    System,
}

#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct LeverConstraints {
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub allowed_values: Option<Vec<Value>>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub min_value: Option<f64>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub max_value: Option<f64>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub regex: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub max_bytes: Option<usize>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub max_tokens: Option<usize>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub mime_type: Option<String>,
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, Eq)]
#[serde(rename_all = "snake_case")]
pub enum LeverActor {
    Optimizer,
    Human,
    System,
}

#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct LeverProvenance {
    pub actor: LeverActor,
    pub reason: String,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub source_event_id: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub source_trace_id: Option<String>,
}

#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct Lever {
    pub lever_id: String,
    pub kind: LeverKind,
    pub scope: Vec<ScopeKey>,
    pub value: Value,
    pub value_format: LeverFormat,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub constraints: Option<LeverConstraints>,
    pub mutability: LeverMutability,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub provenance: Option<LeverProvenance>,
    #[serde(default)]
    pub version: i64,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub created_at: Option<DateTime<Utc>>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub parent_version: Option<i64>,
}

#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct LeverSnapshot {
    pub lever_id: String,
    pub resolved_scope: Vec<ScopeKey>,
    pub version: i64,
    pub value: Value,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub applied_at: Option<DateTime<Utc>>,
}

#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct LeverMutation {
    pub lever_id: String,
    pub parent_version: i64,
    pub new_version: i64,
    pub mutation_type: String,
    #[serde(default)]
    pub delta: Value,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub created_at: Option<DateTime<Utc>>,
    #[serde(default)]
    pub optimizer_id: String,
}

/// MIPRO-specific lever summary payload (as returned in prompt-learning results).
#[derive(Clone, Debug, Serialize, Deserialize)]
pub struct MiproLeverSummary {
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub prompt_lever_id: Option<String>,
    #[serde(default)]
    pub candidate_lever_versions: HashMap<String, i64>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub best_candidate_id: Option<String>,
    #[serde(default, skip_serializing_if = "Option::is_none")]
    pub selected_candidate_id: Option<String>,
    #[serde(default)]
    pub baseline_candidate_id: String,
    #[serde(default)]
    pub lever_count: usize,
    #[serde(default)]
    pub mutation_count: usize,
    #[serde(default)]
    pub latest_version: i64,
}