Struct BootstrapManager 

pub struct BootstrapManager { /* private fields */ }

Bootstrap cache initialization and management

Implementations

impl BootstrapManager

pub async fn new() -> Result<Self>

Create a new bootstrap manager with default configuration

pub async fn with_config(config: CacheConfig) -> Result<Self>

Create a new bootstrap manager with custom configuration

pub async fn with_rate_limiting( config: CacheConfig, rate_limit_config: JoinRateLimiterConfig, ) -> Result<Self>

Create a new bootstrap manager with custom configuration and rate limiting

pub async fn with_full_config( config: CacheConfig, rate_limit_config: JoinRateLimiterConfig, diversity_config: IPDiversityConfig, ) -> Result<Self>

Create a new bootstrap manager with full custom configuration

pub async fn get_bootstrap_peers( &self, count: usize, ) -> Result<Vec<ContactEntry>>

Get bootstrap peers for initial connection

pub async fn add_contact(&mut self, contact: ContactEntry) -> Result<()>

Add a discovered peer to the cache

This method enforces both rate limiting and IP diversity checks to prevent Sybil attacks:

1. Rate limiting: Per-subnet (IPv6 /64, /48 and IPv4 /24) and global limits
2. IP diversity: Ensures geographic and ASN diversity across the network

Errors

Returns an error if:

• The contact has no addresses
• Join rate limit is exceeded for the IP subnet
• IP diversity limits are exceeded
• The cache operation fails

pub async fn add_contact_trusted(&mut self, contact: ContactEntry) -> Result<()>

Add a contact bypassing rate limiting and diversity checks (for internal/trusted sources)

Use this method only for contacts from trusted sources like:

• Well-known bootstrap nodes
• Pre-configured seed nodes
• Admin-approved contacts

Safety

This method does not enforce rate limiting or diversity checks. Only use for trusted sources.

pub async fn update_contact_metrics( &mut self, peer_id: &PeerId, metrics: QualityMetrics, ) -> Result<()>

Update contact performance metrics

pub async fn start_background_tasks(&mut self) -> Result<()>

Start background maintenance tasks

pub async fn get_stats(&self) -> Result<CacheStats>

Get cache statistics

pub async fn force_merge(&self) -> Result<MergeResult>

Force a cache merge operation

pub fn encode_address( &self, socket_addr: &SocketAddr, ) -> Result<FourWordAddress>

Convert socket address to four-word address

pub fn decode_address(&self, words: &FourWordAddress) -> Result<SocketAddr>

Convert four-word address to socket address

pub fn validate_words(&self, words: &FourWordAddress) -> Result<()>

Validate four-word address format

pub fn word_encoder(&self) -> &WordEncoder

Get the word encoder for direct access

pub fn get_well_known_word_addresses( &self, ) -> Vec<(FourWordAddress, SocketAddr)>

Get well-known bootstrap addresses as four-word addresses