Struct KeyValueCatalog 

pub struct KeyValueCatalog { /* private fields */ }

Implementations

impl KeyValueCatalog

pub fn new(store: Arc<dyn KeyValueStore>) -> Self

pub fn store(&self) -> Arc<dyn KeyValueStore>

Trait Implementations

impl CatalogFacade for KeyValueCatalog

fn set_metadata(&self, key: &str, value: &str) -> StorageBackendResult<()>

fn get_metadata(&self, key: &str) -> StorageBackendResult<Option<String>>

fn migrate_relation_namespace(&self) -> StorageBackendResult<()>

Atomically migrate the former flat relation namespace into typed, schema-owned catalog objects. Implementations must reject normalized or cross-kind collisions instead of merging either object.

fn save_schema(&self, name: &str) -> StorageBackendResult<()>

fn drop_schema(&self, name: &str) -> StorageBackendResult<()>

fn load_schemas(&self) -> StorageBackendResult<Vec<String>>

fn save_table(&self, schema: &TableSchema) -> StorageBackendResult<()>

fn load_tables(&self) -> StorageBackendResult<Vec<TableSchema>>

fn drop_table(&self, name: &str) -> StorageBackendResult<()>

fn drop_table_and_data(&self, name: &str) -> StorageBackendResult<()>

Remove a table definition and every catalog/data row owned by it as one atomic catalog operation.

fn purge_table_data(&self, name: &str) -> StorageBackendResult<()>

fn rename_table_data(&self, from: &str, to: &str) -> StorageBackendResult<()>

fn drop_column_data( &self, table_name: &str, column_name: &str, ) -> StorageBackendResult<()>

fn rename_column_data( &self, table_name: &str, from: &str, to: &str, ) -> StorageBackendResult<()>

fn save_model(&self, name: &str, json: &str) -> StorageBackendResult<()>

fn load_models(&self) -> StorageBackendResult<Vec<(String, String)>>

fn load_model(&self, name: &str) -> StorageBackendResult<Option<String>>

fn drop_model(&self, name: &str) -> StorageBackendResult<()>

fn save_scoring_params( &self, name: &str, params_json: &str, ) -> StorageBackendResult<()>

fn load_scoring_params( &self, name: &str, ) -> StorageBackendResult<Option<String>>

fn load_all_scoring_params(&self) -> StorageBackendResult<Vec<(String, String)>>

fn drop_scoring_params(&self, name: &str) -> StorageBackendResult<()>

fn create_sequence_row( &self, sequence: &SequenceRow, ) -> StorageBackendResult<bool>

fn replace_sequence_row( &self, sequence: &SequenceRow, ) -> StorageBackendResult<bool>

fn drop_sequence_row(&self, name: &str) -> StorageBackendResult<bool>

fn load_sequence_rows(&self) -> StorageBackendResult<Vec<SequenceRow>>

fn next_sequence_value(&self, name: &str) -> StorageBackendResult<Option<i64>>

fn set_sequence_value( &self, name: &str, value: i64, ) -> StorageBackendResult<Option<i64>>

fn save_view(&self, view: &ViewRow) -> StorageBackendResult<()>

fn drop_view(&self, relation: &RelationIdentity) -> StorageBackendResult<bool>

fn load_views(&self) -> StorageBackendResult<Vec<ViewRow>>

fn save_named_graph(&self, name: &str) -> StorageBackendResult<()>

fn drop_named_graph(&self, name: &str) -> StorageBackendResult<()>

fn load_named_graphs(&self) -> StorageBackendResult<Vec<String>>

fn save_vertex( &self, vertex_id: u64, label: &str, properties_json: &str, ) -> StorageBackendResult<()>

fn delete_vertex(&self, vertex_id: u64) -> StorageBackendResult<()>

fn load_vertices(&self) -> StorageBackendResult<Vec<(u64, String, String)>>

fn save_edge( &self, edge_id: u64, source_id: u64, target_id: u64, label: &str, properties_json: &str, ) -> StorageBackendResult<()>

fn delete_edge(&self, edge_id: u64) -> StorageBackendResult<()>

fn load_edges(&self) -> StorageBackendResult<Vec<EdgeRow>>

fn save_graph_membership( &self, entity_type: &str, entity_id: u64, graph_name: &str, ) -> StorageBackendResult<()>

fn delete_graph_membership( &self, entity_type: &str, entity_id: u64, graph_name: &str, ) -> StorageBackendResult<()>

fn delete_graph_membership_for_graph( &self, graph_name: &str, ) -> StorageBackendResult<()>

fn load_graph_memberships( &self, ) -> StorageBackendResult<Vec<(String, u64, String)>>

fn purge_orphan_graph_entities(&self) -> StorageBackendResult<()>

fn replace_named_graph( &self, graph_name: &str, snapshot: &GraphSnapshot, ) -> StorageBackendResult<()>

fn drop_named_graph_data(&self, graph_name: &str) -> StorageBackendResult<()>

fn save_analyzer( &self, name: &str, config_json: &str, ) -> StorageBackendResult<()>

fn drop_analyzer(&self, name: &str) -> StorageBackendResult<()>

fn load_analyzers(&self) -> StorageBackendResult<Vec<(String, String)>>

fn save_table_field_analyzer( &self, table_name: &str, field: &str, phase: &str, analyzer_name: &str, ) -> StorageBackendResult<()>

fn replace_table_field_analyzer( &self, table_name: &str, field: &str, phase: &str, analyzer_name: &str, ) -> StorageBackendResult<()>

fn drop_table_field_analyzer_field( &self, table_name: &str, field: &str, ) -> StorageBackendResult<()>

fn drop_table_field_analyzers( &self, table_name: &str, ) -> StorageBackendResult<()>

fn load_table_field_analyzers( &self, ) -> StorageBackendResult<Vec<(String, String, String, String)>>

fn save_foreign_server( &self, name: &str, fdw_type: &str, options_json: &str, ) -> StorageBackendResult<()>

fn drop_foreign_server(&self, name: &str) -> StorageBackendResult<()>

fn load_foreign_servers( &self, ) -> StorageBackendResult<Vec<(String, String, String)>>

fn save_foreign_table( &self, relation: &RelationIdentity, server_name: &str, columns_json: &str, options_json: &str, ) -> StorageBackendResult<()>

fn drop_foreign_table( &self, relation: &RelationIdentity, ) -> StorageBackendResult<()>

fn load_foreign_tables(&self) -> StorageBackendResult<Vec<ForeignTableRow>>

fn save_catalog_index( &self, name: &str, index_type: &str, table_name: &str, columns_json: &str, parameters_json: &str, ) -> StorageBackendResult<()>

fn drop_catalog_index(&self, name: &str) -> StorageBackendResult<()>

fn drop_catalog_indexes_for_table( &self, table_name: &str, ) -> StorageBackendResult<()>

fn load_catalog_indexes(&self) -> StorageBackendResult<Vec<CatalogIndexRow>>

fn save_path_index( &self, graph_name: &str, label_sequences_json: &str, ) -> StorageBackendResult<()>

fn drop_path_index(&self, graph_name: &str) -> StorageBackendResult<()>

fn load_path_indexes(&self) -> StorageBackendResult<Vec<(String, String)>>

fn save_column_stats( &self, stats: ColumnStatsInput<'_>, ) -> StorageBackendResult<()>

fn replace_column_stats( &self, table_name: &str, stats: &[ColumnStatsInput<'_>], ) -> StorageBackendResult<()>

Atomically replace the complete statistics snapshot for one table. Implementations must leave the prior snapshot intact if any row fails.

fn load_column_stats( &self, table_name: &str, ) -> StorageBackendResult<Vec<ColumnStatsRow>>

fn delete_column_stats(&self, table_name: &str) -> StorageBackendResult<()>

fn fts_storage_was_reset(&self) -> bool

impl Clone for KeyValueCatalog

fn clone(&self) -> KeyValueCatalog

Returns a duplicate of the value.

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

Performs copy-assignment from source.