Struct KvBackendCatalogManager 

pub struct KvBackendCatalogManager {
    pub(super) information_extension: InformationExtensionRef,
    pub(super) entity_graph_provider: Arc<OnceLock<EntityGraphProviderRef>>,
    pub(super) partition_manager: PartitionRuleManagerRef,
    pub(super) table_metadata_manager: TableMetadataManagerRef,
    pub(super) system_catalog: SystemCatalog,
    pub(super) cache_registry: LayeredCacheRegistryRef,
    pub(super) procedure_manager: Option<ProcedureManagerRef>,
}

Access all existing catalog, schema and tables.

The result comes from two source, all the user tables are presented in a kv-backend which persists the metadata of a table. And system tables comes from SystemCatalog, which is static and read-only.

Fields

information_extension: InformationExtensionRef

Provides the extension methods for the information_schema tables

entity_graph_provider: Arc<OnceLock<EntityGraphProviderRef>>

Backs the computed entity-graph tables (semantic_entities / semantic_relationships). Set once, after the query engine is built, to break the catalog -> query cycle; None until then. Arc so the cell stays shared across Clones of the manager (a plain OnceLock would fork on clone).

partition_manager: PartitionRuleManagerRef

Manages partition rules.

table_metadata_manager: TableMetadataManagerRef

Manages table metadata.

system_catalog: SystemCatalog

A sub-CatalogManager that handles system tables

cache_registry: LayeredCacheRegistryRef

Cache registry for all caches.

procedure_manager: Option<ProcedureManagerRef>

Only available in Standalone mode.

Implementations

impl KvBackendCatalogManager

pub fn view_info_cache(&self) -> Result<ViewInfoCacheRef>

pub fn information_extension(&self) -> InformationExtensionRef

Returns the [InformationExtension].

pub fn entity_graph_provider(&self) -> Option<EntityGraphProviderRef>

Returns the entity-graph provider, or None if it has not been injected yet (before the query engine is built). The computed graph tables stream empty until it is set.

pub fn set_entity_graph_provider(&self, provider: EntityGraphProviderRef)

Injects the entity-graph provider once the query engine exists. A second call is a no-op (the first binding wins).

pub fn partition_manager(&self) -> PartitionRuleManagerRef

pub fn table_metadata_manager_ref(&self) -> &TableMetadataManagerRef

pub fn procedure_manager(&self) -> Option<ProcedureManagerRef>

async fn override_logical_table_partition_key_indices( table_route_cache: &TableRouteCacheRef, table_info_cache: &TableInfoCacheRef, table: TableRef, ) -> Result<TableRef>

Trait Implementations

impl CatalogManager for KvBackendCatalogManager

fn as_any(&self) -> &dyn Any

fn catalog_names<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn schema_names<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, catalog: &'life1 str, query_ctx: Option<&'life2 QueryContext>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn table_names<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, catalog: &'life1 str, schema: &'life2 str, query_ctx: Option<&'life3 QueryContext>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn catalog_exists<'life0, 'life1, 'async_trait>( &'life0 self, catalog: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn schema_exists<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, catalog: &'life1 str, schema: &'life2 str, query_ctx: Option<&'life3 QueryContext>, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn table_exists<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, catalog: &'life1 str, schema: &'life2 str, table: &'life3 str, query_ctx: Option<&'life4 QueryContext>, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

fn table<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, catalog_name: &'life1 str, schema_name: &'life2 str, table_name: &'life3 str, query_ctx: Option<&'life4 QueryContext>, ) -> Pin<Box<dyn Future<Output = Result<Option<TableRef>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Returns the table by catalog, schema and table name.

fn table_id<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, catalog_name: &'life1 str, schema_name: &'life2 str, table_name: &'life3 str, query_ctx: Option<&'life4 QueryContext>, ) -> Pin<Box<dyn Future<Output = Result<Option<TableId>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Returns the table id of provided table ident.

fn table_info_by_id<'life0, 'async_trait>( &'life0 self, table_id: TableId, ) -> Pin<Box<dyn Future<Output = Result<Option<TableInfoRef>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the table of provided id.

fn tables_by_ids<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, catalog: &'life1 str, schema: &'life2 str, table_ids: &'life3 [TableId], ) -> Pin<Box<dyn Future<Output = Result<Vec<TableRef>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Returns the tables by table ids.

fn tables<'a>( &'a self, catalog: &'a str, schema: &'a str, query_ctx: Option<&'a QueryContext>, ) -> BoxStream<'a, Result<TableRef>>

Returns all tables with a stream by catalog and schema.

fn is_reserved_schema_name(&self, schema: &str) -> bool

Check if schema is a reserved schema name

impl Clone for KvBackendCatalogManager

fn clone(&self) -> KvBackendCatalogManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.