Struct FileVectorStore 

pub struct FileVectorStore { /* private fields */ }

文件持久化向量存储

将向量数据持久化到本地文件，支持应用重启后恢复。 使用 JSON 格式存储，适合中小规模数据。

Implementations

impl FileVectorStore

pub fn new(config: VectorStoreConfig) -> Layer3Result<Self>

创建新的文件向量存储

pub fn with_auto_persist(self, auto_persist: bool) -> Self

创建带自动持久化开关的存储

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

持久化数据到文件

pub fn load_sync(&self) -> Layer3Result<()>

从文件加载数据

Trait Implementations

impl VectorStore for FileVectorStore

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 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 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 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 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_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<()>

验证向量维度