astraea-core 0.3.1

Foundational types and traits shared across every AstraeaDB crate: node/edge records, ID newtypes, and the StorageEngine, GraphOps, and VectorIndex traits.
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

use crate::types::{EdgeId, NodeId, PageId};

/// Top-level error type for AstraeaDB.
#[derive(Debug, thiserror::Error)]
pub enum AstraeaError {
    // --- Storage errors ---
    #[error("page {0} not found")]
    PageNotFound(PageId),

    #[error("page {0} is corrupted: {1}")]
    PageCorrupted(PageId, String),

    #[error("buffer pool is full, cannot pin page {0}")]
    BufferPoolFull(PageId),

    #[error("storage I/O error: {0}")]
    StorageIo(#[from] std::io::Error),

    #[error("storage error: {0}")]
    Storage(String),

    // --- Graph errors ---
    #[error("node {0} not found")]
    NodeNotFound(NodeId),

    #[error("edge {0} not found")]
    EdgeNotFound(EdgeId),

    #[error("duplicate node {0}")]
    DuplicateNode(NodeId),

    #[error("duplicate edge {0}")]
    DuplicateEdge(EdgeId),

    // --- Transaction errors ---
    #[error("transaction aborted: write-write conflict on entity {0}")]
    WriteConflict(u64),

    #[error("transaction not active")]
    TransactionNotActive,

    // --- Query errors ---
    #[error("parse error at position {position}: {message}")]
    ParseError { position: usize, message: String },

    #[error("query execution error: {0}")]
    QueryExecution(String),

    #[error("unknown label: {0}")]
    UnknownLabel(String),

    #[error("unknown edge type: {0}")]
    UnknownEdgeType(String),

    // --- Vector errors ---
    #[error("embedding dimension mismatch: expected {expected}, got {got}")]
    DimensionMismatch { expected: usize, got: usize },

    #[error("node {0} has no embedding")]
    NoEmbedding(NodeId),

    #[error("vector index not built")]
    IndexNotBuilt,

    // --- Serialization errors ---
    #[error("serialization error: {0}")]
    Serialization(String),

    #[error("deserialization error: {0}")]
    Deserialization(String),

    // --- Configuration errors ---
    #[error("configuration error: {0}")]
    Config(String),

    // --- Authentication errors ---
    #[error("authentication required")]
    AuthenticationRequired,

    #[error("invalid credentials")]
    InvalidCredentials,

    #[error("access denied: {0}")]
    AccessDenied(String),

    // --- TLS errors ---
    #[error("TLS error: {0}")]
    Tls(String),
}

/// Convenience alias.
pub type Result<T> = std::result::Result<T, AstraeaError>;