Struct fuel_core_p2p::peer_manager::PeerManager

pub struct PeerManager { /* private fields */ }

Manages Peers and their events

Implementations

impl PeerManager

pub fn new( reserved_peers_updates: Sender<usize>, reserved_peers: HashSet<PeerId>, connection_state: Arc<RwLock<ConnectionState>>, max_non_reserved_peers: usize, ) -> Self

pub fn reserved_peers_updates(&self) -> Sender<usize>

pub fn is_reserved(&self, peer_id: &PeerId) -> bool

pub fn handle_gossip_score_update<T: Punisher>( &self, peer_id: PeerId, gossip_score: f64, punisher: &mut T, )

pub fn handle_peer_info_updated( &mut self, peer_id: &PeerId, block_height: BlockHeight, )

pub fn handle_peer_connected(&mut self, peer_id: &PeerId) -> bool

Returns true signaling that the peer should be disconnected

pub fn handle_peer_identified( &mut self, peer_id: &PeerId, addresses: Vec<Multiaddr>, agent_version: String, )

pub fn batch_update_score_with_decay(&mut self)

pub fn update_app_score<T: Punisher>( &mut self, peer_id: PeerId, score: AppScore, reporting_service: &str, punisher: &mut T, )

pub fn total_peers_connected(&self) -> usize

pub fn get_peers_ids(&self) -> impl Iterator<Item = &PeerId>

pub fn get_peer_info(&self, peer_id: &PeerId) -> Option<&PeerInfo>

pub fn get_all_peers(&self) -> impl Iterator<Item = (&PeerId, &PeerInfo)>

pub fn handle_peer_disconnect(&mut self, peer_id: PeerId) -> bool

Handles on peer’s last connection getting disconnected Returns ‘true’ signaling we should try reconnecting

pub fn get_peer_id_with_height(&self, height: &BlockHeight) -> Option<PeerId>

Find a peer that is holding the given block height.

Trait Implementations

impl Debug for PeerManager

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

Formats the value using the given formatter.