Trait NetworkDHTProvider

pub trait NetworkDHTProvider {
    // Required methods
    fn find_closest_peers(&self, target: PeerId);
    fn get_value(&self, key: &KademliaKey);
    fn put_value(&self, key: KademliaKey, value: Vec<u8>);
    fn put_record_to(
        &self,
        record: Record,
        peers: HashSet<PeerId>,
        update_local_storage: bool,
    );
    fn store_record(
        &self,
        key: KademliaKey,
        value: Vec<u8>,
        publisher: Option<PeerId>,
        expires: Option<Instant>,
    );
    fn start_providing(&self, key: KademliaKey);
    fn stop_providing(&self, key: KademliaKey);
    fn get_providers(&self, key: KademliaKey);
}

Provides access to the networking DHT.

Required Methods

fn find_closest_peers(&self, target: PeerId)

Start finding closest peers to the target.

fn get_value(&self, key: &KademliaKey)

Start getting a value from the DHT.

fn put_value(&self, key: KademliaKey, value: Vec<u8>)

Start putting a value in the DHT.

fn put_record_to( &self, record: Record, peers: HashSet<PeerId>, update_local_storage: bool, )

Start putting the record to peers.

If update_local_storage is true the local storage is udpated as well.

fn store_record( &self, key: KademliaKey, value: Vec<u8>, publisher: Option<PeerId>, expires: Option<Instant>, )

Store a record in the DHT memory store.

fn start_providing(&self, key: KademliaKey)

Register this node as a provider for key on the DHT.

fn stop_providing(&self, key: KademliaKey)

Deregister this node as a provider for key on the DHT.

fn get_providers(&self, key: KademliaKey)

Start getting the list of providers for key on the DHT.

Implementations on Foreign Types

impl<T> NetworkDHTProvider for Arc<T>

where T: ?Sized + NetworkDHTProvider,

fn find_closest_peers(&self, target: PeerId)

fn get_value(&self, key: &KademliaKey)

fn put_value(&self, key: KademliaKey, value: Vec<u8>)

fn put_record_to( &self, record: Record, peers: HashSet<PeerId>, update_local_storage: bool, )

fn store_record( &self, key: KademliaKey, value: Vec<u8>, publisher: Option<PeerId>, expires: Option<Instant>, )

fn start_providing(&self, key: KademliaKey)

fn stop_providing(&self, key: KademliaKey)

fn get_providers(&self, key: KademliaKey)

Implementors

impl<B, H> NetworkDHTProvider for NetworkService<B, H>

where B: BlockT + 'static, H: ExHashT,