Struct MeshRuntimeState 

pub struct MeshRuntimeState<P> {
    pub peers: Arc<RwLock<HashMap<String, MeshPeerEntry<P>>>>,
    pub connected_count: Arc<AtomicUsize>,
    pub bytes_sent: AtomicU64,
    pub bytes_received: AtomicU64,
    pub mesh_received: AtomicU64,
    pub mesh_forwarded: AtomicU64,
    pub mesh_dropped_duplicate: AtomicU64,
    /* private fields */
}

Shared runtime state for transport-backed mesh peers.

Fields

peers: Arc<RwLock<HashMap<String, MeshPeerEntry<P>>>>

connected_count: Arc<AtomicUsize>

bytes_sent: AtomicU64

bytes_received: AtomicU64

mesh_received: AtomicU64

mesh_forwarded: AtomicU64

mesh_dropped_duplicate: AtomicU64

Implementations

impl<P> MeshRuntimeState<P>

where P: MeshSession + Send + Sync + 'static,

pub fn new() -> Self

pub async fn set_local_buses(&self, buses: Vec<SharedLocalNostrBus>)

pub async fn add_local_bus(&self, bus: SharedLocalNostrBus)

pub async fn set_peer_hash_get(&self, peer_id: &str, enabled: bool)

pub async fn clear_peer_hash_get(&self, peer_id: &str)

pub async fn peer_hash_get_enabled(&self, peer_id: &str) -> bool

pub async fn peer_hash_get_snapshot(&self) -> HashMap<String, bool>

pub async fn record_known_peer_signal_urls( &self, peer_id: &str, signal_urls: &[String], source: &str, )

pub async fn known_peer_snapshot(&self) -> KnownPeerSnapshot

pub async fn import_known_peer_snapshot(&self, snapshot: &KnownPeerSnapshot)

pub async fn local_buses(&self) -> Vec<SharedLocalNostrBus>

pub async fn reset(&self)

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

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)

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

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>

Trait Implementations

impl<P> Default for MeshRuntimeState<P>

where P: MeshSession + Send + Sync + 'static,

fn default() -> Self

Returns the “default value” for a type.