Struct hickory_proto::udp::UdpClientStream

pub struct UdpClientStream<S, MF = NoopMessageFinalizer>
where
    S: Send,
    MF: MessageFinalizer,
{ /* private fields */ }

A UDP client stream of DNS binary packets

This stream will create a new UDP socket for every request. This is to avoid potential cache poisoning during use by UDP based attacks.

Implementations

impl<S: UdpSocket + Send + 'static> UdpClientStream<S, NoopMessageFinalizer>

pub fn new(name_server: SocketAddr) -> UdpClientConnect<S, NoopMessageFinalizer>

it is expected that the resolver wrapper will be responsible for creating and managing new UdpClients such that each new client would have a random port (reduce chance of cache poisoning)

Return

a tuple of a Future Stream which will handle sending and receiving messages, and a handle which can be used to send messages into the stream.

pub fn with_timeout( name_server: SocketAddr, timeout: Duration ) -> UdpClientConnect<S, NoopMessageFinalizer>

Constructs a new UdpStream for a client to the specified SocketAddr.

Arguments

• name_server - the IP and Port of the DNS server to connect to
• timeout - connection timeout

pub fn with_bind_addr_and_timeout( name_server: SocketAddr, bind_addr: Option<SocketAddr>, timeout: Duration ) -> UdpClientConnect<S, NoopMessageFinalizer>

Constructs a new UdpStream for a client to the specified SocketAddr.

Arguments

• name_server - the IP and Port of the DNS server to connect to
• bind_addr - the IP and port to connect from
• timeout - connection timeout

impl<S: UdpSocket + Send + 'static, MF: MessageFinalizer> UdpClientStream<S, MF>

pub fn with_timeout_and_signer( name_server: SocketAddr, timeout: Duration, signer: Option<Arc<MF>> ) -> UdpClientConnect<S, MF>

Constructs a new UdpStream for a client to the specified SocketAddr.

Arguments

• name_server - the IP and Port of the DNS server to connect to
• timeout - connection timeout

pub fn with_timeout_and_signer_and_bind_addr( name_server: SocketAddr, timeout: Duration, signer: Option<Arc<MF>>, bind_addr: Option<SocketAddr> ) -> UdpClientConnect<S, MF>

Constructs a new UdpStream for a client to the specified SocketAddr.

Arguments

• name_server - the IP and Port of the DNS server to connect to
• timeout - connection timeout
• bind_addr - the IP address and port to connect from

impl<S: DnsUdpSocket + Send, MF: MessageFinalizer> UdpClientStream<S, MF>

pub fn with_creator( name_server: SocketAddr, signer: Option<Arc<MF>>, timeout: Duration, creator: Arc<dyn Send + Sync + Fn(SocketAddr, SocketAddr) -> Pin<Box<dyn Send + Future<Output = Result<S, Error>>>>> ) -> UdpClientConnect<S, MF>

Constructs a new UdpStream for a client to the specified SocketAddr.

Arguments

• name_server - the IP and Port of the DNS server to connect to
• signer - optional final amendment
• timeout - connection timeout
• creator - function that binds a local address to a newly created UDP socket

Trait Implementations

impl<S: Send, MF: MessageFinalizer> Display for UdpClientStream<S, MF>

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

Formats the value using the given formatter.

impl<S: DnsUdpSocket + Send + 'static, MF: MessageFinalizer> DnsRequestSender for UdpClientStream<S, MF>

fn send_message(&mut self, message: DnsRequest) -> DnsResponseStream

Send a message, and return a stream of response

fn shutdown(&mut self)

Allows the upstream user to inform the underling stream that it should shutdown.

fn is_shutdown(&self) -> bool

Returns true if the stream has been shutdown with shutdown

impl<S: Send, MF: MessageFinalizer> Stream for UdpClientStream<S, MF>

type Item = Result<(), ProtoError>

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.