Struct coord::catalog::CatalogState

pub struct CatalogState {
    by_name: BTreeMap<String, Database>,
    by_id: BTreeMap<GlobalId, CatalogEntry>,
    by_oid: HashMap<u32, GlobalId>,
    enabled_indexes: HashMap<GlobalId, Vec<(GlobalId, Vec<MirScalarExpr>)>>,
    ambient_schemas: BTreeMap<String, Schema>,
    temporary_schemas: HashMap<u32, Schema>,
    roles: HashMap<String, Role>,
}

Fields

by_name: BTreeMap<String, Database>

by_id: BTreeMap<GlobalId, CatalogEntry>

by_oid: HashMap<u32, GlobalId>

enabled_indexes: HashMap<GlobalId, Vec<(GlobalId, Vec<MirScalarExpr>)>>

Contains only enabled indexes from objects in the catalog; does not contain indexes disabled by e.g. the disable_user_indexes flag.

ambient_schemas: BTreeMap<String, Schema>

temporary_schemas: HashMap<u32, Schema>

roles: HashMap<String, Role>

Implementations

impl CatalogState

pub(super) fn pack_database_update(
    &self,
    name: &str,
    diff: Diff
) -> BuiltinTableUpdate

pub(super) fn pack_schema_update(
    &self,
    database_spec: &DatabaseSpecifier,
    schema_name: &str,
    diff: Diff
) -> BuiltinTableUpdate

pub(super) fn pack_role_update(
    &self,
    name: &str,
    diff: Diff
) -> BuiltinTableUpdate

pub(super) fn pack_item_update(
    &self,
    id: GlobalId,
    diff: Diff
) -> Vec<BuiltinTableUpdate>

fn pack_table_update(
    &self,
    id: GlobalId,
    oid: u32,
    schema_id: i64,
    name: &str,
    table: &Table,
    diff: Diff
) -> Vec<BuiltinTableUpdate>

fn pack_source_update(
    &self,
    id: GlobalId,
    oid: u32,
    schema_id: i64,
    name: &str,
    source: &Source,
    diff: Diff
) -> Vec<BuiltinTableUpdate>

fn pack_view_update(
    &self,
    id: GlobalId,
    oid: u32,
    schema_id: i64,
    name: &str,
    diff: Diff
) -> Vec<BuiltinTableUpdate>

fn pack_sink_update(
    &self,
    id: GlobalId,
    oid: u32,
    schema_id: i64,
    name: &str,
    sink: &Sink,
    diff: Diff
) -> Vec<BuiltinTableUpdate>

fn pack_index_update(
    &self,
    id: GlobalId,
    oid: u32,
    name: &str,
    index: &Index,
    diff: Diff
) -> Vec<BuiltinTableUpdate>

fn pack_type_update(
    &self,
    id: GlobalId,
    oid: u32,
    schema_id: i64,
    name: &str,
    typ: &Type,
    diff: Diff
) -> Vec<BuiltinTableUpdate>

fn pack_func_update(
    &self,
    id: GlobalId,
    schema_id: i64,
    name: &str,
    func: &Func,
    diff: Diff
) -> Vec<BuiltinTableUpdate>

impl CatalogState

pub fn source_description_for(&self, id: GlobalId) -> Option<SourceDesc>

Encapsulates the logic for creating a source description for a source or table in the catalog.

pub fn enabled_indexes(
    &self
) -> &HashMap<GlobalId, Vec<(GlobalId, Vec<MirScalarExpr>)>>

pub fn nearest_indexes(
    &self,
    ids: &[GlobalId]
) -> (Vec<GlobalId>, Vec<GlobalId>)

Finds the nearest indexes that can satisfy the views or sources whose identifiers are listed in ids.

Returns the identifiers of all discovered indexes, and the identifiers of the discovered unmaterialized sources required to satisfy ids. The returned list of indexes is incomplete iff ids depends on at least one unmaterialized source.

pub fn dependent_indexes(&self, id: GlobalId) -> Vec<GlobalId>

Computes the IDs of any indexes that transitively depend on this catalog entry.

fn dependent_indexes_inner(&self, id: GlobalId, out: &mut Vec<GlobalId>)

pub fn uses_tables(&self, id: GlobalId) -> bool

pub fn get_by_id(&self, id: &GlobalId) -> &CatalogEntry

pub fn insert_item(
    &mut self,
    id: GlobalId,
    oid: u32,
    name: FullName,
    item: CatalogItem
)

pub fn populate_enabled_indexes(&mut self, id: GlobalId, item: &CatalogItem)

fn get_schema(
    &self,
    database_spec: &DatabaseSpecifier,
    schema_name: &str,
    conn_id: u32
) -> Option<&Schema>

Gets the schema map for the database matching database_spec.

fn get_schema_mut(
    &mut self,
    database_spec: &DatabaseSpecifier,
    schema_name: &str,
    conn_id: u32
) -> Option<&mut Schema>

Like get_schemas, but returns a mut reference.

pub fn is_volatile(&self, id: GlobalId) -> Volatility

Reports whether the item identified by id is considered volatile.

None indicates that the volatility of id is unknown.

pub fn get_by_oid(&self, oid: &u32) -> &CatalogEntry

Trait Implementations

impl Clone for CatalogState

fn clone(&self) -> CatalogState

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for CatalogState

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

Formats the value using the given formatter.