Struct tari_comms_dht::Dht

pub struct Dht { /* fields omitted */ }

Responsible for starting the DHT actor, building the DHT middleware stack and as a factory for producing DHT requesters.

Implementations

impl Dht

pub async fn initialize(
    config: DhtConfig,
    node_identity: Arc<NodeIdentity>,
    peer_manager: Arc<PeerManager>,
    outbound_tx: Sender<DhtOutboundRequest>,
    connectivity: ConnectivityRequester,
    shutdown_signal: ShutdownSignal
) -> Result<Self, DhtInitializationError>

pub fn outbound_requester(&self) -> OutboundMessageRequester

Return a new OutboundMessageRequester connected to the receiver

pub fn dht_requester(&self) -> DhtRequester

Returns a requester for the DhtActor associated with this instance

pub fn discovery_service_requester(&self) -> DhtDiscoveryRequester

Returns a requester for the DhtDiscoveryService associated with this instance

pub fn store_and_forward_requester(&self) -> StoreAndForwardRequester

Returns a requester for the StoreAndForwardService associated with this instance

pub fn subscribe_dht_events(&self) -> DhtEventReceiver

Get a subscription to DhtEvents

pub fn inbound_middleware_layer<S>(
    &self
) -> impl Layer<S, Service = impl Service<InboundMessage, Response = (), Error = PipelineError, Future = impl Future<Output = Result<(), PipelineError>> + Send> + Clone + Send> where
    S: Service<DecryptedDhtMessage, Response = (), Error = PipelineError> + Clone + Send + Sync + 'static,
    S::Future: Send, 

Returns an the full DHT stack as a tower::layer::Layer. This can be composed with other inbound middleware services which expect an DecryptedDhtMessage

pub fn outbound_middleware_layer<S>(
    &self
) -> impl Layer<S, Service = impl Service<DhtOutboundRequest, Response = (), Error = PipelineError, Future = impl Future<Output = Result<(), PipelineError>> + Send> + Clone + Send> where
    S: Service<OutboundMessage, Response = (), Error = PipelineError> + Clone + Send + 'static,
    S::Future: Send, 

Returns an the full DHT stack as a tower::layer::Layer. This can be composed with other outbound middleware services which expect an OutboundMessage