Struct SemanticDHTNode 

pub struct SemanticDHTNode { /* private fields */ }

Main semantic DHT node

Implementations

impl SemanticDHTNode

pub fn new( config: SemanticDHTConfig, local_peer_id: PeerId, local_index: VectorIndex, ) -> Self

Create a new semantic DHT node

pub async fn insert(&self, cid: &Cid, embedding: &[f32]) -> Result<()>

Insert a vector into the local index and replicate to peers

pub fn search_local( &self, embedding: &[f32], k: usize, ) -> Result<Vec<SearchResult>>

Search for nearest neighbors locally

pub async fn search_distributed( &self, embedding: &[f32], k: usize, ) -> Result<Vec<SearchResult>>

Distributed k-NN search across multiple peers

pub fn add_peer(&self, peer: SemanticPeer) -> Result<()>

Add a peer to the routing table

pub fn remove_peer(&self, peer_id: &PeerId)

Remove a peer from the routing table

pub fn update_clusters(&self, num_clusters: usize) -> Result<()>

Update peer clustering

pub fn stats(&self) -> SemanticDHTStats

Get DHT statistics

pub fn get_stats(&self) -> SemanticDHTStats

Get DHT statistics (alias for stats)

pub fn routing_table(&self) -> &SemanticRoutingTable

Get reference to the routing table

pub fn set_replication_strategy(&mut self, strategy: ReplicationStrategy)

Set replication strategy

pub fn get_index_snapshot(&self) -> Vec<Cid>

Get a snapshot of local index entries for synchronization Returns CIDs that can be used for delta synchronization

pub fn has_entry(&self, cid: &Cid) -> bool

Check if local index has a specific CID

pub fn prepare_sync_delta(&self, peer_snapshot: &[Cid]) -> Vec<Cid>

Prepare synchronization delta: entries that peer needs Returns CIDs that are in our index but not in the peer’s snapshot

pub async fn apply_sync_delta(&self, delta_cids: Vec<Cid>) -> Result<usize>

Apply synchronization delta: add entries from peer This is a foundation - actual implementation would fetch embeddings from peer

pub async fn apply_sync_delta_with_embeddings( &self, delta_entries: Vec<(Cid, Vec<f32>)>, ) -> Result<usize>

Apply synchronization delta with embeddings: add entries from peer This method actually inserts the embeddings into the local index

pub fn sync_stats(&self) -> SyncStats

Get synchronization statistics