Struct CollectionManager 

pub struct CollectionManager {
    pub config: VectorConfig,
    pub store: Arc<VectorStore>,
    pub indexes: Arc<RwLock<HashMap<String, IndexSelector>>>,
    pub mmap_files: Arc<RwLock<HashMap<String, MmapVectorFile>>>,
}

Coordinates collection metadata, vector files, and in-memory indexes.

Fields

config: VectorConfig

Runtime configuration shared by all collections.

store: Arc<VectorStore>

Persistent metadata store.

indexes: Arc<RwLock<HashMap<String, IndexSelector>>>

In-memory index implementations keyed by collection name.

mmap_files: Arc<RwLock<HashMap<String, MmapVectorFile>>>

Memory-mapped vector files keyed by collection name.

Implementations

impl CollectionManager

pub async fn new( config: VectorConfig, store: Arc<VectorStore>, ) -> VectorResult<Self>

Build a manager and restore all persisted collections.

pub async fn create_collection( &self, workspace_id: &str, name: &str, dimensions: usize, distance: DistanceMetric, ) -> VectorResult<Collection>

Create a new collection and initialize its index and vector file.

pub async fn get_collection( &self, workspace_id: &str, name: &str, ) -> VectorResult<Collection>

Fetch a collection definition by name.

pub async fn delete_collection( &self, workspace_id: &str, name: &str, ) -> VectorResult<()>

Delete a collection and all of its persisted state.

pub async fn list_collections( &self, workspace_id: &str, ) -> VectorResult<Vec<Collection>>

List all persisted collections.

pub async fn insert_vector( &self, workspace_id: &str, record: VectorRecord, ) -> VectorResult<Uuid>

Insert a single vector record into its collection.

pub async fn insert_batch( &self, workspace_id: &str, records: Vec<VectorRecord>, ) -> VectorResult<Vec<Uuid>>

Insert multiple vector records atomically.

pub async fn delete_vector( &self, workspace_id: &str, collection: &str, id: Uuid, ) -> VectorResult<bool>

Delete a vector from a collection by UUID.

pub async fn get_vector( &self, workspace_id: &str, collection: &str, id: Uuid, ) -> VectorResult<VectorRecord>

Load a full vector record, including its raw vector from the mmap file.

pub async fn persist_indexes(&self) -> VectorResult<()>

Persist all loaded indexes to disk.

pub async fn read_vector_by_internal_id( &self, workspace_id: &str, collection: &str, internal_id: usize, ) -> VectorResult<Vec<f32>>

Read a raw vector by collection and internal id.

pub async fn loaded_index_count(&self) -> usize

Return the number of loaded indexes.

pub async fn loaded_mmap_count(&self) -> usize

Return the number of loaded mmap vector files.