axiomsync 1.0.0

Core data-processing engine for AxiomSync local retrieval runtime.
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

use std::fs;
use std::path::Path;

use crate::models::{
    BenchmarkGateArtifacts, BenchmarkGateExecution, BenchmarkGateQuorum, BenchmarkGateResult,
    BenchmarkGateRunResult, BenchmarkGateSnapshot, BenchmarkGateThresholds, BenchmarkSummary,
    EvalBucket, EvalCaseResult, EvalLoopReport,
};

pub(super) fn eval_report(executed_cases: usize, top1_accuracy: f32) -> EvalLoopReport {
    EvalLoopReport {
        run_id: "run-1".to_string(),
        created_at: "2026-01-01T00:00:00Z".to_string(),
        selection: crate::models::EvalRunSelection {
            trace_limit: 10,
            query_limit: 10,
            search_limit: 5,
            include_golden: true,
            golden_only: false,
        },
        coverage: crate::models::EvalCoverageSummary {
            traces_scanned: 10,
            trace_cases_used: 5,
            golden_cases_used: 5,
            executed_cases,
        },
        quality: crate::models::EvalQualitySummary {
            passed: 0,
            failed: 0,
            top1_accuracy,
            buckets: Vec::<EvalBucket>::new(),
            failures: Vec::<EvalCaseResult>::new(),
        },
        artifacts: crate::models::EvalArtifacts {
            report_uri: "axiom://queue/eval/reports/x.json".to_string(),
            query_set_uri: "axiom://queue/eval/query_sets/x.json".to_string(),
            markdown_report_uri: "axiom://queue/eval/reports/x.md".to_string(),
        },
    }
}

pub(super) fn benchmark_gate_result(
    release_check_uri: Option<&str>,
    gate_record_uri: Option<&str>,
) -> BenchmarkGateResult {
    BenchmarkGateResult {
        passed: true,
        gate_profile: "rc-release".to_string(),
        thresholds: BenchmarkGateThresholds {
            threshold_p95_ms: 1000,
            min_top1_accuracy: 0.75,
            min_stress_top1_accuracy: None,
            max_p95_regression_pct: Some(0.1),
            max_top1_regression_pct: Some(2.0),
        },
        quorum: BenchmarkGateQuorum {
            window_size: 3,
            required_passes: 1,
        },
        snapshot: BenchmarkGateSnapshot {
            latest: Some(BenchmarkSummary {
                run_id: "run".to_string(),
                created_at: "2026-01-01T00:00:00Z".to_string(),
                executed_cases: 10,
                top1_accuracy: 0.9,
                p95_latency_ms: 700,
                p95_latency_us: Some(699_420),
                report_uri: "axiom://queue/benchmarks/reports/run.json".to_string(),
            }),
            previous: None,
            regression_pct: None,
            top1_regression_pct: None,
            stress_top1_accuracy: None,
        },
        execution: BenchmarkGateExecution {
            evaluated_runs: 1,
            passing_runs: 1,
            run_results: vec![BenchmarkGateRunResult {
                run_id: "run".to_string(),
                passed: true,
                p95_latency_ms: 700,
                p95_latency_us: Some(699_420),
                top1_accuracy: 0.9,
                stress_top1_accuracy: None,
                regression_pct: None,
                top1_regression_pct: None,
                reasons: vec!["ok".to_string()],
            }],
            reasons: vec!["ok".to_string()],
        },
        artifacts: BenchmarkGateArtifacts {
            gate_record_uri: gate_record_uri.map(ToString::to_string),
            release_check_uri: release_check_uri.map(ToString::to_string),
            embedding_provider: Some("semantic-model-http".to_string()),
            embedding_strict_error: None,
        },
    }
}

pub(super) fn write_contract_gate_workspace_fixture(
    root: &Path,
    episodic_dep: &str,
    lock_source: Option<&str>,
) {
    let core = root.join("crates").join("axiomsync");
    let engine = core.join("src").join("om").join("engine");
    let prompt = engine.join("prompt");
    fs::create_dir_all(&core).expect("mkdir core");
    fs::create_dir_all(&prompt).expect("mkdir vendored prompt");

    let dependencies_block = if episodic_dep.trim().is_empty() {
        String::new()
    } else {
        format!("\n[dependencies]\n{episodic_dep}\n")
    };
    fs::write(
        core.join("Cargo.toml"),
        format!("[package]\nname=\"axiomsync\"\nversion=\"0.1.0\"\n{dependencies_block}"),
    )
    .expect("write core cargo");
    fs::write(
        engine.join("mod.rs"),
        "pub(crate) fn vendored_engine_fixture() {}\n",
    )
    .expect("write vendored engine mod");
    fs::write(
        prompt.join("contract.rs"),
        format!(
            "pub const OM_PROMPT_CONTRACT_NAME: &str = \"{}\";\n",
            crate::om::engine::OM_PROMPT_CONTRACT_NAME
        ),
    )
    .expect("write vendored prompt contract");

    let lock_source_line = lock_source
        .map(|value| format!("source = \"{value}\"\n"))
        .unwrap_or_default();
    let lockfile = if episodic_dep.trim().is_empty() && lock_source.is_none() {
        String::new()
    } else {
        format!("[[package]]\nname = \"episodic\"\nversion = \"0.2.3\"\n{lock_source_line}\n")
    };
    fs::write(root.join("Cargo.lock"), lockfile).expect("write lockfile");
}