Struct DhtManager 

pub struct DhtManager { /* private fields */ }

DHT manager for peer and content discovery

Implementations

impl DhtManager

pub fn new(config: DhtConfig) -> Self

Create a new DHT manager

pub fn start_provider_refresh(&mut self)

Start the provider refresh background task

pub async fn track_provider(&self, cid: Cid) -> Result<()>

Track a provider record for automatic refresh

pub async fn stop_tracking(&self, cid: &Cid) -> Result<()>

Stop tracking a provider record

pub fn cache_query_result(&self, cid: &Cid, peers: Vec<PeerId>)

Cache a query result

pub fn get_cached_query(&self, cid: &Cid) -> Option<Vec<PeerId>>

Get cached query result

pub fn cache_peer(&self, peer_id: PeerId)

Cache a peer

pub fn is_peer_cached(&self, peer_id: &PeerId) -> bool

Check if peer is in cache

pub fn get_cached_peers(&self) -> Vec<PeerId>

Get all cached peers

pub fn cleanup_cache(&self)

Clean up expired cache entries

pub fn get_stats(&self) -> DhtStats

Get DHT statistics

pub fn record_query_success(&self)

Record a successful query

pub fn record_query_failure(&self)

Record a failed query

pub fn get_health(&self) -> DhtHealth

Get DHT health status

pub fn is_healthy(&self) -> bool

Check if DHT is healthy

pub async fn shutdown(&mut self)

Shutdown the DHT manager

impl DhtManager

pub fn record_provide(&self, cid: &str)

Record that this node is providing cid so it can be re-announced later.

Delegates to an internal ProviderReannouncer stored in the DHT manager. The reannouncer uses a 12-hour interval by default, safely below the 24-hour TTL.

pub fn get_due_for_reannouncement(&self) -> Vec<String>

Return the list of CIDs that are due for DHT re-announcement.

Production usage: hold a ProviderReannouncer alongside DhtManager and call reannouncer.due_for_reannouncement() directly. This method is a convenience stub that always returns an empty list when no external reannouncer is wired up.

pub fn mark_reannounced(&self, _cids: &[String])

Mark cids as having been re-announced.

Production usage: call reannouncer.mark_reannounced(cids) directly.

Trait Implementations

impl Drop for DhtManager

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.