Top Description Inners Fields Constructors Methods
reactor.netty.transport

pack-priv Class AddressResolverGroupMetrics<T extends java.net.SocketAddress>

extends AddressResolverGroup<T extends SocketAddress>
Class Inheritance
Known Direct Subclasses
reactor.netty.transport.MicrometerAddressResolverGroupMetrics
Imports
io.netty.resolver.AddressResolver, .AddressResolverGroup, io.netty.util.concurrent.EventExecutor, .Future, .Promise, reactor.netty.channel.ChannelMetricsRecorder, reactor.netty.internal.util.MapUtils, reactor.util.Logger, .Loggers, java.net.SocketAddress, java.time.Duration, java.util.List, .Objects, java.util.concurrent.ConcurrentHashMap, .ConcurrentMap, java.util.function.Supplier
Metrics related to name resolution.
Author
Violeta Georgieva

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
AddressResolverGroupMetrics.DelegatingAddressResolver<T extends SocketAddress>

Field Summary

Modifier and TypeField and Description
pack-priv static final ConcurrentMap<Integer, AddressResolverGroupMetrics<?>>
cache

private static final Logger
log

pack-priv final ChannelMetricsRecorder
recorder

pack-priv final AddressResolverGroup<T>
resolverGroup

Constructor Summary

AccessConstructor and Description
pack-priv
AddressResolverGroupMetrics(AddressResolverGroup<T> resolverGroup, ChannelMetricsRecorder recorder)

Method Summary

Modifier and TypeMethod and Description
pack-priv static AddressResolverGroupMetrics<?>
getOrCreate(AddressResolverGroup<?> resolverGroup, ChannelMetricsRecorder recorder)

protected AddressResolver<T>
newResolver(EventExecutor executor)

Implements abstract io.netty.resolver.AddressResolverGroup.newResolver.

Invoked by getResolver(EventExecutor) to create a new AddressResolver.
Inherited from io.netty.resolver.AddressResolverGroup:
closegetResolver

Field Detail

cacheback to summary
pack-priv static final ConcurrentMap<Integer, AddressResolverGroupMetrics<?>> cache
logback to summary
private static final Logger log
recorderback to summary
pack-priv final ChannelMetricsRecorder recorder
resolverGroupback to summary
pack-priv final AddressResolverGroup<T> resolverGroup

Constructor Detail

AddressResolverGroupMetricsback to summary
pack-priv AddressResolverGroupMetrics(AddressResolverGroup<T> resolverGroup, ChannelMetricsRecorder recorder)

Method Detail

getOrCreateback to summary
pack-priv static AddressResolverGroupMetrics<?> getOrCreate(AddressResolverGroup<?> resolverGroup, ChannelMetricsRecorder recorder)
newResolverback to summary
protected AddressResolver<T> newResolver(EventExecutor executor)

Implements abstract io.netty.resolver.AddressResolverGroup.newResolver.

Doc from io.netty.resolver.AddressResolverGroup.newResolver.

Invoked by getResolver(EventExecutor) to create a new AddressResolver.

Annotations
@Override
reactor.netty.transport back to summary

pack-priv Class AddressResolverGroupMetrics.DelegatingAddressResolver<T extends java.net.SocketAddress>

extends Object
implements AddressResolver<T extends SocketAddress>
Class Inheritance
  • java.lang.Object
  • reactor.netty.transport.AddressResolverGroupMetrics.DelegatingAddressResolver
All Implemented Interfaces
io.netty.resolver.AddressResolver, java.io.Closeable, java.lang.AutoCloseable
Known Direct Subclasses
reactor.netty.transport.MicrometerAddressResolverGroupMetrics.MicrometerDelegatingAddressResolver

Field Summary

Modifier and TypeField and Description
pack-priv final ChannelMetricsRecorder
recorder

pack-priv final AddressResolver<T>
resolver

Constructor Summary

AccessConstructor and Description
pack-priv
DelegatingAddressResolver(ChannelMetricsRecorder recorder, AddressResolver<T> resolver)

Method Summary

Modifier and TypeMethod and Description
public void
close()

Implements io.netty.resolver.AddressResolver.close.

Closes all the resources allocated and used by this resolver.
public boolean
isResolved(SocketAddress address)

Implements io.netty.resolver.AddressResolver.isResolved.

Returns true if and only if the specified address has been resolved.
public boolean
isSupported(SocketAddress address)

Implements io.netty.resolver.AddressResolver.isSupported.

Returns true if and only if the specified address is supported by this resolved.
pack-priv void
record(long resolveTimeStart, String status, SocketAddress remoteAddress)

public Future<T>
resolve(SocketAddress
the address to resolve
address)

Implements io.netty.resolver.AddressResolver.resolve.

Resolves the specified address.
public Future<T>
resolve(SocketAddress
the address to resolve
address, Promise<T>
the Promise which will be fulfilled when the name resolution is finished
promise)

Implements io.netty.resolver.AddressResolver.resolve.

Resolves the specified address.
public Future<List<T>>
resolveAll(SocketAddress
the address to resolve
address)

Implements io.netty.resolver.AddressResolver.resolveAll.

Resolves the specified address.
public Future<List<T>>
resolveAll(SocketAddress
the address to resolve
address, Promise<List<T>>
the Promise which will be fulfilled when the name resolution is finished
promise)

Implements io.netty.resolver.AddressResolver.resolveAll.

Resolves the specified address.
pack-priv Future<List<T>>
resolveAllInternal(SocketAddress address, Supplier<Future<List<T>>> resolver)

pack-priv Future<T>
resolveInternal(SocketAddress address, Supplier<Future<T>> resolver)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

recorderback to summary
pack-priv final ChannelMetricsRecorder recorder
resolverback to summary
pack-priv final AddressResolver<T> resolver

Constructor Detail

DelegatingAddressResolverback to summary
pack-priv DelegatingAddressResolver(ChannelMetricsRecorder recorder, AddressResolver<T> resolver)

Method Detail

closeback to summary
public void close()

Implements io.netty.resolver.AddressResolver.close.

Doc from io.netty.resolver.AddressResolver.close.

Closes all the resources allocated and used by this resolver.

Annotations
@Override
isResolvedback to summary
public boolean isResolved(SocketAddress address)

Implements io.netty.resolver.AddressResolver.isResolved.

Doc from io.netty.resolver.AddressResolver.isResolved.

Returns true if and only if the specified address has been resolved.

Annotations
@Override
isSupportedback to summary
public boolean isSupported(SocketAddress address)

Implements io.netty.resolver.AddressResolver.isSupported.

Doc from io.netty.resolver.AddressResolver.isSupported.

Returns true if and only if the specified address is supported by this resolved.

Annotations
@Override
recordback to summary
pack-priv void record(long resolveTimeStart, String status, SocketAddress remoteAddress)
resolveback to summary
public Future<T> resolve(SocketAddress address)

Implements io.netty.resolver.AddressResolver.resolve.

Doc from io.netty.resolver.AddressResolver.resolve.

Resolves the specified address. If the specified address is resolved already, this method does nothing but returning the original address.

Parameters
address:SocketAddress

the address to resolve

Returns:Future<T>

the SocketAddress as the result of the resolution

Annotations
@Override
resolveback to summary
public Future<T> resolve(SocketAddress address, Promise<T> promise)

Implements io.netty.resolver.AddressResolver.resolve.

Doc from io.netty.resolver.AddressResolver.resolve.

Resolves the specified address. If the specified address is resolved already, this method does nothing but returning the original address.

Parameters
address:SocketAddress

the address to resolve

promise:Promise<T>

the Promise which will be fulfilled when the name resolution is finished

Returns:Future<T>

the SocketAddress as the result of the resolution

Annotations
@Override
resolveAllback to summary
public Future<List<T>> resolveAll(SocketAddress address)

Implements io.netty.resolver.AddressResolver.resolveAll.

Doc from io.netty.resolver.AddressResolver.resolveAll.

Resolves the specified address. If the specified address is resolved already, this method does nothing but returning the original address.

Parameters
address:SocketAddress

the address to resolve

Returns:Future<List<T>>

the list of the SocketAddresses as the result of the resolution

Annotations
@Override
resolveAllback to summary
public Future<List<T>> resolveAll(SocketAddress address, Promise<List<T>> promise)

Implements io.netty.resolver.AddressResolver.resolveAll.

Doc from io.netty.resolver.AddressResolver.resolveAll.

Resolves the specified address. If the specified address is resolved already, this method does nothing but returning the original address.

Parameters
address:SocketAddress

the address to resolve

promise:Promise<List<T>>

the Promise which will be fulfilled when the name resolution is finished

Returns:Future<List<T>>

the list of the SocketAddresses as the result of the resolution

Annotations
@Override
resolveAllInternalback to summary
pack-priv Future<List<T>> resolveAllInternal(SocketAddress address, Supplier<Future<List<T>>> resolver)
resolveInternalback to summary
pack-priv Future<T> resolveInternal(SocketAddress address, Supplier<Future<T>> resolver)