Struct PeerManager 

pub struct PeerManager { /* private fields */ }

Peer manager for handling peer operations

Implementations

impl PeerManager

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

Create a new peer manager

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

Save peers to disk

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

Auto-save if needed

pub async fn add_peer( &self, address: String, nickname: Option<String>, ) -> Result<String>

Add a new peer

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

Remove a peer

pub async fn list_peers(&self) -> Result<Vec<PeerInfo>>

List all peers

pub async fn get_peer_info(&self, peer_id: String) -> Result<PeerInfo>

Get detailed information about a specific peer

pub async fn update_peer_metadata( &self, peer_id: String, nickname: Option<String>, trust_level: Option<u8>, tags: Option<Vec<String>>, ) -> Result<()>

Update peer metadata

pub async fn ban_peer(&self, peer_id: String) -> Result<()>

Ban a peer

pub async fn unban_peer(&self, address: String) -> Result<()>

Unban a peer by address

pub async fn import_peers(&self, path: PathBuf, merge: bool) -> Result<usize>

Import peers from JSON file

pub async fn export_peers( &self, path: PathBuf, filter_tags: Option<Vec<String>>, ) -> Result<usize>

Export peers to JSON file

pub async fn test_all_peers( &self, progress_callback: impl Fn(usize, usize), ) -> Result<Vec<(String, bool, Option<f64>)>>

Test connectivity to all known peers

pub async fn get_network_stats(&self) -> Result<NetworkStats>

Get network statistics

pub fn is_valid_address(address: &str) -> bool

Validate peer address format

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

Shutdown the peer manager