Skip to main content

run_server

Function run_server 

Source
pub async fn run_server(
    redis_url: &str,
    graph: &str,
    registry: Arc<SchemaRegistry>,
    addr: SocketAddr,
) -> Result<()>
Expand description

Start the Cypher Flight SQL server and block until it shuts down.

use std::{net::SocketAddr, sync::Arc};
use graphar_flight::{SchemaRegistry, run_server};
use arrow_schema::{DataType, Field, Schema};

#[tokio::main]
async fn main() {
    let registry = Arc::new(SchemaRegistry::new());
    registry.register(
        "MATCH (n:Person) RETURN n.id, n.name",
        Arc::new(Schema::new(vec![
            Field::new("n.id",   DataType::Int64, false),
            Field::new("n.name", DataType::Utf8,  true),
        ])),
    );
    run_server("redis://127.0.0.1:6379", "mygraph", registry, "0.0.0.0:50051".parse().unwrap()).await.unwrap();
}