Struct pkarr::PkarrClientAsync

pub struct PkarrClientAsync(/* private fields */);

Async version of PkarrClient

Implementations

impl PkarrClientAsync

pub fn local_addr(&self) -> Option<SocketAddr>

Returns the local address of the udp socket this node is listening on.

Returns None if the node is shutdown

pub fn cache(&self) -> &dyn PkarrCache

Returns a reference to the internal cache.

pub async fn publish(&self, signed_packet: &SignedPacket) -> Result<()>

Publishes a SignedPacket to the Dht.

Errors

• Returns a Error::DhtIsShutdown if PkarrClient::shutdown was called, or the loop in the actor thread is stopped for any reason (like thread panic).
• Returns a Error::PublishInflight if the client is currently publishing the same public_key.
• Returns a Error::NotMostRecent if the provided signed packet is older than most recent.
• Returns a Error::MainlineError if the Dht received an unexpected error otherwise.

pub async fn resolve( &self, public_key: &PublicKey ) -> Result<Option<SignedPacket>>

Returns the first valid SignedPacket available from cache, or the Dht.

If the Dht was called, in the background, it continues receiving responses and updating the cache.

Errors

• Returns a Error::DhtIsShutdown if PkarrClient::shutdown was called, or the loop in the actor thread is stopped for any reason (like thread panic).

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

Shutdown the actor thread loop.

Trait Implementations

impl Clone for PkarrClientAsync

fn clone(&self) -> PkarrClientAsync

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PkarrClientAsync

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

Formats the value using the given formatter.