Struct VectorDirectory 

pub struct VectorDirectory { /* private fields */ }

A node’s stores for the projects it owns, each an HNSW index created on first use. Without with_persistence the indexes are memory-only and a restart empties them; with it, each store keeps a capped, append-only log under the given directory (one file per project) and is rebuilt from it on first use after a restart. The index map is shared between views, so two views with different allow-lists (local cogs, remote forwarders) reach the same store for a project they both allow.

Implementations

impl VectorDirectory

pub fn new(projects: impl IntoIterator<Item = String>, fallback: bool) -> Self

Directory owning projects, and the controller fallback if fallback.

pub fn with_persistence(self, dir: PathBuf) -> Self

Keep each store’s vectors in <dir>/<project id>.vec (the controller fallback in <dir>/_controller.vec), each capped at DEFAULT_MAX_LOG_BYTES. Call before taking views.

pub fn with_persistence_capped(self, dir: PathBuf, max_log_bytes: u64) -> Self

with_persistence with an explicit cap per file.

pub fn view( &self, projects: impl IntoIterator<Item = String>, fallback: bool, ) -> Self

A view over the same stores allowing only projects (and the fallback if fallback).

Trait Implementations

impl Clone for VectorDirectory

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StoreDirectory for VectorDirectory

fn store_for(&self, project_id: Option<&str>) -> Option<Arc<dyn IngestStore>>

The store of project_id, or the node’s fallback (the placing controller’s store) when project_id is None. None result: no such store here.