Struct NetworkFacade 

pub struct NetworkFacade {

    pub node: NetworkNode,
    pub semantic_dht: Option<Arc<RwLock<SemanticDht>>>,
    pub gossipsub: Option<Arc<RwLock<GossipSubManager>>>,
    pub geo_router: Option<Arc<RwLock<GeoRouter>>>,
    pub quality_predictor: Option<Arc<RwLock<QualityPredictor>>>,
    pub peer_selector: Option<Arc<RwLock<PeerSelector>>>,
    pub multipath_quic: Option<Arc<RwLock<MultipathQuicManager>>>,
    pub tor_manager: Option<Arc<RwLock<TorManager>>>,
    pub bandwidth_throttle: Option<Arc<RwLock<BandwidthThrottle>>>,
    pub adaptive_polling: Option<Arc<RwLock<AdaptivePolling>>>,
    pub background_mode: Option<Arc<RwLock<BackgroundModeManager>>>,
    pub offline_queue: Option<Arc<RwLock<OfflineQueue>>>,
    pub memory_monitor: Option<Arc<RwLock<MemoryMonitor>>>,
    pub network_monitor: Option<Arc<RwLock<NetworkMonitor>>>,
    pub query_batcher: Option<Arc<RwLock<QueryBatcher>>>,
    pub peer_store: Arc<RwLock<PeerStore>>,
    pub dht_manager: Arc<RwLock<DhtManager>>,
    pub dht_provider_registry: Arc<RwLock<DhtProviderRegistry>>,
}

High-level network facade integrating all modules

Fields

node: NetworkNode

Core network node

semantic_dht: Option<Arc<RwLock<SemanticDht>>>

Optional modules

gossipsub: Option<Arc<RwLock<GossipSubManager>>>

geo_router: Option<Arc<RwLock<GeoRouter>>>

quality_predictor: Option<Arc<RwLock<QualityPredictor>>>

peer_selector: Option<Arc<RwLock<PeerSelector>>>

multipath_quic: Option<Arc<RwLock<MultipathQuicManager>>>

tor_manager: Option<Arc<RwLock<TorManager>>>

bandwidth_throttle: Option<Arc<RwLock<BandwidthThrottle>>>

adaptive_polling: Option<Arc<RwLock<AdaptivePolling>>>

background_mode: Option<Arc<RwLock<BackgroundModeManager>>>

offline_queue: Option<Arc<RwLock<OfflineQueue>>>

memory_monitor: Option<Arc<RwLock<MemoryMonitor>>>

network_monitor: Option<Arc<RwLock<NetworkMonitor>>>

query_batcher: Option<Arc<RwLock<QueryBatcher>>>

peer_store: Arc<RwLock<PeerStore>>

Always-available supporting modules

dht_manager: Arc<RwLock<DhtManager>>

dht_provider_registry: Arc<RwLock<DhtProviderRegistry>>

Implementations

impl NetworkFacade

pub fn new(config: NetworkConfig) -> Result<Self>

Create a new network facade with default configuration

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

Start the network node and all enabled modules

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

Stop the network node and all modules

pub fn peer_id(&self) -> PeerId

Get peer ID

pub fn connected_peers(&self) -> Vec<PeerId>

Get connected peers

pub async fn connect(&mut self, addr: Multiaddr) -> Result<()>

Connect to a peer

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

Disconnect from a peer

pub async fn provide(&mut self, cid: &Cid) -> Result<()>

Provide content to the DHT

pub async fn find_providers(&mut self, cid: &Cid) -> Result<()>

Find providers for content

pub fn get_health(&self) -> NetworkHealthSummary

Get network health summary

pub fn is_healthy(&self) -> bool

Check if network is healthy

pub fn peer_count(&self) -> usize

Get peer count

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

Check if connected to peer

pub fn bytes_sent(&self) -> u64

Get bytes sent

pub fn bytes_received(&self) -> u64

Get bytes received

pub async fn with_tor_manager( &mut self, config: TorConfig, ) -> Result<(), TorError>

Add a Tor manager after creation (requires async initialization)

pub fn semantic_search( &self, namespace: &NamespaceId, embedding: Vec<f32>, top_k: usize, ) -> Result<Vec<SemanticResult>>

Perform semantic search using vector embeddings (requires semantic_dht)

Returns

Returns an error if semantic DHT is not enabled

pub fn index_content( &self, cid: Cid, embedding: Vec<f32>, namespace: NamespaceId, ) -> Result<()>

Index content with semantic embedding (requires semantic_dht)

pub fn register_semantic_namespace( &self, namespace: NamespaceId, dimension: usize, ) -> Result<()>

Register a semantic namespace (requires semantic_dht)

pub fn subscribe(&self, topic: &str) -> Result<()>

Subscribe to a topic (requires gossipsub)

pub fn unsubscribe(&self, topic: &str) -> Result<()>

Unsubscribe from a topic (requires gossipsub)

pub fn publish(&self, topic: &str, data: Vec<u8>) -> Result<MessageId>

Publish a message to a topic (requires gossipsub)

pub fn subscribed_topics(&self) -> Result<Vec<String>>

Get subscribed topics (requires gossipsub)

pub fn find_nearby_peers(&self, location: GeoLocation) -> Result<Vec<PeerId>>

Find nearby peers based on geographic location (requires geo_routing)

pub fn set_peer_location( &self, peer_id: PeerId, location: GeoLocation, ) -> Result<()>

Set location for a peer (requires geo_routing)

pub fn get_best_peers( &self, peers: &[PeerId], count: usize, ) -> Result<Vec<PeerId>>

Get best quality peers for content transfer (requires quality_predictor)

pub fn select_optimal_peers( &self, criteria: &SelectionCriteria, ) -> Result<Vec<PeerId>>

Select optimal peers (requires peer_selector)

pub fn get_network_stats(&self) -> NetworkStats

Get comprehensive network statistics

pub fn get_module_status(&self) -> ModuleStatus

Get detailed module status

pub fn get_memory_stats(&self) -> Result<MemoryStats>

Get memory usage statistics (requires memory_monitor)

pub async fn connect_batch(&mut self, addrs: Vec<Multiaddr>) -> Vec<Result<()>>

Connect to multiple peers concurrently

pub async fn provide_batch(&mut self, cids: Vec<Cid>) -> Vec<Result<()>>

Announce multiple CIDs to the DHT

pub async fn find_providers_batch(&mut self, cids: Vec<Cid>) -> Vec<Result<()>>

Find providers for multiple CIDs

pub fn is_module_enabled(&self, module: &str) -> bool

Check if a specific module is enabled

pub fn enabled_modules(&self) -> Vec<String>

Get list of enabled module names

pub fn summary(&self) -> String

Get human-readable summary of the network facade configuration