Package | Description |
---|---|
io.netty.channel |
The core channel API which is asynchronous and event-driven abstraction of
various transports such as a
NIO Channel.
|
io.netty.channel.socket |
Abstract TCP and UDP socket interfaces which extend the core channel API.
|
io.netty.handler.codec |
Extensible decoder and its common implementations which deal with the
packet fragmentation and reassembly issue found in a stream-based transport
such as TCP/IP.
|
io.netty.handler.codec.dns |
DNS codec.
|
io.netty.resolver.dns |
An alternative to Java's built-in domain name lookup mechanism that resolves a domain name asynchronously,
which supports the queries of an arbitrary DNS record type as well.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultAddressedEnvelope<M,A extends java.net.SocketAddress>
The default
AddressedEnvelope implementation. |
Modifier and Type | Method and Description |
---|---|
AddressedEnvelope<M,A> |
AddressedEnvelope.retain() |
AddressedEnvelope<M,A> |
DefaultAddressedEnvelope.retain() |
AddressedEnvelope<M,A> |
AddressedEnvelope.retain(int increment) |
AddressedEnvelope<M,A> |
DefaultAddressedEnvelope.retain(int increment) |
AddressedEnvelope<M,A> |
AddressedEnvelope.touch() |
AddressedEnvelope<M,A> |
DefaultAddressedEnvelope.touch() |
AddressedEnvelope<M,A> |
AddressedEnvelope.touch(java.lang.Object hint) |
AddressedEnvelope<M,A> |
DefaultAddressedEnvelope.touch(java.lang.Object hint) |
Modifier and Type | Class and Description |
---|---|
class |
DatagramPacket
The message container that is used for
DatagramChannel to communicate with the remote peer. |
Modifier and Type | Method and Description |
---|---|
protected void |
DatagramPacketEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<M,java.net.InetSocketAddress> msg,
java.util.List<java.lang.Object> out) |
Modifier and Type | Class and Description |
---|---|
class |
DatagramDnsQuery
A
DnsQuery implementation for UDP/IP. |
class |
DatagramDnsResponse
A
DnsResponse implementation for UDP/IP. |
Modifier and Type | Method and Description |
---|---|
protected ByteBuf |
DatagramDnsQueryEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected ByteBuf |
DatagramDnsResponseEncoder.allocateBuffer(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> msg)
Allocate a
ByteBuf which will be used for constructing a datagram packet. |
protected void |
DatagramDnsQueryEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsQuery,java.net.InetSocketAddress> in,
java.util.List<java.lang.Object> out) |
protected void |
DatagramDnsResponseEncoder.encode(ChannelHandlerContext ctx,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> in,
java.util.List<java.lang.Object> out) |
Modifier and Type | Field and Description |
---|---|
private Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsQueryContext.promise |
private java.util.Set<Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>>> |
DnsNameResolverContext.queriesInProgress |
private static FutureListener<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolverContext.RELEASE_RESPONSE |
Modifier and Type | Method and Description |
---|---|
private static Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.cast(Promise<?> promise) |
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question)
Sends a DNS query with the specified question.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question,
java.lang.Iterable<DnsRecord> additionals)
Sends a DNS query with the specified question with additional records.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question)
Sends a DNS query with the specified question using the specified name server list.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
java.lang.Iterable<DnsRecord> additionals)
Sends a DNS query with the specified question with additional records using the specified name server list.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
java.lang.Iterable<DnsRecord> additionals,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question with additional records using the specified name server list.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question using the specified name server list.
|
(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query0(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
ChannelPromise writePromise,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) |
(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query0(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
DnsQueryContext.finish(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope) |
private boolean |
DnsNameResolverContext.handleRedirect(DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise)
Handles a redirect answer if needed and returns
true if a redirect query has been made. |
(package private) void |
DnsNameResolverContext.onResponse(DnsServerAddressStream nameServerAddrStream,
int nameServerAddrStreamIndex,
DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private void |
DnsNameResolverContext.onResponseAorAAAA(DnsRecordType qType,
DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private void |
DnsNameResolverContext.onResponseCNAME(DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> envelope,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private void |
DnsNameResolverContext.onResponseCNAME(DnsQuestion question,
AddressedEnvelope<DnsResponse,java.net.InetSocketAddress> response,
java.util.Map<java.lang.String,java.lang.String> cnames,
DnsQueryLifecycleObserver queryLifecycleObserver,
Promise<T> promise) |
private void |
DnsQueryContext.setSuccess(AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress> envelope) |
Modifier and Type | Method and Description |
---|---|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(DnsQuestion question,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
java.lang.Iterable<DnsRecord> additionals,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question with additional records using the specified name server list.
|
Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise)
Sends a DNS query with the specified question using the specified name server list.
|
(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query0(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
ChannelPromise writePromise,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) |
(package private) Future<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> |
DnsNameResolver.query0(java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
Promise<AddressedEnvelope<? extends DnsResponse,java.net.InetSocketAddress>> promise) |
Constructor and Description |
---|
DnsQueryContext(DnsNameResolver parent,
java.net.InetSocketAddress nameServerAddr,
DnsQuestion question,
DnsRecord[] additionals,
Promise<AddressedEnvelope<DnsResponse,java.net.InetSocketAddress>> promise) |