Struct xstack::MemoryPeerBook

pub struct MemoryPeerBook(/* private fields */);

An in memory PeerBook implementation

Trait Implementations

impl Default for MemoryPeerBook

fn default() -> MemoryPeerBook

Returns the “default value” for a type.

impl DriverPeerBook for MemoryPeerBook

fn len<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the peer book size.

fn insert<'life0, 'async_trait>( &'life0 self, info: PeerInfo, ) -> Pin<Box<dyn Future<Output = Result<Option<PeerInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Insert a new peer informations.

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, ) -> Pin<Box<dyn Future<Output = Result<Option<PeerInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Remove one peer’s PeerInfo from the book indicated by peer_id.

fn appear<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, timestamp: SystemTime, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Call this function when the peer is connected. when the peer is non-existent in the book, returns Error::PeerNotFound

fn disappear<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, timestamp: SystemTime, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Call this function when the peer is disconnected. when the peer is non-existent in the book, returns Error::PeerNotFound

fn get<'life0, 'life1, 'async_trait>( &'life0 self, peer_id: &'life1 PeerId, ) -> Pin<Box<dyn Future<Output = Result<Option<PeerInfo>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetch the PeerInfo indicated by peer_id.

fn listen_on<'life0, 'life1, 'async_trait>( &'life0 self, raddr: &'life1 Multiaddr, ) -> Pin<Box<dyn Future<Output = Result<Option<PeerId>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reverse lookup PeerId by raddr

fn choose_peers<'life0, 'life1, 'async_trait>( &'life0 self, protocol_id: &'life1 str, maximun: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<PeerId>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Randomly select peers by protoco_id.

fn choose_nat_peers<'life0, 'async_trait>( &'life0 self, limits: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Multiaddr>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,