Struct DiscoveryManager

pub struct DiscoveryManager { /* private fields */ }

Peer discovery manager

Implementations

impl DiscoveryManager

pub fn new( node_id: PeerId, socket_addr: SocketAddr, config: DiscoveryConfig, ) -> Self

Create a new discovery manager

pub async fn add_peer(&self, peer_info: PeerInfo) -> Result<()>

Add a peer to the known peers list

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

Remove a peer from known peers

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

Mark a peer as connected

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

Mark a peer as disconnected

pub async fn get_peers(&self) -> Vec<PeerAnnouncement>

Get all known peers

pub async fn get_connected_peers(&self) -> Vec<PeerId>

Get connected peers

pub async fn get_peers_for_discovery( &self, requester_id: &PeerId, max_peers: usize, ) -> Vec<PeerAnnouncement>

Get peers for discovery response (excluding requester and already connected)

pub async fn handle_message( &self, message: DiscoveryMessage, sender_addr: SocketAddr, ) -> Result<Option<DiscoveryMessage>>

Handle discovery message

pub fn create_announcement(&self) -> DiscoveryMessage

Create an announcement message

pub fn create_peer_request(&self, max_peers: usize) -> DiscoveryMessage

Create a peer request message

pub fn create_ping(&self) -> DiscoveryMessage

Create a ping message

pub async fn should_announce(&self) -> bool

Check if we should announce ourselves

pub async fn update_last_announce(&self)

Update last announce time

pub async fn cleanup_old_peers(&self) -> Result<()>

Clean up old peers

pub async fn get_stats(&self) -> DiscoveryStats

Get discovery statistics