graphar-flight 0.1.1

Apache Arrow Flight SQL service over FalkorDB — Cypher in, Arrow out
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

use thiserror::Error;

pub type Result<T> = std::result::Result<T, FlightSqlError>;

#[derive(Debug, Error)]
pub enum FlightSqlError {
    #[error("Redis error: {0}")]
    Redis(#[from] redis::RedisError),

    #[error("Arrow error: {0}")]
    Arrow(#[from] arrow::error::ArrowError),

    #[error("Arrow Flight error: {0}")]
    Flight(#[from] arrow_flight::error::FlightError),

    #[error("FalkorDB error: {0}")]
    Falkor(#[from] graphar_falkordb::FalkorError),

    #[error("GraphAr error: {0}")]
    Graphar(#[from] graphar::GraphArError),

    #[error("Iceberg/skade error: {0}")]
    Skade(String),

    #[error("Schema not registered for key '{0}' — call SchemaRegistry::register first")]
    UnregisteredSchema(String),

    #[error("Unexpected FalkorDB response shape: {0}")]
    MalformedResponse(String),

    #[error(
        "DoPut command unrecognised: '{0}' (expected VERTICES:<label> or EDGES:<src>:<type>:<dst>)"
    )]
    UnknownPutCommand(String),

    #[error("Column count mismatch: schema has {schema} columns but row has {row}")]
    ColumnCountMismatch { schema: usize, row: usize },

    #[error("Transport error: {0}")]
    Transport(#[from] tonic::transport::Error),
}

impl From<FlightSqlError> for tonic::Status {
    fn from(e: FlightSqlError) -> Self {
        match &e {
            FlightSqlError::UnregisteredSchema(_) => tonic::Status::not_found(e.to_string()),
            FlightSqlError::UnknownPutCommand(_) => tonic::Status::invalid_argument(e.to_string()),
            _ => tonic::Status::internal(e.to_string()),
        }
    }
}