uqa-storage 0.5.0

Document store, inverted index, IVF/HNSW vectors, B-tree, R*Tree, catalog
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

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

//! Provider adapters retain frozen bindings without exposing mutable access to their containers.

use super::{retained::FieldBindings, AnalyzerBindings};
use crate::{read_control::StorageReadControl, StorageBackendResult};
use std::{collections::BTreeMap, sync::Arc};

/// Immutable provider metadata. Captures reserve names and ordered-map nodes before copying; clones share the admitted map and original default resolver without allocating.
pub struct RetainedAnalyzerBindings(AnalyzerBindings);

impl RetainedAnalyzerBindings {
    pub fn capture(
        source: &AnalyzerBindings,
        control: &StorageReadControl,
    ) -> StorageBackendResult<Self> {
        source.retained(control).map(Self)
    }
}

impl Clone for RetainedAnalyzerBindings {
    fn clone(&self) -> Self {
        let fields = match &self.0.fields {
            FieldBindings::Retained(fields) => FieldBindings::Retained(Arc::clone(fields)),
            FieldBindings::Live(fields) => {
                assert!(fields.is_empty(), "captured bindings own frozen fields");
                FieldBindings::Live(BTreeMap::new())
            }
        };
        Self(AnalyzerBindings {
            default: Arc::clone(&self.0.default),
            fields,
        })
    }
}

impl std::ops::Deref for RetainedAnalyzerBindings {
    type Target = AnalyzerBindings;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}