Struct InMemoryVectorStore 

pub struct InMemoryVectorStore { /* private fields */ }

内存向量存储实现

使用内存存储向量，支持基本的相似度搜索。 适用于测试和开发环境，不适合大规模生产使用。

Implementations

impl InMemoryVectorStore

pub fn new(config: VectorStoreConfig) -> Self

创建新的内存向量存储

pub fn in_memory() -> Self

创建使用默认配置的存储

Trait Implementations

impl VectorStore for InMemoryVectorStore

fn add<'life0, 'async_trait>( &'life0 self, id: String, vector: Vec<f32>, metadata: HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Layer3Result<bool>> + Send + 'async_trait>>

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

添加向量

fn add_batch<'life0, 'async_trait>( &'life0 self, items: Vec<VectorItem>, ) -> Pin<Box<dyn Future<Output = Layer3Result<Vec<bool>>> + Send + 'async_trait>>

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

批量添加向量（优化版本）

fn query<'life0, 'async_trait>( &'life0 self, vector: Vec<f32>, top_k: usize, ) -> Pin<Box<dyn Future<Output = Layer3Result<Vec<RetrievalResult>>> + Send + 'async_trait>>

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

查询相似向量

fn delete<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Layer3Result<bool>> + Send + 'async_trait>>

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

删除向量

fn delete_batch<'life0, 'life1, 'async_trait>( &'life0 self, ids: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Layer3Result<usize>> + Send + 'async_trait>>

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

批量删除（优化版本）

fn get<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Layer3Result<Option<VectorItem>>> + Send + 'async_trait>>

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

获取向量

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

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

统计数量

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

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

清空存储

fn query_with_filter<'life0, 'async_trait>( &'life0 self, vector: Vec<f32>, top_k: usize, filter: Option<MetadataFilter>, ) -> Pin<Box<dyn Future<Output = Layer3Result<Vec<RetrievalResult>>> + Send + 'async_trait>>

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

带过滤条件的查询

fn add_validated<'life0, 'async_trait>( &'life0 self, id: String, vector: Vec<f32>, metadata: HashMap<String, Value>, expected_dimension: usize, ) -> Pin<Box<dyn Future<Output = Layer3Result<bool>> + Send + 'async_trait>>

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

添加向量（带验证）

fn query_with_threshold<'life0, 'async_trait>( &'life0 self, vector: Vec<f32>, top_k: usize, min_score: f32, ) -> Pin<Box<dyn Future<Output = Layer3Result<Vec<RetrievalResult>>> + Send + 'async_trait>>

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

带分数阈值的查询

fn delete_by_filter<'life0, 'async_trait>( &'life0 self, filter: MetadataFilter, ) -> Pin<Box<dyn Future<Output = Layer3Result<usize>> + Send + 'async_trait>>

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

删除所有匹配元数据条件的向量

fn get_batch<'life0, 'life1, 'async_trait>( &'life0 self, ids: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Layer3Result<Vec<Option<VectorItem>>>> + Send + 'async_trait>>

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

批量获取向量

fn upsert<'life0, 'async_trait>( &'life0 self, id: String, vector: Vec<f32>, metadata: HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Layer3Result<bool>> + Send + 'async_trait>>

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

更新向量（存在则更新，不存在则创建）

fn exists<'life0, 'life1, 'async_trait>( &'life0 self, id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Layer3Result<bool>> + Send + 'async_trait>>

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

检查向量是否存在

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

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

获取存储统计信息

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

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

持久化到磁盘（可选）

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

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

从磁盘加载（可选）

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

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

异步持久化（后台线程）

fn persist_sync(&self) -> Layer3Result<()>

强制同步持久化

fn validate_dimension( &self, vector: &[f32], expected: usize, ) -> Layer3Result<()>

验证向量维度