Struct SchemaManager 

pub struct SchemaManager { /* private fields */ }

Schema management service for handling table schemas and UDT definitions

Implementations

impl SchemaManager

pub async fn new<P: AsRef<Path>>(path: P) -> Result<Self>

Create a new schema manager from a path

pub async fn new_with_storage( storage: Arc<StorageEngine>, _config: &Config, ) -> Result<Self>

Create a new schema manager with storage

pub async fn new_with_registry( storage: Arc<StorageEngine>, registry: Arc<RwLock<SchemaRegistry>>, _config: &Config, ) -> Result<Self>

Create a new schema manager with a pre-loaded SchemaRegistry

This constructor is used when schemas are loaded from external .cql files during ingestion, allowing the pre-loaded schemas to be used by the query engine.

Arguments

• storage - The storage engine instance
• registry - Pre-loaded schema registry from ingestion
• _config - Database configuration (currently unused)

pub async fn register_udt(&self, udt_def: UdtTypeDef)

Register a new UDT type definition

pub async fn get_udt(&self, keyspace: &str, name: &str) -> Option<UdtTypeDef>

Get a UDT definition (returns a cloned UdtTypeDef)

pub async fn load_schema(&self, table_name: &str) -> Result<TableSchema>

Load schema for a table

pub async fn parse_and_register_cql_schema( &self, cql: &str, ) -> Result<TableSchema>

Parse and register a schema from a CQL CREATE TABLE statement

pub async fn find_schema_by_table( &self, keyspace: &Option<String>, table: &str, ) -> Option<TableSchema>

Find schema by table name with optional keyspace matching

pub fn extract_table_info(&self, cql: &str) -> Result<(Option<String>, String)>

Extract table information from CQL without full parsing

pub fn cql_type_to_internal(&self, cql_type: &str) -> Result<CqlTypeId>

Convert CQL type string to internal type ID

pub async fn get_table_schema(&self, table_name: &str) -> Result<TableSchema>

Get table schema by name (async for compatibility)

Trait Implementations

impl Debug for SchemaManager

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.