uqa-execution 0.5.0

Volcano physical operators with row-batch pipelines
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

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

//! Read guards shared by foreign catalog inquiries and definition execution.
use super::StoredForeignTable;
use crate::catalog::security::BoundTableSecurity;
use std::{collections::BTreeMap, ops::Deref};
use uqa_core::RelationIdentity;
pub type ForeignWrappersRead<'a> =
    Box<dyn Deref<Target = uqa_sql::catalog::foreign_wrapper::ForeignWrappers> + 'a>;
pub type ForeignServersRead<'a> = Box<
    dyn Deref<Target = BTreeMap<String, uqa_sql::catalog::foreign_server::ForeignServerDefinition>>
        + 'a,
>;
pub type ForeignTablesRead<'a> =
    Box<dyn Deref<Target = BTreeMap<RelationIdentity, StoredForeignTable>> + 'a>;
pub type ForeignSecurityRead<'a> =
    Box<dyn Deref<Target = BTreeMap<RelationIdentity, BoundTableSecurity>> + 'a>;
pub trait ForeignRegistryReads {
    fn wrappers(&self) -> ForeignWrappersRead<'_>;
    fn servers(&self) -> ForeignServersRead<'_>;
    fn tables(&self) -> ForeignTablesRead<'_>;
    fn security(&self) -> ForeignSecurityRead<'_>;
}