latest.ipv8.REST.dht_endpoint

Classes

This endpoint is responsible for handling requests for DHT data.

Module Contents

class latest.ipv8.REST.dht_endpoint.DHTEndpoint

Bases: latest.ipv8.REST.base_endpoint.BaseEndpoint[ipv8_service.IPv8]

This endpoint is responsible for handling requests for DHT data.

dht: latest.ipv8.dht.community.DHTCommunity | None = None

publisher = None

setup_routes() → None: Register the names to make this endpoint callable.

initialize(session: ipv8_service.IPv8) → None: Initialize this endpoint for the given session instance.

async get_statistics(_: aiohttp.web_request.Request) → latest.ipv8.REST.base_endpoint.Response: Return DHT statistics.

async get_peer(request: aiohttp.web_request.Request) → latest.ipv8.REST.base_endpoint.Response: Connect to a peer using the DHT.

async get_stored_values(_: aiohttp.web_request.Request) → latest.ipv8.REST.base_endpoint.Response: Get a list of locally stored key-value pairs from the DHT.

async get_values(request: aiohttp.web_request.Request) → latest.ipv8.REST.base_endpoint.Response: Lookup the values for a specific key on the DHT.

async put_value(request: aiohttp.web_request.Request) → latest.ipv8.REST.base_endpoint.Response: Store a key-value pair on the DHT.

async get_buckets(_: aiohttp.web_request.Request) → latest.ipv8.REST.base_endpoint.Response: Return a list of all buckets in the routing table of the DHT community.

async refresh_bucket(request: aiohttp.web_request.Request) → latest.ipv8.REST.base_endpoint.Response: Prefix of the bucket which to refresh.