jammi-db 0.32.0

Vector database, SQL federation, mutable companion tables, and trigger broker for Jammi AI
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

//! Error taxonomy for the trigger-stream primitive.

use thiserror::Error;

use crate::catalog::backend::BackendError;
use crate::store::mutable::definition::MutableTableError;
use crate::tenant::TenantId;

#[derive(Debug, Error)]
pub enum TriggerError {
    #[error("topic not found: {0}")]
    TopicNotFound(String),

    #[error("topic schema conflict on {topic}: {detail}")]
    SchemaConflict { topic: String, detail: String },

    #[error("unsupported topic schema type for column '{column}': {data_type}")]
    UnsupportedSchemaType { column: String, data_type: String },

    #[error("batch schema does not match topic schema: {0}")]
    BatchSchemaMismatch(String),

    #[error(
        "publish tenant mismatch on topic '{topic}': topic is pinned to {topic_tenant:?}, publish was scoped to {publish_tenant:?}"
    )]
    PublishTenantMismatch {
        topic: String,
        topic_tenant: Option<TenantId>,
        publish_tenant: Option<TenantId>,
    },

    #[error("predicate parse failure: {0}")]
    PredicateParse(String),

    #[error("predicate evaluation failure: {0}")]
    PredicateEval(String),

    #[error("predicate uses an unsupported construct: {0}")]
    PredicateUnsupported(String),

    #[error("offset {0} is older than broker retention")]
    OffsetEvicted(u64),

    #[error("backing table unavailable: {0}")]
    BackingTable(#[from] MutableTableError),

    #[error("catalog backend error: {0}")]
    Backend(#[from] BackendError),

    #[error("broker driver error: {0}")]
    Driver(String),

    #[error("topic catalog corruption: {0}")]
    Catalog(String),
}