uqa-engine 0.4.0

Engine: schema-aware table store, catalog restore, transactions
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

//
// Unified Query Algebra
//
// Copyright (c) 2023-2026 Cognica, Inc.
//

use super::*;
use uqa_storage::{DocumentMetadata, StoredDocument};

#[path = "../tests/support/native_catalog.rs"]
pub(crate) mod native_storage;

fn doc<const N: usize>(pairs: [(&str, Value); N]) -> Document {
    pairs.into_iter().map(|(k, v)| (k.to_string(), v)).collect()
}

fn s(v: &str) -> Value {
    Value::Str(v.to_string())
}

fn vector(values: &[f64]) -> Value {
    Value::List(values.iter().copied().map(Value::Float).collect())
}

fn vector_index_kind(engine: &Engine, table: &str, field: &str) -> String {
    let table = engine.table(table).unwrap().expect("table");
    let indexes = table.vector_indexes.read();
    indexes
        .get(field)
        .expect("vector index")
        .index_kind()
        .into()
}

mod api_validation;

mod storage_cancellation;
mod storage_consistency;

mod search_and_vectors;

mod catalog;
mod prepared;
mod queries;
mod system_catalog_locks;
mod system_catalog_security;
mod table_locks;
mod virtual_catalog_names;

mod direct_drop_locks;
mod drop_locks;
mod relation_lock_support;
mod view_locks;