Top Description Inners Fields Constructors Methods
reactor.netty.transport

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

extends AddressResolverGroupMetrics<T extends SocketAddress>
Class Inheritance
Imports
io.micrometer.common.KeyValues, io.micrometer.core.instrument.Timer, io.micrometer.observation.Observation, io.netty.resolver.AddressResolver, .AddressResolverGroup, io.netty.util.concurrent.EventExecutor, .Future, reactor.netty.channel.MicrometerChannelMetricsRecorder, reactor.netty.internal.util.MapUtils, reactor.netty.observability.ReactorNettyHandlerContext, reactor.util.context.ContextView, java.net.InetSocketAddress, .SocketAddress, java.util.List, .Objects, java.util.concurrent.ConcurrentHashMap, .ConcurrentMap, java.util.function.Supplier
Metrics related to name resolution.
Authors
Marcin Grzejszczak, Violeta Georgieva
Since
1.1.0

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
MicrometerAddressResolverGroupMetrics.FutureHandlerContext

pack-priv static class
MicrometerAddressResolverGroupMetrics.MicrometerDelegatingAddressResolver<T extends SocketAddress>

Field Summary

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

Hides reactor.netty.transport.AddressResolverGroupMetrics.cache.

Inherited from reactor.netty.transport.AddressResolverGroupMetrics:
recorderresolverGroup

Constructor Summary

AccessConstructor and Description
pack-priv
MicrometerAddressResolverGroupMetrics(AddressResolverGroup<T> resolverGroup, MicrometerChannelMetricsRecorder recorder)

Method Summary

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

protected AddressResolver<T>
newResolver(EventExecutor executor)

Overrides reactor.netty.transport.AddressResolverGroupMetrics.newResolver.

Invoked by getResolver(EventExecutor) to create a new AddressResolver.
Inherited from reactor.netty.transport.AddressResolverGroupMetrics:
getOrCreate

Field Detail

cacheback to summary
pack-priv static final ConcurrentMap<Integer, MicrometerAddressResolverGroupMetrics<?>> cache

Hides reactor.netty.transport.AddressResolverGroupMetrics.cache.

Constructor Detail

MicrometerAddressResolverGroupMetricsback to summary
pack-priv MicrometerAddressResolverGroupMetrics(AddressResolverGroup<T> resolverGroup, MicrometerChannelMetricsRecorder recorder)

Method Detail

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

Overrides reactor.netty.transport.AddressResolverGroupMetrics.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 final Class MicrometerAddressResolverGroupMetrics.FutureHandlerContext

extends Context
implements ReactorNettyHandlerContext, Supplier<Observation.Context>
Class Inheritance
All Implemented Interfaces
java.util.function.Supplier, reactor.netty.observability.ReactorNettyHandlerContext

Field Summary

Modifier and TypeField and Description
pack-priv static final String
CONTEXTUAL_NAME

pack-priv final String
netPeerName

pack-priv final String
netPeerPort

pack-priv final MicrometerChannelMetricsRecorder
recorder

pack-priv String
status

pack-priv static final String
TYPE

Constructor Summary

AccessConstructor and Description
pack-priv
FutureHandlerContext(MicrometerChannelMetricsRecorder recorder, SocketAddress remoteAddress)

Method Summary

Modifier and TypeMethod and Description
public Observation.Context
get()

Implements java.util.function.Supplier.get.

Gets a result.
public String
getContextualName()

Overrides io.micrometer.observation.Observation.Context.getContextualName.

Implements io.micrometer.observation.Observation.ContextView.getContextualName.

Returns the contextual name.
public KeyValues
getHighCardinalityKeyValues()

Overrides io.micrometer.observation.Observation.Context.getHighCardinalityKeyValues.

Implements io.micrometer.observation.Observation.ContextView.getHighCardinalityKeyValues.

Returns high cardinality key values.
public KeyValues
getLowCardinalityKeyValues()

Overrides io.micrometer.observation.Observation.Context.getLowCardinalityKeyValues.

Implements io.micrometer.observation.Observation.ContextView.getLowCardinalityKeyValues.

Returns low cardinality key values.
public io.micrometer.core.instrument.Timer
getTimer()

Implements reactor.netty.observability.ReactorNettyHandlerContext.getTimer.

Obtain the timer associated to this reactor netty context.
Inherited from io.micrometer.observation.Observation.Context:
addHighCardinalityKeyValueaddHighCardinalityKeyValuesaddLowCardinalityKeyValueaddLowCardinalityKeyValuesclearcomputeIfAbsentcontainsKeygetgetAllKeyValuesgetErrorgetHighCardinalityKeyValuegetLowCardinalityKeyValuegetNamegetOrDefaultgetParentObservationgetRequiredputremoveremoveHighCardinalityKeyValueremoveHighCardinalityKeyValuesremoveLowCardinalityKeyValueremoveLowCardinalityKeyValuessetContextualNamesetErrorsetNamesetParentObservationtoString

Field Detail

CONTEXTUAL_NAMEback to summary
pack-priv static final String CONTEXTUAL_NAME
netPeerNameback to summary
pack-priv final String netPeerName
netPeerPortback to summary
pack-priv final String netPeerPort
recorderback to summary
pack-priv final MicrometerChannelMetricsRecorder recorder
statusback to summary
pack-priv String status
TYPEback to summary
pack-priv static final String TYPE

Constructor Detail

FutureHandlerContextback to summary
pack-priv FutureHandlerContext(MicrometerChannelMetricsRecorder recorder, SocketAddress remoteAddress)

Method Detail

getback to summary
public Observation.Context get()

Implements java.util.function.Supplier.get.

Doc from java.util.function.Supplier.get.

Gets a result.

Returns:Observation.Context

a result

Annotations
@Override
getContextualNameback to summary
public String getContextualName()

Overrides io.micrometer.observation.Observation.Context.getContextualName.

Implements io.micrometer.observation.Observation.ContextView.getContextualName.

Doc from io.micrometer.observation.Observation.Context.getContextualName.

Returns the contextual name. The name that makes sense within the current context (e.g. name derived from HTTP request).

Returns:String

contextual name

Annotations
@Override
getHighCardinalityKeyValuesback to summary
public KeyValues getHighCardinalityKeyValues()

Overrides io.micrometer.observation.Observation.Context.getHighCardinalityKeyValues.

Implements io.micrometer.observation.Observation.ContextView.getHighCardinalityKeyValues.

Doc from io.micrometer.observation.Observation.ContextView.getHighCardinalityKeyValues.

Returns high cardinality key values.

Returns:KeyValues

high cardinality key values

Annotations
@Override
getLowCardinalityKeyValuesback to summary
public KeyValues getLowCardinalityKeyValues()

Overrides io.micrometer.observation.Observation.Context.getLowCardinalityKeyValues.

Implements io.micrometer.observation.Observation.ContextView.getLowCardinalityKeyValues.

Doc from io.micrometer.observation.Observation.ContextView.getLowCardinalityKeyValues.

Returns low cardinality key values.

Returns:KeyValues

low cardinality key values

Annotations
@Override
getTimerback to summary
public io.micrometer.core.instrument.Timer getTimer()

Implements reactor.netty.observability.ReactorNettyHandlerContext.getTimer.

Doc from reactor.netty.observability.ReactorNettyHandlerContext.getTimer.

Obtain the timer associated to this reactor netty context.

Returns:io.micrometer.core.instrument.Timer

the current reactor netty handler context timer

Annotations
@Override
reactor.netty.transport back to summary

pack-priv final Class MicrometerAddressResolverGroupMetrics.MicrometerDelegatingAddressResolver<T extends java.net.SocketAddress>

extends AddressResolverGroupMetrics.DelegatingAddressResolver<T extends SocketAddress>
Class Inheritance

Field Summary

Modifier and TypeField and Description
pack-priv final String
name

Inherited from reactor.netty.transport.AddressResolverGroupMetrics.DelegatingAddressResolver:
recorderresolver

Constructor Summary

AccessConstructor and Description
pack-priv
MicrometerDelegatingAddressResolver(MicrometerChannelMetricsRecorder recorder, AddressResolver<T> resolver)

Method Summary

Modifier and TypeMethod and Description
pack-priv Future<List<T>>
resolveAll(SocketAddress address, ContextView contextView)

pack-priv Future<List<T>>
resolveAllInternal(SocketAddress address, Supplier<Future<List<T>>> resolver, ContextView contextView)

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

Overrides reactor.netty.transport.AddressResolverGroupMetrics.DelegatingAddressResolver.resolveInternal.

Inherited from reactor.netty.transport.AddressResolverGroupMetrics.DelegatingAddressResolver:
closeisResolvedisSupportedrecordresolveresolveresolveAllresolveAllresolveAllInternal

Field Detail

nameback to summary
pack-priv final String name

Constructor Detail

MicrometerDelegatingAddressResolverback to summary
pack-priv MicrometerDelegatingAddressResolver(MicrometerChannelMetricsRecorder recorder, AddressResolver<T> resolver)

Method Detail

resolveAllback to summary
pack-priv Future<List<T>> resolveAll(SocketAddress address, ContextView contextView)
resolveAllInternalback to summary
pack-priv Future<List<T>> resolveAllInternal(SocketAddress address, Supplier<Future<List<T>>> resolver, ContextView contextView)
resolveInternalback to summary
pack-priv Future<T> resolveInternal(SocketAddress address, Supplier<Future<T>> resolver)

Overrides reactor.netty.transport.AddressResolverGroupMetrics.DelegatingAddressResolver.resolveInternal.

Annotations
@Override