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();
}