neumann_server 0.4.0

gRPC server exposing Neumann database via QueryRouter
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

// SPDX-License-Identifier: MIT OR Apache-2.0
//! Neumann Server binary entry point.

use std::sync::Arc;

use neumann_server::{NeumannServer, ServerConfig};
use parking_lot::RwLock;
use query_router::QueryRouter;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    // Initialize tracing
    tracing_subscriber::fmt()
        .with_env_filter(
            tracing_subscriber::EnvFilter::from_default_env()
                .add_directive("neumann_server=info".parse()?)
                .add_directive("query_router=info".parse()?)
                .add_directive("tower_http=debug".parse()?),
        )
        .init();

    // Load configuration from environment or defaults
    let config = ServerConfig::from_env()?;

    tracing::info!("Starting Neumann server on {}", config.bind_addr);

    // Create the query router
    let router = Arc::new(RwLock::new(QueryRouter::new()));

    // Initialize cluster mode if configured
    if let Some(ref cluster_config) = config.cluster {
        router.write().init_cluster_with_wal(
            &cluster_config.node_id,
            cluster_config.raft_bind_addr,
            &cluster_config.peers,
            &cluster_config.data_dir,
        )?;
        tracing::info!(
            "Cluster mode: {} listening on {}",
            cluster_config.node_id,
            cluster_config.raft_bind_addr,
        );
    }

    // Create and run the server
    let server = NeumannServer::new(router, config);
    server.serve().await?;

    Ok(())
}