Struct DeltaSyncVectorStore 

pub struct DeltaSyncVectorStore { /* private fields */ }

An in-memory vector store with a full append-only change log enabling efficient delta synchronisation between replicas.

Implementations

impl DeltaSyncVectorStore

pub fn new() -> Self

Create a new, empty store.

pub fn insert(&mut self, key: String, vector: Vec<f32>) -> Result<u64>

Insert a new vector. Returns an error if the key already exists.

pub fn insert_with_metadata( &mut self, key: String, vector: Vec<f32>, metadata: HashMap<String, String>, ) -> Result<u64>

Insert with explicit metadata. Returns an error if the key already exists.

pub fn update(&mut self, key: String, vector: Vec<f32>) -> Result<u64>

Update an existing vector. Returns an error if the key does not exist.

pub fn update_with_metadata( &mut self, key: String, vector: Vec<f32>, metadata: HashMap<String, String>, ) -> Result<u64>

Update with explicit metadata. Returns an error if the key does not exist.

pub fn upsert(&mut self, key: String, vector: Vec<f32>) -> Result<u64>

Insert or update a vector (upsert semantics).

pub fn delete(&mut self, key: &str) -> Result<u64>

Delete a vector by key. Returns an error if the key does not exist.

pub fn get(&self, key: &str) -> Option<&StoredEntry>

Look up a vector by key.

pub fn contains(&self, key: &str) -> bool

Check whether a key exists.

pub fn len(&self) -> usize

Current number of live entries.

pub fn is_empty(&self) -> bool

Return true if no entries are present.

pub fn current_seq(&self) -> u64

The current (latest) sequence number.

pub fn keys(&self) -> Vec<&str>

All keys of live entries.

pub fn export_delta(&self, since_seq: u64) -> StoreDelta

Export all changes with seq > since_seq as a StoreDelta.

Pass since_seq = 0 to export the full history.

pub fn merge_delta(&mut self, delta: &StoreDelta) -> Result<MergeResult>

Apply a StoreDelta received from a remote replica.

Uses last-writer-wins based on sequence number; records whose sequence number is ≤ the current local version of that key are skipped.

The local sequence counter is NOT advanced by merges — only by local write operations. This keeps sequence numbers local-only and avoids gaps in the log.

pub fn stats(&self) -> DeltaStoreStats

Return store statistics.

pub fn compact_log(&mut self)

Compact the change log, retaining only the most-recent operation for each key plus any delete tombstones whose key no longer exists.

After compaction the log covers the same logical state but may be shorter.

Trait Implementations

impl Default for DeltaSyncVectorStore

fn default() -> Self

Returns the “default value” for a type.