Struct DhtClient 

pub struct DhtClient { /* private fields */ }

DHT Client for messaging system

This wraps the core DHT engine and provides a simple interface for storing and retrieving messages and other data.

Implementations

impl DhtClient

pub fn new() -> Result<Self>

Create a new DHT client with a random node ID

pub fn with_node_id(node_id: NodeId) -> Result<Self>

Create a DHT client with a specific node ID (derived from four-word address)

pub fn core_engine(&self) -> Arc<RwLock<DhtCoreEngine>>

Get the core DHT engine for advanced operations

pub async fn put(&self, key: String, value: Vec<u8>) -> Result<StoreReceipt>

Store data in the DHT

pub async fn get(&self, key: String) -> Result<Option<Vec<u8>>>

Retrieve data from the DHT

pub async fn put_object<T: Serialize>( &self, key: String, object: &T, ) -> Result<StoreReceipt>

Store a serializable object in the DHT

pub async fn get_object<T: for<'de> Deserialize<'de>>( &self, key: String, ) -> Result<Option<T>>

Retrieve and deserialize an object from the DHT

pub async fn join_network(&self, bootstrap_nodes: Vec<NodeInfo>) -> Result<()>

Join the DHT network with bootstrap nodes

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

Leave the DHT network gracefully

pub async fn find_nodes( &self, key: String, count: usize, ) -> Result<Vec<NodeInfo>>

Find nodes closest to a key

pub fn node_id(&self) -> &NodeId

Get the local node ID

pub async fn exists(&self, key: String) -> Result<bool>

Check if data exists in the DHT

pub async fn delete(&self, key: String) -> Result<StoreReceipt>

Delete data from the DHT (soft delete by storing empty value)

impl DhtClient

This impl block contains no items.

Create a mock DHT client for testing This is a temporary function to maintain compatibility during migration

Trait Implementations

impl Clone for DhtClient

fn clone(&self) -> DhtClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.