Struct NetworkClient 

pub struct NetworkClient { /* private fields */ }

Implementations

impl NetworkClient

pub const fn new(network_manager: LazyRecipient<NetworkMessage>) -> Self

pub async fn dial(&self, peer_addr: Multiaddr) -> Result<()>

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

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

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

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

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

pub async fn open_stream(&self, peer_id: PeerId) -> Result<Stream>

pub async fn peer_count(&self) -> usize

pub async fn mesh_peer_count(&self, topic: TopicHash) -> usize

pub async fn mesh_peers(&self, topic: TopicHash) -> Vec<PeerId>

pub async fn announce_blob( &self, blob_id: BlobId, context_id: ContextId, size: u64, ) -> Result<()>

Announce a blob to the DHT for a specific context

pub async fn query_blob( &self, blob_id: BlobId, context_id: Option<ContextId>, ) -> Result<Vec<PeerId>>

Query the DHT for peers that have a specific blob

pub async fn request_blob( &self, blob_id: BlobId, context_id: ContextId, peer_id: PeerId, ) -> Result<Option<Vec<u8>>>

Request a blob from a specific peer

Trait Implementations

impl Clone for NetworkClient

fn clone(&self) -> NetworkClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NetworkClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.