Struct MemoryCatalogManager

pub struct MemoryCatalogManager {
    catalogs: Arc<RwLock<HashMap<String, HashMap<String, HashMap<String, TableRef>>>>>,
}

Simple in-memory list of catalogs

Fields

catalogs: Arc<RwLock<HashMap<String, HashMap<String, HashMap<String, TableRef>>>>>

Collection of catalogs containing schemas and ultimately Tables

Implementations

impl MemoryCatalogManager

pub fn new() -> Arc<Self>

pub fn with_default_setup() -> Arc<Self>

Creates a manager with some default setups (e.g. default catalog/schema and information schema)

fn schema_exist_sync(&self, catalog: &str, schema: &str) -> Result<bool>

fn catalog_exist_sync(&self, catalog: &str) -> Result<bool>

pub fn register_catalog_sync(&self, name: &str) -> Result<bool>

Registers a catalog if it does not exist and returns false if the schema exists.

pub fn deregister_table_sync( &self, request: DeregisterTableRequest, ) -> Result<()>

pub fn register_schema_sync( &self, request: RegisterSchemaRequest, ) -> Result<bool>

Registers a schema if it does not exist. It returns an error if the catalog does not exist, and returns false if the schema exists.

pub fn register_table_sync(&self, request: RegisterTableRequest) -> Result<bool>

Registers a schema and returns an error if the catalog or schema does not exist.

fn create_catalog_entry( self: &Arc<Self>, catalog: String, ) -> HashMap<String, HashMap<String, TableRef>>

Trait Implementations

impl CatalogManager for MemoryCatalogManager

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: &'life1 str, schema: &'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 tables<'a>( &'a self, catalog: &'a str, schema: &'a str, _query_ctx: Option<&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 MemoryCatalogManager

fn clone(&self) -> MemoryCatalogManager

Returns a copy of the value.

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

Performs copy-assignment from source.