Struct VectorStoreManager 

pub struct VectorStoreManager { /* private fields */ }

VectorStore のシンプルなインメモリ実装。

Implementations

impl VectorStoreManager

pub fn new(config: VectorStoreConfig) -> Self

新しい VectorStoreManager を生成。

pub fn segments(&self) -> &[VectorSegment]

現在保持しているセグメント一覧（読み取り専用）を返す。

注意（Disk モード復元時の前提）

• VectorStoreManager は「セグメントの順序」を row_id の割当てに利用します（検索時に row_offset を積み上げる）。
• from_segments で復元する場合は、永続化時と同じ順序（通常は古い→新しい）で segments を渡してください。

pub fn config(&self) -> &VectorStoreConfig

設定を返す（Disk モードの復元用）。

注意（Disk モード復元時の前提）

• segments 内の各セグメントは、この config と整合している必要があります（例: dimension/metric）。

pub fn next_segment_id(&self) -> u64

次に割り当てられるセグメントIDを返す（永続化用）。

注意（Disk モード復元時の前提）

• from_segments に渡す next_segment_id は、通常 max(segment_id) + 1 以上である必要があります。

pub fn from_segments( config: VectorStoreConfig, segments: Vec<VectorSegment>, next_segment_id: u64, ) -> Self

永続化済みセグメントから VectorStoreManager を復元する（Disk モード向け）。

注意（呼び出し側が満たすべき前提）

• segments は永続化時と同じ順序（通常は古い→新しい）で渡すこと。
• segments は重複しない segment_id を持つこと。
• config と segments の整合（dimension/metric など）を保つこと。
• next_segment_id は max(segment_id) + 1 以上であること（将来の追加/コンパクションで重複IDを避けるため）。

pub async fn append_batch( &mut self, keys: &[i64], vectors: &[Vec<f32>], ) -> Result<AppendResult>

ベクトルバッチを追加する。

Errors

• DimensionMismatch: 入力ベクトルの次元が設定と異なる場合
• InvalidVector: NaN/Inf を含む場合

Examples

use alopex_core::vector::{VectorStoreManager, VectorStoreConfig};
let mut mgr = VectorStoreManager::new(VectorStoreConfig { dimension: 2, ..Default::default() });
let keys = vec![1, 2];
let vecs = vec![vec![1.0, 0.0], vec![0.0, 1.0]];
mgr.append_batch(&keys, &vecs).await?;

pub fn segments_needing_compaction(&self) -> Vec<u64>

コンパクション対象セグメントを取得する。

deletion_ratio が compaction_threshold 以上かつ > 0 のセグメントIDを返す。 threshold >= 1.0 の場合は常に空。

Examples

assert!(mgr.segments_needing_compaction().is_empty()); // no deletions yet
// Mark one row deleted -> deletion_ratio = 0.5, meets threshold
mgr.segments[0].deleted.set(0, true);
mgr.segments[0].recompute_deletion_stats();
assert_eq!(mgr.segments_needing_compaction(), vec![mgr.segments[0].segment_id]);

pub async fn delete_batch(&mut self, keys: &[i64]) -> Result<DeleteResult>

指定キーのベクトルを論理削除する（in-memory）。

Errors

• セグメントのデコードに失敗した場合 InvalidFormat

Examples

let res = futures::executor::block_on(mgr.delete_batch(&[1])).unwrap();
assert_eq!(res.vectors_deleted, 1);

pub async fn compact_segment( &mut self, segment_id: u64, ) -> Result<CompactionResult>

セグメントをコンパクションして新セグメントに置換する。

削除済み行を物理的に取り除き、新セグメントを構築する（全削除時はセグメントを削除）。

Errors

• Error::NotFound 指定IDが存在しない場合
• InvalidFormat セグメントのデコード/再構成に失敗した場合

Examples

let seg_id = mgr.segments[0].segment_id;
let res = futures::executor::block_on(mgr.compact_segment(seg_id)).unwrap();
assert!(res.new_segment_id.is_some());

pub fn search( &self, params: VectorSearchParams, ) -> Result<Vec<VectorSearchResult>>

ベクトル検索。

Errors

• DimensionMismatch: クエリ次元が設定と異なる場合。
• InvalidVector: クエリに NaN/Inf が含まれる場合。

pub fn search_with_stats( &self, params: VectorSearchParams, ) -> Result<(Vec<VectorSearchResult>, SearchStats)>

統計付き検索。

search と同じ結果に加え、走査/プルーニング件数を返す。

Trait Implementations

impl Debug for VectorStoreManager

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

Formats the value using the given formatter.