Enum StorageBackend 

pub enum StorageBackend {
    RocksDB(RealRocksDBStorage),
    SurrealDB(Arc<SurrealDBStorage>),
}

Unified storage backend enum for runtime selection.

This enum wraps the different storage implementations and provides a unified interface for the rest of the application.

Variants

RocksDB(RealRocksDBStorage)

RocksDB-based local storage (default)

SurrealDB(Arc<SurrealDBStorage>)

SurrealDB-based storage with native graph support

Implementations

impl StorageBackend

pub fn supports_native_graph(&self) -> bool

Check if this backend supports native graph operations

pub fn supports_native_vectors(&self) -> bool

Check if this backend supports native vector operations

Trait Implementations

impl Clone for StorageBackend

fn clone(&self) -> StorageBackend

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl FreshnessStorage for StorageBackend

fn register_source<'life0, 'async_trait>( &'life0 self, session_id: Uuid, reference: SourceReference, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Register or update a source reference for an entry

fn check_freshness<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, entry_id: &'life1 str, file_hash: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = Result<FreshnessEntry>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Check if an entry’s stored hash matches the provided hash. When the stored entry has a FunctionScope with ast_hash, compares that instead of the file-level hash (semantic freshness).

fn invalidate_source<'life0, 'life1, 'async_trait>( &'life0 self, file_path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u32>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Invalidate (remove) a source reference, usually because the source changed or the entry is being deleted. Returns count of removed references.

fn get_entries_by_source<'life0, 'life1, 'async_trait>( &'life0 self, file_path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<SourceReference>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get all entries associated with a specific file path

fn get_stale_entries_by_source<'life0, 'life1, 'async_trait>( &'life0 self, file_path: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<StaleEntryInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return entry_ids (plus symbol metadata) for all source_reference records that are still marked stale (status=1) for the given file. Called by Axon after register_source_batch to detect symbols that were deleted from the file (they were marked stale by invalidate_source but never re-registered).

fn check_freshness_semantic<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, entry_id: &'life1 str, file_hash: &'life2 [u8], ast_hash: Option<&'life3 [u8]>, symbol_name: Option<&'life4 str>, ) -> Pin<Box<dyn Future<Output = Result<FreshnessEntry>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Semantic freshness check: compare ast_hash when available, fallback to file hash. The ast_hash and symbol_name are optional — if provided and the stored entry has a FunctionScope, ast_hash comparison is used instead of file-level hash.

fn register_symbol_dependencies<'life0, 'async_trait>( &'life0 self, from: SymbolId, to_symbols: Vec<SymbolId>, ) -> Pin<Box<dyn Future<Output = Result<u32>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Register symbol-level dependencies (e.g., fn foo depends on struct Bar). Used for cascade invalidation.

fn cascade_invalidate<'life0, 'async_trait>( &'life0 self, changed: SymbolId, new_ast_hash: Vec<u8>, max_depth: u32, ) -> Pin<Box<dyn Future<Output = Result<CascadeInvalidateReport>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Cascade invalidate: when a symbol changes, invalidate all entries whose symbols depend on it (transitively up to max_depth).

fn check_freshness_batch<'life0, 'async_trait>( &'life0 self, entries: Vec<(String, Vec<u8>, Option<Vec<u8>>, Option<String>)>, ) -> Pin<Box<dyn Future<Output = Result<Vec<FreshnessEntry>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Batch freshness check: check multiple entries in a single storage round-trip.

impl GraphStorage for StorageBackend

fn upsert_entity<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, entity: &'life1 EntityData, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Insert or update an entity

fn get_entity<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<EntityData>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get an entity by name

fn list_entities<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<EntityData>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all entities for a session

fn delete_entity<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Delete an entity

fn create_relationship<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, relationship: &'life1 EntityRelationship, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create a relationship between entities

fn find_related_entities<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, entity_name: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Find all entities related to a given entity

fn find_related_by_type<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: Uuid, entity_name: &'life1 str, relation_type: &'life2 RelationType, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Find entities related by a specific relation type

fn find_shortest_path<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, session_id: Uuid, from: &'life1 str, to: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Vec<String>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Find the shortest path between two entities

fn get_entity_network<'life0, 'life1, 'async_trait>( &'life0 self, session_id: Uuid, center: &'life1 str, max_depth: usize, ) -> Pin<Box<dyn Future<Output = Result<EntityNetwork>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Get the entity network (subgraph) around a center entity

impl Storage for StorageBackend

fn save_session<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 ActiveSession, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a session to storage

fn load_session<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<ActiveSession>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Load a session from storage

fn delete_session<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a session and all related data

fn clear_session_entities<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete all entities and relationships for a session (used by entity graph rebuild)

fn list_sessions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Uuid>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all session IDs

fn session_exists<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Check if a session exists

fn batch_save_updates<'life0, 'async_trait>( &'life0 self, session_id: Uuid, updates: Vec<ContextUpdate>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Batch save multiple context updates efficiently

fn save_session_with_updates<'life0, 'life1, 'async_trait>( &'life0 self, session: &'life1 ActiveSession, session_id: Uuid, updates: Vec<ContextUpdate>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save session and context updates in a single atomic write. Default implementation calls save_session then batch_save_updates sequentially. Backends can override for a single WriteBatch operation.

fn load_session_updates<'life0, 'async_trait>( &'life0 self, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<Vec<ContextUpdate>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Load all updates for a session

fn save_checkpoint<'life0, 'life1, 'async_trait>( &'life0 self, checkpoint: &'life1 SessionCheckpoint, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Save a session checkpoint

fn load_checkpoint<'life0, 'async_trait>( &'life0 self, checkpoint_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<SessionCheckpoint>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Load a session checkpoint

fn list_checkpoints<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<SessionCheckpoint>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all checkpoints

fn save_workspace_metadata<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, workspace_id: Uuid, name: &'life1 str, description: &'life2 str, session_ids: &'life3 [Uuid], ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Save workspace metadata

fn delete_workspace<'life0, 'async_trait>( &'life0 self, workspace_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a workspace

fn list_workspaces<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredWorkspace>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all workspaces

fn add_session_to_workspace<'life0, 'async_trait>( &'life0 self, workspace_id: Uuid, session_id: Uuid, role: SessionRole, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Add a session to a workspace

fn remove_session_from_workspace<'life0, 'async_trait>( &'life0 self, workspace_id: Uuid, session_id: Uuid, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Remove a session from a workspace

fn compact<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Force database compaction

fn get_key_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<usize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get estimated number of keys in database

fn get_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get database statistics as a string