uqa-engine 0.2.3

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

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

use super::{
    initial_random_state, normalize_analyzer_phase, parse_analyzer_config, Analyzer, Arc,
    AtomicBool, BTreeMap, CatalogFacade, ColumnStatsRow, DeepModel, DurableCatalogState, Engine,
    EpochCoordinator, FieldName, IVFIndexParams, ManagedConnection, Path, PersistentStorageBackend,
    PersistentStorageProvider, PersistentStorageSession, QueryRuntime, RuntimeExtensions, RwLock,
    SQLiteCompressedContainerAnchor, SQLiteCompressionOptions, SQLiteError, SQLiteStorageProvider,
    SessionContext, StorageBackendError, StorageBackendResult, StorageContext, TableSchema,
    TableState, Value, VectorIndex, SQL_FUNCTION_DEPTH_LIMIT,
};

mod cache_refresh;
mod catalog_sync;
mod data_sync;
mod graphs;
mod lifecycle;
mod registries;
mod session_seed;
mod statistics;
mod table_restore;

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub(crate) enum CatalogRestoreMode {
    InitialMigration,
    LoadOnly,
}

impl CatalogRestoreMode {
    pub(crate) fn allows_migration(self) -> bool {
        self == Self::InitialMigration
    }
}

#[cfg(test)]
mod tests;