Struct IndexManager 

pub struct IndexManager { /* private fields */ }

Implementations

impl IndexManager

pub fn new() -> Self

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

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

Single enum dual emission source: index DDL is emitted here, everything else by SchemaManager; 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 index DDL events.

Writes to the registry shared with SchemaManager, so one subscription receives both index DDL and table/space DDL.

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 index observers.

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

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

Trait Implementations

impl Debug for IndexManager

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

Formats the value using the given formatter.

impl Default for IndexManager

fn default() -> Self

Returns the “default value” for a type.

impl IndexMetadataManager for IndexManager

fn create_tag_index( &self, space_id: u64, index: &Index, ) -> Result<bool, StorageError>

fn drop_tag_index( &self, space_id: u64, index_name: &str, ) -> Result<bool, StorageError>

fn get_tag_index( &self, space_id: u64, index_name: &str, ) -> Result<Option<Index>, StorageError>

fn list_tag_indexes(&self, space_id: u64) -> Result<Vec<Index>, StorageError>

fn drop_tag_indexes_by_tag( &self, space_id: u64, tag_name: &str, ) -> Result<Vec<String>, StorageError>

fn create_edge_index( &self, space_id: u64, index: &Index, ) -> Result<bool, StorageError>

fn drop_edge_index( &self, space_id: u64, index_name: &str, ) -> Result<bool, StorageError>

fn get_edge_index( &self, space_id: u64, index_name: &str, ) -> Result<Option<Index>, StorageError>

fn list_edge_indexes(&self, space_id: u64) -> Result<Vec<Index>, StorageError>

fn drop_edge_indexes_by_type( &self, space_id: u64, edge_type: &str, ) -> Result<Vec<String>, StorageError>

fn set_tag_index_status( &self, space_id: u64, index_name: &str, status: IndexStatus, ) -> Result<bool, StorageError>

Set the status of a tag index (used for generation rebuild lifecycle).

fn set_edge_index_status( &self, space_id: u64, index_name: &str, status: IndexStatus, ) -> Result<bool, StorageError>

Set the status of an edge index (used for generation rebuild lifecycle).