aprender-orchestrate 0.31.2

Sovereign AI orchestration: autonomous agents, ML serving, code analysis, and transpilation pipelines
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

//! Problem domain to capability mappings.

use super::super::types::ProblemDomain;
use super::types::KnowledgeGraph;

impl KnowledgeGraph {
    /// Initialize problem domain to capability mappings
    pub(crate) fn initialize_domain_mappings(&mut self) {
        use ProblemDomain::{
            CMigration, DataPipeline, DeepLearning, DistributedCompute, GraphAnalytics, Inference,
            LinearAlgebra, MediaProduction, ModelServing, Profiling, PythonMigration,
            ShellMigration, SpeechRecognition, SupervisedLearning, Testing, UnsupervisedLearning,
            Validation, VectorSearch,
        };

        self.domain_capabilities.insert(
            SupervisedLearning,
            vec![
                "linear_regression".into(),
                "logistic_regression".into(),
                "decision_tree".into(),
                "random_forest".into(),
                "gbm".into(),
                "naive_bayes".into(),
                "knn".into(),
                "svm".into(),
            ],
        );

        self.domain_capabilities.insert(
            UnsupervisedLearning,
            vec!["kmeans".into(), "pca".into(), "dbscan".into(), "hierarchical".into()],
        );

        self.domain_capabilities.insert(
            DeepLearning,
            vec!["autograd".into(), "lora".into(), "qlora".into(), "quantization".into()],
        );

        self.domain_capabilities.insert(
            Inference,
            vec!["model_serving".into(), "batching".into(), "moe_routing".into()],
        );

        self.domain_capabilities.insert(
            SpeechRecognition,
            vec![
                "speech_recognition".into(),
                "streaming_transcription".into(),
                "multilingual".into(),
                "whisper_quantization".into(),
            ],
        );

        self.domain_capabilities.insert(
            LinearAlgebra,
            vec!["vector_ops".into(), "matrix_ops".into(), "simd".into(), "gpu".into()],
        );

        self.domain_capabilities.insert(
            VectorSearch,
            vec!["vector_store".into(), "similarity_search".into(), "knn_search".into()],
        );

        self.domain_capabilities.insert(
            GraphAnalytics,
            vec!["pathfinding".into(), "centrality".into(), "community_detection".into()],
        );

        self.domain_capabilities.insert(
            PythonMigration,
            vec!["type_inference".into(), "sklearn_to_aprender".into(), "numpy_to_trueno".into()],
        );

        self.domain_capabilities
            .insert(CMigration, vec!["ownership_inference".into(), "unsafe_elimination".into()]);

        self.domain_capabilities
            .insert(ShellMigration, vec!["script_conversion".into(), "cli_generation".into()]);

        self.domain_capabilities.insert(
            DistributedCompute,
            vec![
                "work_stealing".into(),
                "cpu_executor".into(),
                "gpu_executor".into(),
                "remote_executor".into(),
            ],
        );

        self.domain_capabilities.insert(
            DataPipeline,
            vec!["csv".into(), "parquet".into(), "json".into(), "streaming".into()],
        );

        self.domain_capabilities.insert(
            ModelServing,
            vec!["model_serving".into(), "lambda".into(), "container".into(), "edge".into()],
        );

        self.domain_capabilities.insert(
            Testing,
            vec![
                "coverage_check".into(),
                "mutation_testing".into(),
                "tdg_scoring".into(),
                "parity_checking".into(),
                "oracle_generation".into(),
                "falsification_testing".into(),
                "quantization_drift".into(),
                "roundtrip_validation".into(),
            ],
        );

        self.domain_capabilities.insert(
            Profiling,
            vec!["syscall_trace".into(), "flamegraph".into(), "golden_trace_comparison".into()],
        );

        self.domain_capabilities.insert(
            Validation,
            vec![
                "privacy_audit".into(),
                "quality_gates".into(),
                "complexity_analysis".into(),
                "contract_parsing".into(),
                "scaffold_generation".into(),
                "kani_verification".into(),
                "probar_generation".into(),
                "traceability_audit".into(),
                "binding_registry".into(),
            ],
        );

        self.domain_capabilities.insert(
            MediaProduction,
            vec![
                "video_rendering".into(),
                "mlt_xml".into(),
                "ffmpeg_encode".into(),
                "transition_blend".into(),
                "course_production".into(),
                "audio_processing".into(),
                "subtitle_burn_in".into(),
                "media_concat".into(),
                "transcription_qa".into(),
                "vocabulary_enrichment".into(),
                "content_generation".into(),
                "svg_asset_pipeline".into(),
                "course_quality_scoring".into(),
                "course_publishing".into(),
            ],
        );
    }
}