Struct StubPeerManager 

pub struct StubPeerManager { /* private fields */ }

Stub P2P peer manager implementation

A lightweight stub suitable for testing and development when actual network connectivity is not needed.

Implementations

impl StubPeerManager

pub fn new() -> Self

Create a new stub peer manager

pub async fn peer_count(&self) -> usize

Get count of connected peers

Trait Implementations

impl Default for StubPeerManager

fn default() -> Self

Returns the “default value” for a type.

impl PeerManager for StubPeerManager

fn connect_peer<'life0, 'async_trait>( &'life0 self, addr: SocketAddr, ) -> Pin<Box<dyn Future<Output = Result<u64, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Initiates a connection to a peer.

fn disconnect_peer<'life0, 'async_trait>( &'life0 self, peer_id: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Disconnects from a peer.

fn ban_peer<'life0, 'async_trait>( &'life0 self, addr: SocketAddr, ban_time: u64, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Bans a peer, preventing further connections.

fn get_connected_peers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<PeerInfo>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Gets information about all connected peers.

fn broadcast_transaction<'life0, 'life1, 'async_trait>( &'life0 self, _tx: &'life1 Transaction, ) -> Pin<Box<dyn Future<Output = Result<usize, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Broadcasts a transaction to all connected peers.

fn broadcast_block<'life0, 'life1, 'async_trait>( &'life0 self, block: &'life1 Block, ) -> Pin<Box<dyn Future<Output = Result<usize, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Broadcasts a block to all connected peers.

fn send_to_peer<'life0, 'async_trait>( &'life0 self, peer_id: u64, message: NetworkMessage, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

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

Sends a network message to a specific peer.