Struct DHTNode 

pub struct DHTNode { /* private fields */ }

DHT node

Implementations

impl DHTNode

pub fn new(local_id: PeerId, config: NodeConfig) -> Self

Create new DHT node

pub fn local_id(&self) -> PeerId

Get our peer ID

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

Add peer to routing table

pub fn remove_peer(&self, peer_id: &PeerId) -> Result<bool>

Remove peer from routing table

pub fn find_closest_peers(&self, target: &PeerId, count: usize) -> Vec<PeerInfo>

Find closest peers to target

pub fn store_value( &self, key: [u8; 32], data: Bytes, publisher: [u8; 32], ) -> Result<()>

Store value locally

pub fn get_value(&self, key: &[u8; 32]) -> Option<StoredValue>

Get value from local storage

pub fn has_value(&self, key: &[u8; 32]) -> bool

Check if we have a value

pub fn remove_value(&self, key: &[u8; 32]) -> Option<StoredValue>

Remove value from storage

pub fn all_peers(&self) -> Vec<PeerInfo>

Get all known peers

pub fn peer_count(&self) -> usize

Get peer count

pub fn value_count(&self) -> usize

Get stored value count

pub fn storage_size(&self) -> usize

Get storage size

pub fn mark_peer_failed(&self, peer_id: &PeerId) -> Result<()>

Mark peer as failed

pub fn cleanup_expired(&self) -> usize

Cleanup expired values

pub async fn start_maintenance(self: Arc<Self>)

Start background maintenance tasks

pub fn stats(&self) -> DHTStats

Get DHT statistics