Struct TcpPeerManager 

pub struct TcpPeerManager { /* private fields */ }

TCP-based Bitcoin P2P peer manager.

Manages outbound connections, performs version/verack handshakes, tracks misbehaviour, and broadcasts blocks and transactions.

Implementations

impl TcpPeerManager

pub fn new(local_addr: SocketAddr) -> Self

Create a new TCP peer manager

pub async fn set_height(&self, height: u32)

Update the current chain height (used in version messages)

pub async fn peer_count(&self) -> usize

Get count of connected peers

pub async fn add_misbehaviour(&self, peer_id: u64, score: i32)

Increase a peer’s misbehaviour score; ban if threshold exceeded

Trait Implementations

impl Default for TcpPeerManager

fn default() -> Self

Returns the “default value” for a type.

impl PeerManager for TcpPeerManager

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.