Struct NodePeers 

pub struct NodePeers { /* private fields */ }

NodePeers structure managing the peer database

Implementations

impl NodePeers

pub fn new(max_peers: usize) -> Self

Create a new NodePeers instance

pub fn default() -> Self

Create with default max_peers of 100

pub async fn clear_stale( &self, fabric: &Fabric, node_registry: &NodeAnrs, ) -> usize

pub async fn clear_stale_inner( &self, fabric: &Fabric, node_registry: &NodeAnrs, ) -> Result<usize, Error>

Clear stale peers and add missing validators/handshaked nodes

pub async fn insert_new_peer(&self, peer: Peer) -> bool

Insert a new peer if it doesn’t already exist

pub async fn seed( &self, fabric: &Fabric, config: &Config, node_anrs: &NodeAnrs, ) -> Result<(), Error>

Seed initial peers with validators

pub async fn size(&self) -> usize

Get number of peers

pub async fn random(&self, no: usize) -> Result<Vec<Peer>, Error>

Get random online peers

pub async fn get_all(&self) -> Result<Vec<Peer>, Error>

Get all peers

pub async fn get_online(&self) -> Result<Vec<Peer>, Error>

Get all online peers

pub async fn get_online_ip_l_th_rh( &self, ) -> Result<Vec<(Ipv4Addr, Option<u64>, Option<u64>, Option<u64>)>, Error>

Get summary of online peers

pub async fn get_shared_secret(&self, pk: &[u8]) -> Result<Vec<u8>, Error>

Get shared secret for a peer by public key

pub async fn by_ip(&self, ip: Ipv4Addr) -> Option<Peer>

Get peer by IP address

pub async fn by_pks(&self, pks: &[Vec<u8>]) -> Result<Vec<Peer>, Error>

Get peers by multiple public keys

pub async fn for_height( &self, fabric: &Fabric, height: u64, ) -> Result<Vec<Peer>, Error>

Get peers for a specific height (trainers)

pub async fn by_who( &self, fabric: &Fabric, who: Who, ) -> Result<Vec<Ipv4Addr>, Error>

Get peer IPs by who specification

pub async fn update_peer_ping_timestamp(&self, ip: Ipv4Addr, ts_m: u64)

pub async fn update_peer_from_tip( &self, _ctx: &Context, ip: Ipv4Addr, tip: &EventTip, )

pub async fn update_peer_from_pong(&self, ip: Ipv4Addr, pong: &PingReply)

pub async fn update_peer_from_proto(&self, ip: Ipv4Addr, last_msg_type: &str)

Update peer activity and last message type

pub async fn set_handshake_status( &self, ip: Ipv4Addr, status: HandshakeStatus, ) -> Result<(), Error>

Set handshake status for a specific IP

pub async fn update_peer_from_anr( &self, ip: Ipv4Addr, pk: &PublicKey, version: &Ver, status: Option<HandshakeStatus>, )

Update peer with version and public key information from ANR

pub async fn get_heights( &self, trainer_pks: &[PublicKey], ) -> Result<(u64, u64, u64), Error>

Returns temporal, rooted and bft heights across peers

pub async fn get_trainer_ips_above_rooted( &self, height: u64, trainer_pks: &[PublicKey], ) -> Result<Vec<Ipv4Addr>, Error>

pub async fn get_trainer_ips_above_temporal( &self, height: u64, trainer_pks: &[PublicKey], ) -> Result<Vec<Ipv4Addr>, Error>

pub async fn get_online_trainers( &self, trainer_pks: &[PublicKey], ) -> Result<Vec<Peer>, Error>

pub async fn get_peers_summary( &self, my_ip: Ipv4Addr, trainer_pks: &[PublicKey], ) -> Result<PeersSummary, Error>

Get peers summary with counts

Trait Implementations

impl Clone for NodePeers

fn clone(&self) -> NodePeers

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodePeers

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

Formats the value using the given formatter.