Struct PeerStore 

pub struct PeerStore { /* private fields */ }

Implementations

impl PeerStore

pub fn new() -> Self

pub async fn insert(&self, addr: SocketAddr, source: PeerSource)

pub async fn bulk_insert<I: IntoIterator<Item = SocketAddr>>( &self, it: I, source: PeerSource, )

pub async fn mark_success(&self, addr: &SocketAddr)

pub async fn mark_success_with_meta( &self, addr: &SocketAddr, node_id: Option<String>, capabilities: Option<Vec<String>>, )

Mark peer as successfully connected and update metadata from HELLO

pub async fn mark_failure(&self, addr: &SocketAddr)

pub async fn next_reconnect_attempt( &self, addr: &SocketAddr, max_attempts: u32, ) -> Option<u32>

Reserve the next reconnect attempt number, starting at one.

Returns None when the configured consecutive-attempt budget is exhausted.

pub async fn reset_reconnect(&self, addr: &SocketAddr)

pub async fn reconnect_attempts(&self, addr: &SocketAddr) -> u32

pub async fn sample( &self, k: usize, exclude: &HashSet<SocketAddr>, ) -> Vec<SocketAddr>

pub async fn all(&self) -> Vec<SocketAddr>

pub async fn load_from_file( path: &str, ttl_secs: u64, max_entries: usize, ) -> Self

pub async fn save_to_file(&self, path: &str) -> Result<(), Error>

pub async fn spawn_periodic_save(self, path: String, interval_secs: u64)

pub async fn from_config(cfg: &Config) -> Self

Construct and optionally start periodic saves based on runtime config. Uses node.state_dir to derive path when not explicitly provided.

pub async fn save_if_enabled(&self, cfg: &Config)

Save to derived path if persistence enabled in config.

Trait Implementations

impl Clone for PeerStore

fn clone(&self) -> PeerStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for PeerStore

fn default() -> Self

Returns the “default value” for a type.