Struct TokioDnsResolver 

#[non_exhaustive]
pub struct TokioDnsResolver { /* private fields */ }

Available on crate features dns and std only.

Portable DNS resolver backed by the host’s getaddrinfo, run on tokio’s blocking pool.

This relies on the host resolver for address lookups and does not support CNAME, TXT, SVCB, or HTTPS record resolution. Concurrent lookups of one name share a single getaddrinfo call.

Implementations

impl TokioDnsResolver

pub fn new() -> TokioDnsResolver

pub const fn timeout(&self) -> Duration

pub fn with_timeout(self, timeout: Duration) -> TokioDnsResolver

The budget of one lookup, including any wait for a free slot (default 5s). Clones made before this call no longer share lookups with this resolver.

pub fn set_timeout(&mut self, timeout: Duration) -> &mut TokioDnsResolver

The budget of one lookup, including any wait for a free slot (default 5s). Clones made before this call no longer share lookups with this resolver.

pub fn max_concurrency(&self) -> Option<usize>

pub fn maybe_with_max_concurrency(self, max: Option<usize>) -> TokioDnsResolver

Maximum concurrent getaddrinfo calls (default 384, 64 on Apple platforms, at least 1). Each holds a blocking-pool thread until libc returns, which a timeout cannot cancel, and on Apple platforms an mDNSResponder connection of launchd’s default 256 descriptors. Clones made before this call keep their own bounds.

pub fn maybe_set_max_concurrency( &mut self, max: Option<usize>, ) -> &mut TokioDnsResolver

Maximum concurrent getaddrinfo calls (default 384, 64 on Apple platforms, at least 1). Each holds a blocking-pool thread until libc returns, which a timeout cannot cancel, and on Apple platforms an mDNSResponder connection of launchd’s default 256 descriptors. Clones made before this call keep their own bounds.

pub fn with_max_concurrency(self, max: usize) -> TokioDnsResolver

Maximum concurrent getaddrinfo calls (default 384, 64 on Apple platforms, at least 1). Each holds a blocking-pool thread until libc returns, which a timeout cannot cancel, and on Apple platforms an mDNSResponder connection of launchd’s default 256 descriptors. Clones made before this call keep their own bounds.

pub fn set_max_concurrency(&mut self, max: usize) -> &mut TokioDnsResolver

Maximum concurrent getaddrinfo calls (default 384, 64 on Apple platforms, at least 1). Each holds a blocking-pool thread until libc returns, which a timeout cannot cancel, and on Apple platforms an mDNSResponder connection of launchd’s default 256 descriptors. Clones made before this call keep their own bounds.

pub fn without_max_concurrency(self) -> TokioDnsResolver

Maximum concurrent getaddrinfo calls (default 384, 64 on Apple platforms, at least 1). Each holds a blocking-pool thread until libc returns, which a timeout cannot cancel, and on Apple platforms an mDNSResponder connection of launchd’s default 256 descriptors. Clones made before this call keep their own bounds.

pub fn unset_max_concurrency(&mut self) -> &mut TokioDnsResolver

Maximum concurrent getaddrinfo calls (default 384, 64 on Apple platforms, at least 1). Each holds a blocking-pool thread until libc returns, which a timeout cannot cancel, and on Apple platforms an mDNSResponder connection of launchd’s default 256 descriptors. Clones made before this call keep their own bounds.

pub fn burst_limit(&self) -> Option<usize>

pub fn maybe_with_burst_limit(self, max: Option<usize>) -> TokioDnsResolver

Maximum getaddrinfo calls started within one burst window and still unanswered (default 64, as each asks for A and AAAA; at least 1). A local stub such as systemd-resolved drops queries that arrive faster than it reads them; an answer frees its place at once, a query waiting on a slow upstream once the window has passed. Clones made before this call keep their own bounds.

pub fn maybe_set_burst_limit( &mut self, max: Option<usize>, ) -> &mut TokioDnsResolver

Maximum getaddrinfo calls started within one burst window and still unanswered (default 64, as each asks for A and AAAA; at least 1). A local stub such as systemd-resolved drops queries that arrive faster than it reads them; an answer frees its place at once, a query waiting on a slow upstream once the window has passed. Clones made before this call keep their own bounds.

pub fn with_burst_limit(self, max: usize) -> TokioDnsResolver

Maximum getaddrinfo calls started within one burst window and still unanswered (default 64, as each asks for A and AAAA; at least 1). A local stub such as systemd-resolved drops queries that arrive faster than it reads them; an answer frees its place at once, a query waiting on a slow upstream once the window has passed. Clones made before this call keep their own bounds.

pub fn set_burst_limit(&mut self, max: usize) -> &mut TokioDnsResolver

Maximum getaddrinfo calls started within one burst window and still unanswered (default 64, as each asks for A and AAAA; at least 1). A local stub such as systemd-resolved drops queries that arrive faster than it reads them; an answer frees its place at once, a query waiting on a slow upstream once the window has passed. Clones made before this call keep their own bounds.

pub fn without_burst_limit(self) -> TokioDnsResolver

Maximum getaddrinfo calls started within one burst window and still unanswered (default 64, as each asks for A and AAAA; at least 1). A local stub such as systemd-resolved drops queries that arrive faster than it reads them; an answer frees its place at once, a query waiting on a slow upstream once the window has passed. Clones made before this call keep their own bounds.

pub fn unset_burst_limit(&mut self) -> &mut TokioDnsResolver

Maximum getaddrinfo calls started within one burst window and still unanswered (default 64, as each asks for A and AAAA; at least 1). A local stub such as systemd-resolved drops queries that arrive faster than it reads them; an answer frees its place at once, a query waiting on a slow upstream once the window has passed. Clones made before this call keep their own bounds.

pub fn burst_window(&self) -> Duration

pub fn with_burst_window(self, window: Duration) -> TokioDnsResolver

The window of Self::burst_limit (default 20ms). Clones made before this call keep their own bounds.

pub fn set_burst_window(&mut self, window: Duration) -> &mut TokioDnsResolver

The window of Self::burst_limit (default 20ms). Clones made before this call keep their own bounds.

Trait Implementations

impl Clone for TokioDnsResolver

fn clone(&self) -> TokioDnsResolver

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TokioDnsResolver

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for TokioDnsResolver

fn default() -> TokioDnsResolver

Returns the “default value” for a type.

impl DnsAddressResolver for TokioDnsResolver

type Error = Box<dyn Error + Sync + Send>

Error returned by the DnsAddressResolver

fn lookup_ipv4( &self, domain: Domain, ) -> impl Stream<Item = Result<Ipv4Addr, <TokioDnsResolver as DnsAddressResolver>::Error>> + Send

Resolve the ‘A’ records accessible by this resolver for the given Domain into Ipv4Addresses.

fn lookup_ipv6( &self, domain: Domain, ) -> impl Stream<Item = Result<Ipv6Addr, <TokioDnsResolver as DnsAddressResolver>::Error>> + Send

Resolve the ‘AAAA’ records accessible by this resolver for the given Domain into Ipv6Addresses.

fn lookup_ipv4_first( &self, domain: Domain, ) -> impl Future<Output = Option<Result<Ipv4Addr, Self::Error>>> + Send

Resolve the first ‘A’ record found for the resolver.

fn lookup_ipv4_rand( &self, domain: Domain, ) -> impl Future<Output = Option<Result<Ipv4Addr, Self::Error>>> + Send

Resolve to a pseudo-random ‘A’ record found for the resolver.

fn lookup_ipv6_first( &self, domain: Domain, ) -> impl Future<Output = Option<Result<Ipv6Addr, Self::Error>>> + Send

Resolve the first ‘AAAA’ record found for the resolver.

fn lookup_ipv6_rand( &self, domain: Domain, ) -> impl Future<Output = Option<Result<Ipv6Addr, Self::Error>>> + Send

Resolve to a pseudo-random ‘AAAA’ record found for the resolver.

fn into_box_dns_address_resolver(self) -> BoxDnsAddressResolver

Box this resolver to allow for dynamic dispatch.

impl DnsCnameResolver for TokioDnsResolver

type Error = TokioDnsCnameUnsupportedError

Error returned by this resolver.

fn lookup_cname( &self, _domain: Domain, ) -> impl Stream<Item = Result<Name, <TokioDnsResolver as DnsCnameResolver>::Error>> + Send

Resolve CNAME targets for the given domain.

fn into_box_dns_cname_resolver(self) -> BoxDnsCnameResolver

Box this resolver to allow dynamic dispatch.

impl DnsResolver for TokioDnsResolver

fn into_box_dns_resolver(self) -> BoxDnsResolver

where Self: Sized,

Box this aggregate resolver for dynamic dispatch.

impl DnsServiceBindingResolver for TokioDnsResolver

type Error = TokioDnsServiceBindingUnsupportedError

Error returned by this resolver.

fn lookup_svcb( &self, _domain: Domain, ) -> impl Stream<Item = Result<ServiceBinding, <TokioDnsResolver as DnsServiceBindingResolver>::Error>> + Send

Resolve the complete SVCB RRset for the given domain.

fn lookup_https( &self, _domain: Domain, ) -> impl Stream<Item = Result<ServiceBinding, <TokioDnsResolver as DnsServiceBindingResolver>::Error>> + Send

Resolve the complete HTTPS RRset for the given domain.

fn into_box_dns_service_binding_resolver(self) -> BoxDnsServiceBindingResolver

Box this resolver to allow dynamic dispatch.

impl DnsTxtResolver for TokioDnsResolver

type Error = TokioDnsTxtUnsupportedError

Error returned by the DnsTxtResolver

fn lookup_txt( &self, _domain: Domain, ) -> impl Stream<Item = Result<Txt, <TokioDnsResolver as DnsTxtResolver>::Error>> + Send

Resolve the TXT records accessible for the given Domain.

fn into_box_dns_txt_resolver(self) -> BoxDnsTxtResolver

Box this resolver to allow for dynamic dispatch.