Struct DnsDiscoveryService

pub struct DnsDiscoveryService<R: Resolver = DnsResolver> { /* private fields */ }

A client that discovers nodes via DNS.

Implementations

impl<R: Resolver> DnsDiscoveryService<R>

pub fn new(resolver: Arc<R>, config: DnsDiscoveryConfig) -> Self

Creates a new instance of the DnsDiscoveryService using the given settings.

use reth_dns_discovery::{DnsDiscoveryService, DnsResolver};
use std::sync::Arc;
let service = DnsDiscoveryService::new(
    Arc::new(DnsResolver::from_system_conf().unwrap()),
    Default::default(),
);

pub fn spawn(self) -> JoinHandle<()>

Spawns this services onto a new task

Note: requires a running runtime

pub fn bootstrap(&mut self)

Starts discovery with all configured bootstrap links

pub fn new_pair( resolver: Arc<R>, config: DnsDiscoveryConfig, ) -> (Self, DnsDiscoveryHandle)

Same as DnsDiscoveryService::new but also returns a new handle that’s connected to the service

pub fn handle(&self) -> DnsDiscoveryHandle

Returns a new DnsDiscoveryHandle that can send commands to this type.

pub fn node_record_stream(&mut self) -> ReceiverStream<DnsNodeRecordUpdate>

Creates a new channel for [NodeRecord]s.

pub fn sync_tree(&mut self, link: &str) -> Result<(), ParseDnsEntryError>

Starts syncing the given link to a tree.

pub fn sync_tree_with_link(&mut self, link: LinkEntry)

Starts syncing the given link to a tree.

Trait Implementations

impl<R: Resolver> Stream for DnsDiscoveryService<R>

A Stream events, mainly used for debugging

type Item = DnsDiscoveryEvent

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

Layout

Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.

Size: 432 bytes