Struct WebRTCState 

pub struct WebRTCState {
    pub runtime: MeshRuntimeState<MeshPeer>,
    /* private fields */
}

Shared state for the native mesh router.

Fields

runtime: MeshRuntimeState<MeshPeer>

Implementations

impl WebRTCState

pub fn new() -> WebRTCState

pub fn new_with_routing( selection_strategy: SelectionStrategy, fairness_enabled: bool, request_dispatch: RequestDispatchConfig, ) -> WebRTCState

pub fn new_with_routing_and_cashu( selection_strategy: SelectionStrategy, fairness_enabled: bool, request_dispatch: RequestDispatchConfig, request_timeout: Duration, cashu_routing: CashuRoutingConfig, payment_client: Option<Arc<dyn CashuPaymentClient>>, mint_metadata: Option<Arc<CashuMintMetadataStore>>, ) -> WebRTCState

pub async fn set_local_buses(&self, buses: Vec<Arc<dyn LocalNostrBus>>)

pub async fn add_local_bus(&self, bus: Arc<dyn LocalNostrBus>)

pub async fn set_multicast_bus(&self, bus: Option<Arc<MulticastNostrBus>>)

pub async fn reset_runtime_state(&self)

Drop all live peer sessions and clear topology-specific state while keeping cumulative bandwidth counters intact.

pub fn get_bandwidth(&self) -> (u64, u64)

Get current bandwidth stats (bytes sent/received)

pub fn get_mesh_stats(&self) -> (u64, u64, u64)

pub fn record_mesh_received(&self)

pub fn record_mesh_forwarded(&self, count: u64)

pub fn record_mesh_duplicate_drop(&self)

pub async fn record_sent(&self, peer_id: &str, bytes: u64)

Record bytes sent (global + per-peer)

pub async fn record_received(&self, peer_id: &str, bytes: u64)

Record bytes received (global + per-peer)

pub async fn request_from_peers(&self, hash_hex: &str) -> Option<Vec<u8>>

Request content by hash from connected peers Queries peers in adaptive selector order with hedged fanout waves. Returns the first successful response, or None if no peer has it

pub async fn request_from_peers_with_source( &self, hash_hex: &str, ) -> Option<(Vec<u8>, String)>

Request content by hash from connected peers, returning data and source peer.

pub async fn resolve_root_from_peers( &self, owner_pubkey: &str, tree_name: &str, per_peer_timeout: Duration, ) -> Option<PeerRootEvent>

Resolve a hashtree root event through connected peers using Nostr REQ/EOSE over WebRTC.

pub async fn resolve_root_from_local_buses_with_source( &self, owner_pubkey: &str, tree_name: &str, timeout: Duration, ) -> Option<(&'static str, PeerRootEvent)>

pub async fn resolve_root_from_local_buses( &self, owner_pubkey: &str, tree_name: &str, timeout: Duration, ) -> Option<PeerRootEvent>

pub async fn resolve_root_from_multicast( &self, owner_pubkey: &str, tree_name: &str, timeout: Duration, ) -> Option<PeerRootEvent>

Trait Implementations

impl Default for WebRTCState

fn default() -> WebRTCState

Returns the “default value” for a type.