Struct BootstrapManager 

pub struct BootstrapManager { /* private fields */ }

Simplified bootstrap manager wrapping ant-quic’s cache

Provides Sybil protection via rate limiting and IP diversity enforcement while delegating core caching to ant-quic’s proven implementation.

Implementations

impl BootstrapManager

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

Create a new bootstrap manager with default configuration

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

Create a new bootstrap manager with custom configuration

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

Create a new bootstrap manager with full custom configuration

This is a compatibility method for migrating from the old BootstrapManager. It accepts the old CacheConfig type and maps it to the new configuration.

pub fn start_maintenance(&mut self) -> Result<()>

Start background maintenance tasks (delegated to ant-quic)

pub async fn add_peer( &self, peer_id: PeerId, addresses: Vec<SocketAddr>, ) -> Result<()>

Add a peer to the cache with Sybil protection

Enforces:

1. Rate limiting (per-subnet temporal limits)
2. IP diversity (geographic/ASN limits)

pub async fn add_peer_trusted( &self, peer_id: PeerId, addresses: Vec<SocketAddr>, )

Add a trusted peer bypassing Sybil protection

Use only for well-known bootstrap nodes or admin-approved peers.

pub async fn record_success(&self, peer_id: &PeerId, rtt_ms: u32)

Record a successful connection

pub async fn record_failure(&self, peer_id: &PeerId)

Record a failed connection

pub async fn select_peers(&self, count: usize) -> Vec<CachedPeer>

Select peers for bootstrap using epsilon-greedy strategy

pub async fn select_relay_peers(&self, count: usize) -> Vec<CachedPeer>

Select peers that support relay functionality

pub async fn select_coordinators(&self, count: usize) -> Vec<CachedPeer>

Select peers that support NAT coordination

pub async fn stats(&self) -> BootstrapStats

Get cache statistics

pub async fn peer_count(&self) -> usize

Get the number of cached peers

pub async fn save(&self) -> Result<()>

Save cache to disk

pub async fn update_capabilities( &self, peer_id: &PeerId, capabilities: PeerCapabilities, )

Update peer capabilities

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

Check if a peer exists in the cache

pub async fn get_peer(&self, peer_id: &PeerId) -> Option<CachedPeer>

Get a specific peer from the cache

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

Add a discovered peer to the cache (compatibility method)

This accepts the old ContactEntry type and converts it to the new API.

pub async fn add_contact_trusted(&self, contact: ContactEntry)

Add a contact bypassing rate limiting (compatibility method)

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

Update contact performance metrics (compatibility method)

Maps the old QualityMetrics to record_success/record_failure calls.

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

Get bootstrap cache statistics (compatibility method)

Returns stats in the old CacheStats format.

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

Start background maintenance tasks (compatibility method)

Alias for start_maintenance().

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

Get bootstrap peers for initial connection (compatibility method)

Converts ant-quic CachedPeer results to ContactEntry format.

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

Get QUIC-capable bootstrap peers (compatibility method)

impl BootstrapManager

pub fn diversity_config(&self) -> &IPDiversityConfig

Get the diversity config