Struct DhtService 

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

Implementations

impl DhtService

pub fn builder(local_id: PeerId) -> DhtServiceBuilder

pub fn local_id(&self) -> &PeerId

pub fn make_client(&self, network: &Network) -> DhtClient

pub fn make_peer_resolver(&self) -> PeerResolverBuilder

pub fn has_peer(&self, peer_id: &PeerId) -> bool

pub fn find_local_closest( &self, key: &[u8; 32], count: usize, ) -> Vec<Arc<PeerInfo>>

pub fn store_value_locally( &self, value: &ValueRef<'_>, ) -> Result<bool, StorageError>

pub fn insert_merger( &self, group_id: &[u8; 32], merger: Arc<dyn DhtValueMerger>, ) -> Option<Arc<dyn DhtValueMerger>>

pub fn remove_merger( &self, group_id: &[u8; 32], ) -> Option<Arc<dyn DhtValueMerger>>

pub fn peer_added(&self) -> &Arc<Notify>

Trait Implementations

impl Clone for DhtService

fn clone(&self) -> DhtService

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Routable for DhtService

fn query_ids(&self) -> impl IntoIterator<Item = u32>

fn message_ids(&self) -> impl IntoIterator<Item = u32>

impl Service<ServiceRequest> for DhtService

type QueryResponse = Response

type OnQueryFuture = Ready<Option<<DhtService as Service<ServiceRequest>>::QueryResponse>>

type OnMessageFuture = Ready<()>

fn on_query(&self, req: ServiceRequest) -> Self::OnQueryFuture

Called when a query is received.

fn on_message(&self, req: ServiceRequest) -> Self::OnMessageFuture

Called when a message is received.