Struct WebRTCManager 

pub struct WebRTCManager { /* private fields */ }

Native mesh manager handles peer discovery and transport fan-out.

Implementations

impl WebRTCManager

pub fn new(keys: Keys, config: WebRTCConfig) -> WebRTCManager

Create a new WebRTC manager

pub fn new_with_state( keys: Keys, config: WebRTCConfig, state: Arc<WebRTCState>, ) -> WebRTCManager

Create a new WebRTC manager reusing an existing shared state object.

pub fn new_with_classifier( keys: Keys, config: WebRTCConfig, classifier: Arc<dyn Fn(&str) -> PeerPool + Sync + Send>, ) -> WebRTCManager

Create a new WebRTC manager with a peer classifier

pub fn new_with_store( keys: Keys, config: WebRTCConfig, store: Arc<dyn ContentStore>, ) -> WebRTCManager

Create a new WebRTC manager with a content store for serving hash requests

pub fn new_with_store_and_classifier( keys: Keys, config: WebRTCConfig, store: Arc<dyn ContentStore>, classifier: Arc<dyn Fn(&str) -> PeerPool + Sync + Send>, ) -> WebRTCManager

Create a new WebRTC manager with store and classifier

pub fn new_with_state_and_store_and_classifier( keys: Keys, config: WebRTCConfig, state: Arc<WebRTCState>, store: Arc<dyn ContentStore>, classifier: Arc<dyn Fn(&str) -> PeerPool + Sync + Send>, ) -> WebRTCManager

pub fn new_with_store_and_classifier_and_cashu( keys: Keys, config: WebRTCConfig, store: Arc<dyn ContentStore>, classifier: Arc<dyn Fn(&str) -> PeerPool + Sync + Send>, cashu_routing: CashuRoutingConfig, payment_client: Option<Arc<dyn CashuPaymentClient>>, mint_metadata: Option<Arc<CashuMintMetadataStore>>, ) -> WebRTCManager

pub fn set_store(&mut self, store: Arc<dyn ContentStore>)

Set the content store for serving hash requests

pub fn set_peer_classifier( &mut self, classifier: Arc<dyn Fn(&str) -> PeerPool + Sync + Send>, )

Set the peer classifier

pub fn set_nostr_relay(&mut self, relay: Arc<dyn MeshRelayClient>)

Set the Nostr relay for data-channel relay messages

pub fn my_peer_id(&self) -> &PeerId

Get my peer ID

pub fn state(&self) -> Arc<WebRTCState>

Get shared state for external access

pub fn shutdown_signal(&self) -> Arc<Sender<bool>>

Cloneable shutdown handle for external lifecycle control.

pub fn shutdown(&self)

Signal shutdown

pub async fn connected_count(&self) -> usize

Get connected peer count

pub async fn peer_statuses(&self) -> Vec<PeerStatus>

Get all peer statuses

pub async fn get_pool_counts(&self) -> (usize, usize, usize, usize)

Get pool counts Returns (follows_connected, follows_active, other_connected, other_active) “active” = Connected or Connecting (excludes Discovered and Failed)

impl WebRTCManager

pub async fn run(&mut self) -> Result<(), Error>

Start the native peer router - connects transports and handles signaling.