Struct MemoryVectorStorage

pub struct MemoryVectorStorage { /* private fields */ }

High-performance in-memory vector storage

Implementations

impl MemoryVectorStorage

pub async fn new() -> Result<Self>

Create a new memory vector storage with default configuration

pub async fn with_capacity(capacity: usize) -> Result<Self>

Create a new memory vector storage with specified capacity

pub async fn with_config(config: MemoryConfig) -> Result<Self>

Create a new memory vector storage with custom configuration

pub async fn get_stats(&self) -> StorageStats

Get storage statistics

pub async fn memory_usage(&self) -> u64

Get memory usage in bytes

pub async fn cleanup(&self) -> Result<()>

Cleanup unused memory (if configured)

pub async fn get_performance_metrics(&self) -> PerformanceMetrics

Get performance metrics

pub async fn get_cache_stats(&self) -> CacheStats

Get cache statistics

Trait Implementations

impl Clone for MemoryVectorStorage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl VectorStorage for MemoryVectorStorage

type Config = MemoryConfig

Storage-specific configuration type

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

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

Create a new vector index

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

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

List all available indexes

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

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

Get information about a specific index

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

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

Delete an index and all its vectors

fn upsert_documents<'life0, 'life1, 'async_trait>( &'life0 self, index_name: &'life1 str, documents: Vec<Document>, ) -> Pin<Box<dyn Future<Output = Result<Vec<DocumentId>>> + Send + 'async_trait>>

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

Insert or update documents in the index

fn search<'life0, 'async_trait>( &'life0 self, request: SearchRequest, ) -> Pin<Box<dyn Future<Output = Result<SearchResponse>> + Send + 'async_trait>>

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

Search for similar vectors

fn update_document<'life0, 'life1, 'async_trait>( &'life0 self, index_name: &'life1 str, document: Document, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Update a specific document

fn delete_documents<'life0, 'life1, 'async_trait>( &'life0 self, index_name: &'life1 str, ids: Vec<DocumentId>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Delete documents by IDs

fn get_documents<'life0, 'life1, 'async_trait>( &'life0 self, index_name: &'life1 str, ids: Vec<DocumentId>, include_vectors: bool, ) -> Pin<Box<dyn Future<Output = Result<Vec<Document>>> + Send + 'async_trait>>

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

Get documents by IDs

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

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

Check if the storage backend is healthy

fn backend_info(&self) -> BackendInfo

Get storage backend information