Struct SchemaManager 

pub struct SchemaManager { /* private fields */ }

Implementations

impl SchemaManager

pub fn new() -> Self

pub fn with_shared_schema_callbacks( shared: Arc<EventSubscriptions<SchemaChangeEvent>>, ) -> Self

Build a manager sharing one schema-event registry with IndexManager.

Single enum dual emission source: table/space DDL is emitted by SchemaManager, index DDL by IndexManager; sharing one registry lets observers subscribe once and receive both halves.

pub fn shared_schema_callbacks( &self, ) -> Arc<EventSubscriptions<SchemaChangeEvent>>

Shared schema-event registry behind this manager.

pub fn register_schema_callback( &self, callback: SchemaChangeCallback, ) -> SubscriptionId

Register a runtime observer for schema changes.

pub fn register_schema_callback_filtered( &self, callback: SchemaChangeCallback, filter: EventFilter<SchemaChangeEvent>, ) -> SubscriptionId

Register a filtered observer invoked only when filter returns true.

pub fn unregister_schema_callback(&self, id: SubscriptionId) -> bool

Remove a previously registered observer. Returns true if present.

pub fn schema_callback_count(&self) -> usize

Number of registered schema observers (useful for tests and diagnostics).

pub fn set_serial_next(&self, entries: Vec<(u64, String, u64)>)

Set the persisted SERIAL counters (space_id, table name, next value). Called by the storage layer before the schema snapshot is saved.

pub fn serial_next(&self) -> Vec<(u64, String, u64)>

Persisted SERIAL counters as (space_id, table name, next value) triples.

pub fn peek_next_space_id(&self) -> u64

pub fn peek_next_tag_id(&self) -> u32

pub fn peek_next_edge_type_id(&self) -> u32

pub fn create_space(&self, space: &mut SpaceInfo) -> Result<bool, StorageError>

pub fn drop_space(&self, space_name: &str) -> Result<bool, StorageError>

pub fn clear_space(&self, space_name: &str) -> Result<bool, StorageError>

pub fn get_space( &self, space_name: &str, ) -> Result<Option<SpaceInfo>, StorageError>

pub fn get_space_id(&self, space_name: &str) -> Result<u64, StorageError>

pub fn get_space_by_id( &self, space_id: u64, ) -> Result<Option<SpaceInfo>, StorageError>

pub fn list_spaces(&self) -> Result<Vec<SpaceInfo>, StorageError>

pub fn update_space(&self, space: &SpaceInfo) -> Result<bool, StorageError>

pub fn create_tag( &self, space_name: &str, tag: &TagInfo, ) -> Result<u32, StorageError>

pub fn create_tag_with_id( &self, space_name: &str, tag: &TagInfo, tag_id: u32, ) -> Result<u32, StorageError>

pub fn drop_tag( &self, space_name: &str, tag_name: &str, ) -> Result<bool, StorageError>

pub fn get_tag( &self, space_name: &str, tag_name: &str, ) -> Result<Option<TagInfo>, StorageError>

pub fn list_tags(&self, space_name: &str) -> Result<Vec<TagInfo>, StorageError>

pub fn find_tag_by_id(&self, tag_id: u32) -> Option<(String, TagInfo)>

pub fn update_tag( &self, space_name: &str, tag: &TagInfo, ) -> Result<bool, StorageError>

pub fn create_edge_type( &self, space_name: &str, edge_type: &EdgeTypeInfo, ) -> Result<u32, StorageError>

pub fn create_edge_type_with_id( &self, space_name: &str, edge_type: &EdgeTypeInfo, edge_type_id: u32, ) -> Result<u32, StorageError>

pub fn drop_edge_type( &self, space_name: &str, edge_type_name: &str, ) -> Result<bool, StorageError>

pub fn get_edge_type( &self, space_name: &str, edge_type_name: &str, ) -> Result<Option<EdgeTypeInfo>, StorageError>

pub fn list_edge_types( &self, space_name: &str, ) -> Result<Vec<EdgeTypeInfo>, StorageError>

pub fn find_edge_type_by_id( &self, edge_type_id: u32, ) -> Option<(String, EdgeTypeInfo)>

pub fn update_edge_type( &self, space_name: &str, edge_type: &EdgeTypeInfo, ) -> Result<bool, StorageError>

pub fn alter_tag( &self, space_name: &str, tag_name: &str, additions: Vec<PropertyDef>, deletions: Vec<String>, new_comment: Option<String>, ) -> Result<bool, StorageError>

pub fn rename_tag_property( &self, space_name: &str, tag_name: &str, old_name: &str, new_name: &str, ) -> Result<bool, StorageError>

pub fn rename_tag( &self, space_name: &str, old_name: &str, new_name: &str, ) -> Result<bool, StorageError>

pub fn rename_edge_type( &self, space_name: &str, old_name: &str, new_name: &str, ) -> Result<bool, StorageError>

pub fn rename_edge_property( &self, space_name: &str, edge_type_name: &str, old_name: &str, new_name: &str, ) -> Result<bool, StorageError>

pub fn alter_edge_type( &self, space_name: &str, edge_type_name: &str, additions: Vec<PropertyDef>, deletions: Vec<String>, new_comment: Option<String>, ) -> Result<bool, StorageError>

pub fn update_edge_endpoints( &self, space_name: &str, edge_type_name: &str, src_tag_name: &str, dst_tag_name: &str, ) -> Result<bool, StorageError>

pub fn save_schema(&self, path: &Path) -> Result<(), StorageError>

pub fn load_schema(&self, path: &Path) -> Result<(), StorageError>

pub fn create_sequence( &self, name: String, start: i64, increment: i64, min_value: i64, max_value: i64, cycle: bool, ) -> Result<(), StorageError>

Create a sequence

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

Drop a sequence

pub fn get_sequence(&self, name: &str) -> Option<SequenceDef>

Get a sequence definition

pub fn sequence_current_value(&self, name: &str) -> Result<i64, StorageError>

Get the current value of a sequence

pub fn sequence_next_value(&self, name: &str) -> Result<i64, StorageError>

Get the next value of a sequence (atomic increment)

pub fn alter_sequence( &self, name: &str, increment: Option<i64>, min_value: Option<i64>, max_value: Option<i64>, cycle: Option<bool>, ) -> Result<(), StorageError>

Alter sequence properties

pub fn list_sequences(&self) -> Vec<String>

List all sequence names

Trait Implementations

impl Clone for SchemaManager

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchemaManager

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

Formats the value using the given formatter.

impl Default for SchemaManager

fn default() -> Self

Returns the “default value” for a type.