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

//! Banco TCP server binding with graceful shutdown.

use super::router::create_banco_router;
use super::state::BancoState;
use tokio::net::TcpListener;

/// Start the Banco HTTP server with graceful shutdown on SIGTERM/SIGINT.
pub async fn start_server(host: &str, port: u16, state: BancoState) -> anyhow::Result<()> {
    let addr = format!("{host}:{port}");
    let listener = TcpListener::bind(&addr).await?;

    let model_status = if let Some(info) = state.model.info() {
        format!("{} ({})", info.model_id, format!("{:?}", info.format).to_lowercase())
    } else {
        "none — load via POST /api/v1/models/load or --model flag".to_string()
    };

    let tokenizer_status = {
        #[cfg(feature = "aprender")]
        {
            if state.model.has_bpe_tokenizer() {
                "BPE (proper merge rules)"
            } else if state.model.is_loaded() {
                "greedy (no tokenizer.json found)"
            } else {
                "n/a"
            }
        }
        #[cfg(not(feature = "aprender"))]
        {
            "greedy (aprender not enabled)"
        }
    };

    eprintln!("┌──────────────────────────────────────────────────┐");
    eprintln!("│  Banco – Local AI Workbench                      │");
    eprintln!("├──────────────────────────────────────────────────┤");
    eprintln!("│  Listening:  {addr:<36}│");
    eprintln!("│  Privacy:    {:?}", state.privacy_tier);
    eprintln!("│  Model:      {model_status}");
    eprintln!("│  Tokenizer:  {tokenizer_status}");
    eprintln!("│  Telemetry:  disabled");
    eprintln!("├──────────────────────────────────────────────────┤");
    eprintln!("│  Browser:    http://{addr}/ (chat UI)");
    eprintln!("│  Core:       /health /api/v1/models /api/v1/system");
    eprintln!("│  Chat:       /api/v1/chat/completions (SSE)");
    eprintln!("│  Completions:/v1/completions (text, OpenAI-compat)");
    eprintln!("│  Data:       /api/v1/tokenize /detokenize /embeddings");
    eprintln!("│  Models:     /api/v1/models/load|unload|status|:id");
    eprintln!("│  Chat cfg:   /api/v1/chat/parameters");
    eprintln!("│  Convos:     /api/v1/conversations + /search /export /import");
    eprintln!("│  Presets:    /api/v1/prompts");
    eprintln!("│  Files:      /api/v1/data/upload /files");
    eprintln!("│  Recipes:    /api/v1/data/recipes /datasets");
    eprintln!("│  RAG:        /api/v1/rag/index /status /search");
    eprintln!("│  Eval:       /api/v1/eval/perplexity /runs");
    eprintln!("│  Training:   /api/v1/train/start /runs /presets /metrics /export");
    eprintln!("│  Merge:      /api/v1/models/merge /strategies (TIES/DARE/SLERP)");
    eprintln!("│  Experiments:/api/v1/experiments /compare");
    eprintln!("│  Batch:      /api/v1/batch");
    eprintln!("│  Registry:   /api/v1/models/pull /registry (pacha)");
    eprintln!("│  Audio:      /api/v1/audio/transcriptions (whisper-apr)");
    eprintln!("│  MCP:        /api/v1/mcp (Model Context Protocol)");
    eprintln!("│  Tools:      /api/v1/tools (calculator, code_execution, web_search)");
    eprintln!("│  Metrics:    /api/v1/metrics (Prometheus)");
    eprintln!("│  WebSocket:  /api/v1/ws (real-time events)");
    eprintln!("│  OpenAI:     /v1/models /v1/completions /v1/chat/completions /v1/embeddings");
    eprintln!("│  Ollama:     /api/generate /api/chat /api/tags /api/show /api/pull /api/delete");
    eprintln!("├──────────────────────────────────────────────────┤");
    let sys = state.system_info();
    eprintln!("│  Data:       {} files, {} conversations", sys.files, sys.conversations);
    eprintln!(
        "│  RAG:        {}",
        if sys.rag_indexed {
            format!("{} chunks indexed", sys.rag_chunks)
        } else {
            "empty".to_string()
        }
    );
    eprintln!("│  Storage:    ~/.banco/");
    eprintln!("│  Shutdown:   Ctrl+C (graceful drain)");
    eprintln!("└──────────────────────────────────────────────────┘");

    let app = create_banco_router(state);

    axum::serve(listener, app).with_graceful_shutdown(shutdown_signal()).await?;

    eprintln!("[banco] Graceful shutdown complete");
    Ok(())
}

/// Wait for shutdown signal (Ctrl+C / SIGTERM).
async fn shutdown_signal() {
    let ctrl_c = async {
        tokio::signal::ctrl_c().await.expect("failed to install Ctrl+C handler");
    };

    #[cfg(unix)]
    let terminate = async {
        tokio::signal::unix::signal(tokio::signal::unix::SignalKind::terminate())
            .expect("failed to install signal handler")
            .recv()
            .await;
    };

    #[cfg(not(unix))]
    let terminate = std::future::pending::<()>();

    tokio::select! {
        () = ctrl_c => eprintln!("\n[banco] Received Ctrl+C, shutting down..."),
        () = terminate => eprintln!("\n[banco] Received SIGTERM, shutting down..."),
    }
}