Struct ReplicaDcManager 

pub struct ReplicaDcManager { /* private fields */ }

Replica datacenter replication receiver

Receives and applies replication entries from the primary DC, maintaining an eventually-consistent copy of the vector index.

Implementations

impl ReplicaDcManager

pub fn new(config: CrossDcConfig) -> Result<Self>

Create a new replica DC manager

pub fn receive_entries(&self, entries: Vec<ReplicationEntry>) -> ReplicationSeq

Receive a batch of replication entries from the primary

pub fn apply_pending(&self) -> usize

Apply all buffered entries to the local state

pub fn get_vector( &self, vector_id: &str, ) -> Option<(Vec<f32>, HashMap<String, String>)>

Get a vector from local state

pub fn last_applied_seq(&self) -> ReplicationSeq

Get the last applied sequence number

pub fn lag_entries(&self) -> u64

Get estimated lag (entries behind primary)

pub fn is_within_lag_tolerance(&self) -> bool

Check if we are within the configured lag tolerance

pub fn vector_count(&self) -> usize

Get the number of vectors in local state

pub fn get_stats(&self) -> CrossDcStats

Get current statistics

pub fn search_similar(&self, query: &[f32], k: usize) -> Vec<(String, f32)>

Search for similar vectors in local state

pub fn primary_heartbeat_recent(&self) -> bool

Check if primary heartbeat is recent

pub fn conflict_log(&self) -> Vec<ConflictRecord>

Get the conflict log

pub fn pending_count(&self) -> usize

Get the pending buffer size

Trait Implementations

impl Debug for ReplicaDcManager

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

Formats the value using the given formatter.