Struct NodeAnrs 

pub struct NodeAnrs { /* private fields */ }

NodeRegistry manages the network-wide identity verification system Tracks ANR (Amadeus Network Record) entries with cryptographic signatures

Implementations

impl NodeAnrs

pub fn new() -> Self

Create a new NodeRegistry instance

pub fn default() -> Self

Create with default configuration

pub async fn insert(&self, anr: Anr)

Insert or update anr record

pub async fn get(&self, pk: &[u8]) -> Option<Anr>

Get anr by public key

pub async fn get_by_ip4(&self, ip4: Ipv4Addr) -> Option<Anr>

Get anr by IP address

pub async fn get_all_b3f4(&self) -> Vec<B3f4>

Get all anrs

pub async fn get_all(&self) -> Vec<Anr>

Get all anrs

pub async fn is_within_udp_limit(&self, ip4: Ipv4Addr) -> Option<bool>

Increment and return the frames counter

pub async fn is_within_proto_limit( &self, pk: &[u8], typename: &str, ) -> Option<bool>

Check if protocol message is within rate limit for this peer

pub async fn update_rate_limiting_counters(&self)

Reset rate limiting counters for all anrs

pub async fn unset_handshaked(&self, pk: &[u8])

Reset handshaked status (will silently return if pk not found)

pub async fn set_handshaked(&self, pk: &[u8])

Set handshaked status (will silently return if pk not found)

pub async fn handshaked(&self) -> Vec<PublicKey>

Get all handshaked node public keys

pub async fn get_all_not_handshaked_ip4(&self) -> Vec<Ipv4Addr>

Get all not handshaked (pk, ip4) pairs

pub async fn is_handshaked(&self, pk: &[u8]) -> bool

Check if node is handshaked

pub async fn handshaked_and_valid_ip4(&self, pk: &[u8], ip4: &Ipv4Addr) -> bool

Check if node is handshaked with valid ip4

pub async fn get_random_verified(&self, count: usize) -> Vec<Ipv4Addr>

Get random verified nodes

pub async fn get_random_not_verified(&self, count: usize) -> Vec<Ipv4Addr>

Get random unverified nodes

pub async fn get_all_excluding_b3f4(&self, b3f4: &[B3f4]) -> Vec<Anr>

Get all handshaked (pk, ip4) pairs

pub async fn get_all_handshaked_ip4(&self) -> Vec<Ipv4Addr>

Get all handshaked (pk, ip4) pairs

pub async fn by_pks_ip<T: AsRef<[u8]>>(&self, pks: &[T]) -> Vec<Ipv4Addr>

Get ip addresses for given public keys

pub async fn seed(&self, config: &Config)

Seed initial anrs (called on startup)

Trait Implementations

impl Clone for NodeAnrs

fn clone(&self) -> NodeAnrs

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeAnrs

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

Formats the value using the given formatter.