Struct PartialSyncManager 

pub struct PartialSyncManager { /* private fields */ }

Manages partial sync of HNSW graph changes between peers.

Wraps a DirtyRegionTracker and adds outbound delta bookkeeping so the caller can detect when a peer has not yet acknowledged a delta.

Implementations

impl PartialSyncManager

pub fn new( max_dirty_nodes: usize, max_pending: usize, local_peer_id: impl Into<String>, ) -> Self

Create a new manager.

• max_dirty_nodes: denominator for dirty_ratio (forwarded to the inner DirtyRegionTracker).
• max_pending: maximum number of un-acked deltas held in memory.
• local_peer_id: identifier stamped onto outbound deltas.

pub fn record_change(&self, layer: usize, node_id: u64)

Record that the vector for node_id in layer has changed.

pub fn build_delta<F>( &self, region: &EmbeddingRegion, get_vector: F, now_ms: u64, ) -> EmbeddingDelta

where F: Fn(u64) -> Option<Vec<f32>>,

Build a delta containing all dirty nodes that fall inside region.

get_vector is called for each dirty node ID to retrieve its current embedding. If get_vector returns None for a node the node is skipped (it may have been deleted).

pub fn build_all_deltas<F>( &self, get_vector: F, now_ms: u64, ) -> Vec<EmbeddingDelta>

where F: Fn(usize, u64) -> Option<Vec<f32>>,

Build one delta per dirty layer, covering all dirty nodes in that layer.

get_vector receives (layer, node_id) and should return the current embedding for that node, or None if the node no longer exists.

Layers with no dirty nodes are omitted from the result.

pub fn apply_delta(&self, delta: &EmbeddingDelta)

Apply an incoming delta from a peer.

Clears the local dirty status for all nodes mentioned in the delta (the peer has the authoritative version of those nodes).

pub fn push_pending(&self, delta: EmbeddingDelta) -> bool

Push a delta onto the pending list (waiting for peer acknowledgement).

Returns false when the pending list is already at capacity; the caller should ack older deltas first.

pub fn ack_generation(&self, generation: u64) -> usize

Remove all pending deltas whose generation is ≤ generation.

Returns the number of deltas removed.

pub fn pending_count(&self) -> usize

Number of pending (un-acked) deltas.

pub fn tracker(&self) -> &DirtyRegionTracker

Access the underlying DirtyRegionTracker.

pub fn dirty_ratio(&self) -> f64

Convenience wrapper: dirty_ratio of the inner tracker.