Struct MapPeerResolver 

pub struct MapPeerResolver<I> { /* private fields */ }

Available on crate feature quic only.

Simple HashMap-based peer resolver.

Thread-safe resolver that maps peer IDs to socket addresses using an internal RwLock<HashMap>. Suitable for testing and simple deployments.

Example

use memberlist_plumtree::transport::quic::MapPeerResolver;
use std::net::SocketAddr;

let local_addr: SocketAddr = "127.0.0.1:9000".parse().unwrap();
let mut resolver = MapPeerResolver::new(local_addr);

// Add peers
resolver.add_peer("node1".to_string(), "192.168.1.10:9000".parse().unwrap());
resolver.add_peer("node2".to_string(), "192.168.1.11:9000".parse().unwrap());

// Resolve peer addresses
assert!(resolver.resolve(&"node1".to_string()).is_some());
assert!(resolver.resolve(&"unknown".to_string()).is_none());

Implementations

impl<I> MapPeerResolver<I>

where I: Clone + Eq + Hash + Debug + Send + Sync + 'static,

pub fn new(local_addr: SocketAddr) -> Self

Create a new resolver with the given local address.

pub fn with_peers(local_addr: SocketAddr, peers: HashMap<I, SocketAddr>) -> Self

Create a resolver with pre-populated peers.

pub fn add_peer(&self, peer: I, addr: SocketAddr)

Add a peer to the resolver.

pub fn remove_peer(&self, peer: &I) -> Option<SocketAddr>

Remove a peer from the resolver.

pub fn update_peer(&self, peer: I, addr: SocketAddr) -> Option<SocketAddr>

Update a peer’s address.

pub fn peer_count(&self) -> usize

Get the number of known peers.

pub fn peer_ids(&self) -> Vec<I>

Get all known peer IDs.

pub fn clear(&self)

Clear all peers.

pub fn snapshot(&self) -> HashMap<I, SocketAddr>

Get a snapshot of all peer mappings.

Trait Implementations

impl<I> Clone for MapPeerResolver<I>

where I: Clone + Eq + Hash + Debug + Send + Sync + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I: Debug> Debug for MapPeerResolver<I>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<I> PeerResolver<I> for MapPeerResolver<I>

where I: Clone + Eq + Hash + Debug + Send + Sync + 'static,

fn resolve(&self, peer: &I) -> Option<SocketAddr>

Resolve a peer ID to a socket address.

fn local_addr(&self) -> SocketAddr

Get the local socket address for this node.

fn contains(&self, peer: &I) -> bool

Check if a peer is known to this resolver.