- AbortedException - Exception in reactor.netty.channel
-
An exception marking prematurely or unexpectedly closed inbound.
- AbortedException(String) - Constructor for exception reactor.netty.channel.AbortedException
-
- AbortedException(Throwable) - Constructor for exception reactor.netty.channel.AbortedException
-
- AbstractChannelMetricsHandler - Class in reactor.netty.channel
-
- AbstractChannelMetricsHandler(SocketAddress, boolean) - Constructor for class reactor.netty.channel.AbstractChannelMetricsHandler
-
- AbstractHttpMessageLogFactory - Class in reactor.netty.http.logging
-
An abstract factory for generating one and the same type of log message
no matter the log level that will be used.
- AbstractHttpMessageLogFactory() - Constructor for class reactor.netty.http.logging.AbstractHttpMessageLogFactory
-
- AbstractProtocolSslContextSpec<T extends AbstractProtocolSslContextSpec<T>> - Class in reactor.netty.tcp
-
SslContext builder that provides, specific for protocol, default configuration.
- AbstractProtocolSslContextSpec(SslContextBuilder) - Constructor for class reactor.netty.tcp.AbstractProtocolSslContextSpec
-
- accept(Throwable) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- ACCESS_LOG_ENABLED - Static variable in class reactor.netty.ReactorNetty
-
Specifies whether the Http Server access log will be enabled.
- accessDateTime() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the date-time of the moment when the request was received.
- accessLog(boolean) - Method in class reactor.netty.http.server.HttpServer
-
Enable or disable the access log.
- accessLog(boolean, AccessLogFactory) - Method in class reactor.netty.http.server.HttpServer
-
- accessLog(Function<AccessLogArgProvider, AccessLog>) - Method in class reactor.netty.http.server.HttpServer
-
- AccessLog - Class in reactor.netty.http.server.logging
-
Log the http access information into a Logger named reactor.netty.http.server.AccessLog
at INFO level.
- AccessLogArgProvider - Interface in reactor.netty.http.server.logging
-
A provider of the args required for access log.
- AccessLogFactory - Interface in reactor.netty.http.server.logging
-
- AccessLogHandler - Static variable in interface reactor.netty.NettyPipeline
-
- AccessLogHandlerFactory - Enum in reactor.netty.http.server.logging
-
Use to create an access-log handler.
- acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in interface reactor.netty.resources.ConnectionProvider
-
Return an existing or new
Connection
on subscribe.
- acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpResources
-
- acquireCount() - Method in interface reactor.netty.resources.ConnectionProvider.ConnectionMetadata
-
Returns the number of times the connection has been acquired from the pool.
- ACQUIRED - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection has been reused / acquired
(keep-alive or pooling)
- acquiredSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Measure the current number of resources that have been successfully
acquired and are in active use.
- ACTIVE_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The number of the connections that have been successfully acquired and are in active use.
- ACTIVE_DIRECT_MEMORY - Static variable in class reactor.netty.Metrics
-
The actual bytes consumed by in-use buffers allocated from direct buffer pools.
- ACTIVE_HEAP_MEMORY - Static variable in class reactor.netty.Metrics
-
The actual bytes consumed by in-use buffers allocated from heap buffer pools.
- ACTIVE_STREAMS - Static variable in class reactor.netty.Metrics
-
The number of the active HTTP/2 streams.
- addCookie(Cookie) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Add an outbound cookie.
- addCookie(Cookie) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Adds an outbound cookie.
- addHandler(ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandler(String, ChannelHandler) - Method in class reactor.netty.http.HttpOperations
-
- addHandlerConfigurator(SslProvider, Consumer<? super SslHandler>) - Static method in class reactor.netty.tcp.SslProvider
-
Creates a new
SslProvider
with a prepending handler
configurator callback to inject default settings to an existing provider
configuration.
- addHandlerFirst(ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandlerFirst(String, ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandlerLast(ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHandlerLast(String, ChannelHandler) - Method in interface reactor.netty.Connection
-
- addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Add an outbound http header, appending the value if the header is already set.
- addHeader(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Adds an outbound HTTP header, appending the value if the header already exist.
- addMetricsHandler(Channel, ChannelMetricsRecorder, SocketAddress, boolean) - Static method in class reactor.netty.channel.ChannelOperations
-
- addProxyHandler(Channel) - Method in class reactor.netty.transport.ProxyProvider
-
- addReactiveBridge(Channel, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.ChannelOperations
-
- address() - Method in interface reactor.netty.DisposableChannel
-
When on the server, returns the bind address,
when on the client, returns the remote address.
- address() - Method in interface reactor.netty.DisposableServer
-
- address(InetSocketAddress) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
-
The address to connect to.
- address(Supplier<? extends InetSocketAddress>) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
-
The supplier for the address to connect to.
- ADDRESS_RESOLVER - Static variable in class reactor.netty.Metrics
-
Time spent for resolving the address.
- addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
-
- AddressUtils - Class in reactor.netty.transport
-
Internal class that creates unresolved or resolved InetSocketAddress instances
Numeric IPv4 and IPv6 addresses will be detected and parsed by using Netty's
NetUtil.createByteArrayFromIpAddressString(java.lang.String)
utility method and the
InetSocketAddress instances will be created in a way that these instances are resolved
initially.
- addSniMapping(String, Consumer<? super SslProvider.SslContextSpec>) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Adds a mapping for the given domain name to an
SslProvider
builder.
- addSniMappings(Map<String, Consumer<? super SslProvider.SslContextSpec>>) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Adds the provided mappings of domain names to
SslProvider
builders to the existing mappings.
- addSslHandler(Channel, SocketAddress, boolean) - Method in class reactor.netty.tcp.SslProvider
-
- AdvancedByteBufFormat - Enum in reactor.netty.transport.logging
-
- afterInboundComplete() - Method in class reactor.netty.channel.ChannelOperations
-
React after inbound completion (last packet).
- afterMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
-
- aggregate() - Method in class reactor.netty.ByteBufFlux
-
Aggregate subsequent byte buffers into a single buffer.
- aggregateFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Turn this
WebsocketInbound
into aggregating mode which will only produce
fully formed frame that have been received fragmented.
- aggregateFrames(int) - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Turn this
WebsocketInbound
into aggregating mode which will only produce
fully formed frame that have been received fragmented.
- allCookieHeaders() - Method in class reactor.netty.http.Cookies
-
- allCookies() - Method in interface reactor.netty.http.server.HttpServerInfos
-
Returns resolved HTTP cookies.
- alloc() - Method in class reactor.netty.channel.ChannelOperations
-
- alloc() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- alloc() - Method in interface reactor.netty.NettyOutbound
-
- allocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Measure the current number of allocated resources in the pool, acquired
or idle.
- allocationStrategy(ConnectionProvider.AllocationStrategy<?>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
- allocationStrategy() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
-
- allocationTimestamp() - Method in interface reactor.netty.resources.ConnectionProvider.ConnectionMetadata
-
Returns a timestamp that denotes the order in which the connection was created/allocated, to millisecond
precision.
- allowDuplicateContentLengths - Variable in class reactor.netty.http.HttpDecoderSpec
-
- allowDuplicateContentLengths(boolean) - Method in class reactor.netty.http.HttpDecoderSpec
-
Configure whether to allow duplicate Content-Length
headers.
- allowDuplicateContentLengths() - Method in class reactor.netty.http.HttpDecoderSpec
-
Return the configuration whether to allow duplicate Content-Length
headers.
- as(Class<T>) - Method in class reactor.netty.channel.ChannelOperations
-
- as(Class<T>) - Method in interface reactor.netty.Connection
-
Return an existing
Connection
that must match the given type wrapper or
null.
- asByteArray() - Method in class reactor.netty.ByteBufFlux
-
Convert to a byte[] inbound
Flux
.
- asByteArray() - Method in class reactor.netty.ByteBufMono
-
- asByteBuffer() - Method in class reactor.netty.ByteBufFlux
-
- asByteBuffer() - Method in class reactor.netty.ByteBufMono
-
- asDebugLogMessage(Object) - Method in class reactor.netty.channel.ChannelOperations
-
Transforms the object to a string for debug logs.
- asDebugLogMessage(Object) - Method in class reactor.netty.http.HttpOperations
-
- asInputStream() - Method in class reactor.netty.ByteBufFlux
-
- asInputStream() - Method in class reactor.netty.ByteBufMono
-
- asLongText() - Method in class reactor.netty.channel.ChannelOperations
-
- asLongText() - Method in interface reactor.netty.ChannelOperationsId
-
The long string is a combination of the id of the underlying connection, local and remote addresses,
and in case of HTTP, the serial number of the request received on that connection.
- asShortText() - Method in class reactor.netty.channel.ChannelOperations
-
- asShortText() - Method in interface reactor.netty.ChannelOperationsId
-
The short string is a combination of the id of the underlying connection
and in case of HTTP, the serial number of the request received on that connection.
- asString() - Method in class reactor.netty.ByteBufFlux
-
- asString(Charset) - Method in class reactor.netty.ByteBufFlux
-
- asString() - Method in class reactor.netty.ByteBufMono
-
- asString(Charset) - Method in class reactor.netty.ByteBufMono
-
- attr(String, String) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP Form attribute.
- attr(AttributeKey<A>, A) - Method in class reactor.netty.tcp.TcpClient
-
- attr(AttributeKey<A>, A) - Method in class reactor.netty.transport.Transport
-
Update the given attribute key or remove it if the value is null.
- attr(AttributeKey<A>, A) - Method in class reactor.netty.udp.UdpClient
-
- attr(AttributeKey<A>, A) - Method in class reactor.netty.udp.UdpServer
-
- attributes() - Method in class reactor.netty.transport.TransportConfig
-
Return the read-only default channel attributes.
- cachedCookies - Variable in class reactor.netty.http.Cookies
-
- cacheMaxTimeToLive() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns the configured max time to live of the cached DNS resource records.
- cacheMaxTimeToLive(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets the max time to live of the cached DNS resource records (resolution: seconds).
- cacheMinTimeToLive() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns the configured min time to live of the cached DNS resource records.
- cacheMinTimeToLive(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets the min time to live of the cached DNS resource records (resolution: seconds).
- cacheNegativeTimeToLive() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns the configured time to live of the cache for the failed DNS queries.
- cacheNegativeTimeToLive(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets the time to live of the cache for the failed DNS queries (resolution: seconds).
- calculateInitialCapacity(int) - Static method in class reactor.netty.internal.util.MapUtils
-
This is a temporary workaround for Java 8 issue https://bugs.openjdk.org/browse/JDK-8186958.
- channel() - Method in class reactor.netty.channel.ChannelOperations
-
- channel() - Method in interface reactor.netty.DisposableChannel
-
- channelActive(ChannelHandlerContext) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- ChannelBindException - Exception in reactor.netty
-
Represents a failing attempt to bind a local socket address.
- ChannelBindException(String, int, Throwable) - Constructor for exception reactor.netty.ChannelBindException
-
- ChannelBindException(String, Throwable) - Constructor for exception reactor.netty.ChannelBindException
-
- ChannelContextAccessor - Class in reactor.netty.contextpropagation
-
A
ContextAccessor
to enable reading values from a Netty
Channel
and
writing values to a Netty
Channel
.
- ChannelContextAccessor() - Constructor for class reactor.netty.contextpropagation.ChannelContextAccessor
-
- channelGroup(ChannelGroup) - Method in class reactor.netty.http.server.HttpServer
-
- channelGroup(ChannelGroup) - Method in class reactor.netty.tcp.TcpServer
-
- channelGroup(ChannelGroup) - Method in class reactor.netty.transport.Transport
-
Provide a
ChannelGroup
to hold all active connected channels.
- channelGroup() - Method in class reactor.netty.transport.TransportConfig
-
- channelHash() - Method in class reactor.netty.http.client.HttpClientConfig
-
- channelHash() - Method in class reactor.netty.tcp.TcpClientConfig
-
- channelHash() - Method in class reactor.netty.transport.ClientTransportConfig
-
- channelHash() - Method in class reactor.netty.transport.TransportConfig
-
- channelInactive(ChannelHandlerContext) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- channelInitializer(ConnectionObserver, SocketAddress, boolean) - Method in class reactor.netty.transport.TransportConfig
-
- ChannelMeters - Enum in reactor.netty.channel
-
Channel meters.
- ChannelMeters.ChannelMetersTags - Enum in reactor.netty.channel
-
- ChannelMeters.ConnectionsTotalMeterTags - Enum in reactor.netty.channel
-
- ChannelMetricsHandler - Class in reactor.netty.channel
-
- ChannelMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
-
- ChannelMetricsRecorder - Interface in reactor.netty.channel
-
Interface for recording metrics on protocol level.
- ChannelOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.channel
-
- ChannelOperations(ChannelOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.channel.ChannelOperations
-
- ChannelOperations(Connection, ConnectionObserver) - Constructor for class reactor.netty.channel.ChannelOperations
-
- ChannelOperations.OnSetup - Interface in reactor.netty.channel
-
- ChannelOperationsId - Interface in reactor.netty
-
Provides short/long string representation of the channel.
- channelOperationsProvider() - Method in class reactor.netty.http.client.HttpClientConfig
-
- channelOperationsProvider() - Method in class reactor.netty.tcp.TcpClientConfig
-
- channelOperationsProvider() - Method in class reactor.netty.tcp.TcpServerConfig
-
- channelOperationsProvider() - Method in class reactor.netty.transport.TransportConfig
-
Return the associated ChannelOperations.OnSetup
, config implementations might override this.
- channelOperationsProvider() - Method in class reactor.netty.udp.UdpClientConfig
-
- channelOperationsProvider() - Method in class reactor.netty.udp.UdpServerConfig
-
- ChannelPipelineConfigurer - Interface in reactor.netty
-
Configure the channel pipeline while initializing the channel.
- channelRead(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- channelRegistered(ChannelHandlerContext) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- channelType(boolean) - Method in class reactor.netty.transport.ClientTransportConfig
-
- channelType(boolean) - Method in class reactor.netty.transport.ServerTransportConfig
-
- channelType(boolean) - Method in class reactor.netty.transport.TransportConfig
-
Return the channel type this configuration is associated with, it can be one of the following.
- channelType(boolean) - Method in class reactor.netty.udp.UdpClientConfig
-
- channelType(boolean) - Method in class reactor.netty.udp.UdpServerConfig
-
- charset(Charset) - Method in interface reactor.netty.http.client.HttpClientForm
-
- charset(Charset) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
-
- charset() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
-
- childAttr(AttributeKey<A>, A) - Method in class reactor.netty.transport.ServerTransport
-
Injects default attribute to the future child
Channel
connections.
- childAttributes() - Method in class reactor.netty.transport.ServerTransportConfig
-
Return the read-only default channel attributes for each remote connection.
- childObserve(ConnectionObserver) - Method in class reactor.netty.transport.ServerTransport
-
- childObserver() - Method in class reactor.netty.transport.ServerTransportConfig
-
- childOption(ChannelOption<A>, A) - Method in class reactor.netty.transport.ServerTransport
-
Injects default options to the future child
Channel
connections.
- childOptions() - Method in class reactor.netty.transport.ServerTransportConfig
-
Return the read-only
ChannelOption
map for each remote connection.
- CHUNK_SIZE - Static variable in class reactor.netty.Metrics
-
The chunk size for an arena.
- chunkedTransfer(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets Transfer-Encoding header.
- ChunkedWriter - Static variable in interface reactor.netty.NettyPipeline
-
- cleanOnTerminate(boolean) - Method in interface reactor.netty.http.client.HttpClientForm
-
Should file attributes be cleaned and eventually removed from disk.
- ClientTransport<T extends ClientTransport<T,CONF>,CONF extends ClientTransportConfig<CONF>> - Class in reactor.netty.transport
-
- ClientTransport() - Constructor for class reactor.netty.transport.ClientTransport
-
- ClientTransportConfig<CONF extends TransportConfig> - Class in reactor.netty.transport
-
Encapsulate all necessary configuration for client transport.
- ClientTransportConfig(ConnectionProvider, Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.ClientTransportConfig
-
- ClientTransportConfig(ClientTransportConfig<CONF>) - Constructor for class reactor.netty.transport.ClientTransportConfig
-
- closeNotifyFlushTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL close_notify flush timeout.
- closeNotifyFlushTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL close_notify flush timeout.
- closeNotifyReadTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL close_notify read timeout.
- closeNotifyReadTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL close_notify read timeout.
- colocate(EventLoopGroup) - Static method in interface reactor.netty.resources.LoopResources
-
Create a delegating
EventLoopGroup
which reuse local event loop if already
working
inside one.
- common(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
-
- common(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
-
- comparator(Comparator<HttpRouteHandlerMetadata>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Use the provided
Comparator
to sort routes, rather than using configured order.Routes that were
already configured are also impacted by this change and will be sorted according to the comparator.You can revert
to using the declaration order by calling the
HttpServerRoutes.noComparator()
method (which is the default).
- completeOncePreferredResolved(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
If
true
, the resolver notifies the returned
Future
as
soon as all queries for the preferred address type are complete.
- compress(boolean) - Method in class reactor.netty.http.client.HttpClient
-
Specifies whether GZip compression is enabled.
- compress(BiPredicate<HttpServerRequest, HttpServerResponse>) - Method in class reactor.netty.http.server.HttpServer
-
Enable GZip response compression if the client request presents accept encoding
headers and the provided
Predicate
matches.
- compress(boolean) - Method in class reactor.netty.http.server.HttpServer
-
Specifies whether GZip response compression is enabled if the client request
presents accept encoding.
- compress(int) - Method in class reactor.netty.http.server.HttpServer
-
Enable GZip response compression if the client request presents accept encoding
headers AND the response reaches a minimum threshold.
- compress(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
Sets flag whether the websocket compression extension is enabled
if the client request presents websocket extensions headers.
- compress() - Method in interface reactor.netty.http.websocket.WebsocketSpec
-
Returns whether the websocket compression extension is enabled.
- compress() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
-
- compression(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Enables/Disables compression handling (gzip/deflate) for the underlying response.
- compressionAllowClientNoContext(boolean) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
-
Allows the server to activate client_no_context_takeover
Default to false.
- compressionAllowClientNoContext() - Method in interface reactor.netty.http.client.WebsocketClientSpec
-
Returns whether the server is allowed to activate client_no_context_takeover
.
- compressionAllowServerNoContext(boolean) - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
-
Allows the client to activate server_no_context_takeover
.
- compressionAllowServerNoContext() - Method in interface reactor.netty.http.server.WebsocketServerSpec
-
Returns whether the client is allowed to activate server_no_context_takeover
.
- CompressionHandler - Static variable in interface reactor.netty.NettyPipeline
-
- compressionPreferredClientNoContext(boolean) - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
-
Indicates if the server prefers to activate client_no_context_takeover
if client is compatible with.
- compressionPreferredClientNoContext() - Method in interface reactor.netty.http.server.WebsocketServerSpec
-
Returns whether the server prefers to activate client_no_context_takeover
.
- compressionRequestedServerNoContext(boolean) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
-
Indicates if the client needs to activate server_no_context_takeover
if the server is compatible with.
- compressionRequestedServerNoContext() - Method in interface reactor.netty.http.client.WebsocketClientSpec
-
Returns whether the client needs to activate server_no_context_takeover
.
- compressPredicate() - Method in class reactor.netty.http.server.HttpServerConfig
-
Return the configured compression predicate or null.
- computeIfAbsent(Map<K, V>, K, Function<K, V>) - Static method in class reactor.netty.internal.util.MapUtils
-
This is a temporary workaround for Java 8 specific performance issue https://bugs.openjdk.org/browse/JDK-8161372.
- configuration() - Method in class reactor.netty.transport.Transport
-
- configure(Consumer<SslContextBuilder>) - Method in class reactor.netty.tcp.AbstractProtocolSslContextSpec
-
- configure(SslHandler) - Method in class reactor.netty.tcp.SslProvider
-
- configure(Consumer<SslContextBuilder>) - Method in interface reactor.netty.tcp.SslProvider.ProtocolSslContextSpec
-
- CONFIGURED - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection is bound to a channelOperation and ready for
user interaction
- connect() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
-
- connect() - Method in class reactor.netty.incubator.quic.QuicClient
-
- connect() - Method in class reactor.netty.tcp.TcpClient
-
- connect() - Method in class reactor.netty.transport.ClientTransport
-
- connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>) - Static method in class reactor.netty.transport.TransportConnector
-
Connect a
Channel
to the remote peer.
- connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, ContextView) - Static method in class reactor.netty.transport.TransportConnector
-
Connect a
Channel
to the remote peer.
- connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, EventLoop) - Static method in class reactor.netty.transport.TransportConnector
-
Connect a
Channel
to the remote peer.
- connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, EventLoop, ContextView) - Static method in class reactor.netty.transport.TransportConnector
-
Connect a
Channel
to the remote peer.
- connect() - Method in class reactor.netty.udp.UdpClient
-
- CONNECT_TIME - Static variable in class reactor.netty.Metrics
-
Time spent for connecting to the remote address.
- CONNECTED - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection has been established and is available
- connection() - Method in class reactor.netty.channel.ChannelOperations
-
Return the delegate IO
Connection
for low-level IO access.
- Connection - Interface in reactor.netty
-
Hold contextual information for the underlying
Channel
.
- CONNECTION_PROVIDER_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the PooledConnectionProvider's metrics
registered in Micrometer's global registry.
- connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.transport.TransportConfig
-
- connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.udp.UdpClientConfig
-
- connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.udp.UdpServerConfig
-
- connectionHostAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
-
Returns the address of the host which received the request, possibly null
in case of Unix Domain Sockets.
- connectionIdAddressGenerator(QuicConnectionIdGenerator) - Method in class reactor.netty.incubator.quic.QuicServer
-
Set the QuicConnectionIdGenerator
to use.
- connectionIdAddressGenerator() - Method in class reactor.netty.incubator.quic.QuicServerConfig
-
Return the configured QuicConnectionIdGenerator
or the default.
- ConnectionInfo - Class in reactor.netty.http.server
-
Resolve information about the current connection, including the
host (server) address, the remote (client) address and the scheme.
- ConnectionInformation - Interface in reactor.netty.http.server
-
Resolve information about the connection from which an http request is received.
- connectionInformation() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the information about the current connection.
- ConnectionObserver - Interface in reactor.netty
-
Event listeners for connection lifecycle.
- connectionObserver() - Method in class reactor.netty.transport.TransportConfig
-
- ConnectionObserver.State - Interface in reactor.netty
-
- ConnectionPoolMetrics - Interface in reactor.netty.resources
-
- connectionProvider() - Method in class reactor.netty.http.client.HttpClientConfig
-
- ConnectionProvider - Interface in reactor.netty.resources
-
- connectionProvider() - Method in class reactor.netty.transport.ClientTransportConfig
-
- ConnectionProvider.AllocationStrategy<A extends ConnectionProvider.AllocationStrategy<A>> - Interface in reactor.netty.resources
-
- ConnectionProvider.Builder - Class in reactor.netty.resources
-
- ConnectionProvider.ConnectionMetadata - Interface in reactor.netty.resources
-
- ConnectionProvider.ConnectionPoolSpec<SPEC extends ConnectionProvider.ConnectionPoolSpec<SPEC>> - Class in reactor.netty.resources
-
Configuration for a connection pool.
- ConnectionProvider.HostSpecificSpec - Class in reactor.netty.resources
-
Configuration for a connection pool per remote host.
- ConnectionProvider.MeterRegistrar - Interface in reactor.netty.resources
-
A strategy to register which metrics are collected in a particular connection pool.
- connectionRemoteAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
-
Returns the address of the client that initiated the request, possibly null
in case of Unix Domain Sockets.
- CONNECTIONS_ACTIVE - Static variable in class reactor.netty.Metrics
-
The number of connections that are currently in use.
- CONNECTIONS_TOTAL - Static variable in class reactor.netty.Metrics
-
The number of all connections, whether they are active or idle.
- connectionScheme() - Method in interface reactor.netty.http.server.ConnectionInformation
-
Returns the current protocol scheme.
- connectMetricsHandler() - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- connectMetricsHandler() - Method in class reactor.netty.channel.ChannelMetricsHandler
-
- connectMetricsHandler() - Method in class reactor.netty.channel.MicrometerChannelMetricsHandler
-
- ConnectMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
-
- connectNow() - Method in class reactor.netty.incubator.quic.QuicClient
-
- connectNow(Duration) - Method in class reactor.netty.incubator.quic.QuicClient
-
- connectNow() - Method in class reactor.netty.tcp.TcpClient
-
- connectNow(Duration) - Method in class reactor.netty.tcp.TcpClient
-
- connectNow() - Method in class reactor.netty.transport.ClientTransport
-
- connectNow(Duration) - Method in class reactor.netty.transport.ClientTransport
-
- connectNow() - Method in class reactor.netty.udp.UdpClient
-
- connectNow(Duration) - Method in class reactor.netty.udp.UdpClient
-
- connectTimeoutMillis(long) - Method in interface reactor.netty.transport.ProxyProvider.Builder
-
The proxy connect timeout in millis.
- content() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
-
- contentLength() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the response content length.
- CONTEXT_CALLER_EVENTLOOP - Static variable in class reactor.netty.resources.PooledConnectionProvider
-
Context key used to propagate the caller event loop in the connection pool subscription.
- ContextAwareChannelMetricsRecorder - Class in reactor.netty.channel
-
ContextView
aware class for recording metrics on protocol level.
- ContextAwareChannelMetricsRecorder() - Constructor for class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- ContextAwareHttpClientMetricsRecorder - Class in reactor.netty.http.client
-
ContextView
aware class for collecting metrics on HTTP client level.
- ContextAwareHttpClientMetricsRecorder() - Constructor for class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- ContextAwareHttpMetricsRecorder - Class in reactor.netty.http
-
ContextView
aware class for recording metrics for HTTP protocol.
- ContextAwareHttpMetricsRecorder() - Constructor for class reactor.netty.http.ContextAwareHttpMetricsRecorder
-
- ContextAwareHttpServerMetricsRecorder - Class in reactor.netty.http.server
-
ContextView
aware class for collecting metrics on HTTP server level.
- ContextAwareHttpServerMetricsRecorder() - Constructor for class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
-
- cookie(Cookie) - Method in class reactor.netty.http.client.HttpClient
-
Apply cookies configuration.
- cookie(String, Consumer<? super Cookie>) - Method in class reactor.netty.http.client.HttpClient
-
- cookieCodec(ClientCookieEncoder) - Method in class reactor.netty.http.client.HttpClient
-
- cookieCodec(ClientCookieEncoder, ClientCookieDecoder) - Method in class reactor.netty.http.client.HttpClient
-
- cookieCodec(ServerCookieEncoder) - Method in class reactor.netty.http.server.HttpServer
-
- cookieCodec(ServerCookieEncoder, ServerCookieDecoder) - Method in class reactor.netty.http.server.HttpServer
-
- cookieDecoder() - Method in class reactor.netty.http.client.HttpClientConfig
-
- cookieDecoder() - Method in class reactor.netty.http.server.HttpServerConfig
-
- cookieEncoder() - Method in class reactor.netty.http.client.HttpClientConfig
-
- cookieEncoder() - Method in class reactor.netty.http.server.HttpServerConfig
-
- Cookies - Class in reactor.netty.http
-
Store cookies for the http channel.
- Cookies(HttpHeaders, CharSequence, boolean, CookieDecoder) - Constructor for class reactor.netty.http.Cookies
-
- cookies() - Method in interface reactor.netty.http.HttpInfos
-
Returns resolved HTTP cookies.
- cookies() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns resolved HTTP cookies.
- cookiesWhen(String, Function<? super Cookie, Mono<? extends Cookie>>) - Method in class reactor.netty.http.client.HttpClient
-
Apply cookies configuration emitted by the returned Mono before requesting.
- copy() - Method in class reactor.netty.http.client.Http2AllocationStrategy
-
- copy() - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
-
Returns a deep copy of this instance.
- create(Connection, ConnectionObserver, Object) - Method in interface reactor.netty.channel.ChannelOperations.OnSetup
-
- create() - Static method in class reactor.netty.http.client.HttpClient
-
- create(ConnectionProvider) - Static method in class reactor.netty.http.client.HttpClient
-
- create(Object) - Static method in class reactor.netty.http.logging.HttpMessageArgProviderFactory
-
- create() - Static method in class reactor.netty.http.server.HttpServer
-
- create(String, Object...) - Static method in class reactor.netty.http.server.logging.AccessLog
-
- create(Function<AccessLogArgProvider, AccessLog>) - Method in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
-
- create() - Static method in class reactor.netty.incubator.quic.QuicClient
-
- create() - Static method in class reactor.netty.incubator.quic.QuicServer
-
- create(String) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- create(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- create(String, int, boolean) - Static method in interface reactor.netty.resources.ConnectionProvider
-
- create(String) - Static method in interface reactor.netty.resources.LoopResources
-
- create(String, int, boolean) - Static method in interface reactor.netty.resources.LoopResources
-
- create(String, int, int, boolean) - Static method in interface reactor.netty.resources.LoopResources
-
- create(String, int, int, boolean, boolean) - Static method in interface reactor.netty.resources.LoopResources
-
- create() - Static method in class reactor.netty.tcp.TcpClient
-
- create(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpClient
-
- create() - Static method in class reactor.netty.tcp.TcpServer
-
- create() - Static method in class reactor.netty.udp.UdpClient
-
- create() - Static method in class reactor.netty.udp.UdpServer
-
- createDisposableAcquire(TransportConfig, ConnectionObserver, long, InstrumentedPool<T>, MonoSink<Connection>, Context) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- createDisposableAcquire(TransportConfig, ConnectionObserver, long, InstrumentedPool<T>, SocketAddress, MonoSink<Connection>, Context) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- createFilter(Predicate<AccessLogArgProvider>) - Static method in interface reactor.netty.http.server.logging.AccessLogFactory
-
Helper method to create an access log factory that selectively enables access logs.
- createFilter(Predicate<AccessLogArgProvider>, AccessLogFactory) - Static method in interface reactor.netty.http.server.logging.AccessLogFactory
-
Helper method to create an access log factory that selectively enables access logs and customizes
the format to apply.
- createInetSocketAddress(String, int, boolean) - Static method in class reactor.netty.transport.AddressUtils
-
Creates InetSocketAddress instance.
- createPool(TransportConfig, PooledConnectionProvider.PoolFactory<T>, SocketAddress, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- createPool(String, TransportConfig, PooledConnectionProvider.PoolFactory<T>, SocketAddress, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- createResolved(String, int) - Static method in class reactor.netty.transport.AddressUtils
-
Creates InetSocketAddress that is always resolved.
- createStream(BiFunction<? super QuicInbound, ? super QuicOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.incubator.quic.QuicConnection
-
Creates a bidirectional stream.
- createStream(QuicStreamType, BiFunction<? super QuicInbound, ? super QuicOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.incubator.quic.QuicConnection
-
Creates a stream.
- createUnresolved(String, int) - Static method in class reactor.netty.transport.AddressUtils
-
Creates unresolved InetSocketAddress.
- currentContext() - Method in class reactor.netty.channel.ChannelOperations
-
- currentContext() - Method in interface reactor.netty.ConnectionObserver
-
- currentContext() - Method in interface reactor.netty.http.client.HttpClientInfos
-
- currentContextView() - Method in interface reactor.netty.http.client.HttpClientInfos
-
- currentObservation(ContextView) - Static method in class reactor.netty.Metrics
-
- daemon() - Method in class reactor.netty.incubator.quic.QuicResources
-
- daemon() - Method in interface reactor.netty.resources.LoopResources
-
- daemon() - Method in class reactor.netty.tcp.TcpResources
-
- daemon() - Method in class reactor.netty.udp.UdpResources
-
- DATA_RECEIVED - Static variable in class reactor.netty.Metrics
-
Amount of the data received, in bytes.
- DATA_RECEIVED_TIME - Static variable in class reactor.netty.Metrics
-
Time spent in consuming incoming data.
- DATA_SENT - Static variable in class reactor.netty.Metrics
-
Amount of the data sent, in bytes.
- DATA_SENT_TIME - Static variable in class reactor.netty.Metrics
-
Time spent in sending outgoing data.
- dataReceivedTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- dataSentTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- debug(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
-
- debug(HttpMessageArgProvider) - Method in interface reactor.netty.http.logging.HttpMessageLogFactory
-
- decoder() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return the configured HTTP response decoder options or the default.
- decoder() - Method in class reactor.netty.http.server.HttpServerConfig
-
Return the configured HTTP request decoder options or the default.
- decoderResult() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
-
- decoderResultFunction() - Method in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
-
Returns the function that is used for sanitizing the decoding result.
- DEFAULT_ALLOW_DUPLICATE_CONTENT_LENGTHS - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_FAIL_ON_MISSING_RESPONSE - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
-
- DEFAULT_H2C_MAX_CONTENT_LENGTH - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
-
The maximum length of the content of the HTTP/2.0 clear-text upgrade request.
- DEFAULT_H2C_MAX_CONTENT_LENGTH - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
-
The maximum length of the content of the HTTP/2.0 clear-text upgrade request.
- DEFAULT_INITIAL_BUFFER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_IO_SELECT_COUNT - Static variable in interface reactor.netty.resources.LoopResources
-
Default selector thread count, fallback to -1 (no selector thread).
- DEFAULT_IO_WORKER_COUNT - Static variable in interface reactor.netty.resources.LoopResources
-
Default worker thread count, fallback to available processor
(but with a minimum value of 4).
- DEFAULT_MAX_CHUNK_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_MAX_HEADER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_MAX_INITIAL_LINE_LENGTH - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- DEFAULT_NATIVE - Static variable in interface reactor.netty.resources.LoopResources
-
Default value whether the native transport (epoll, kqueue) will be preferred,
fallback it will be preferred when available.
- DEFAULT_PARSE_HTTP_AFTER_CONNECT_REQUEST - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
-
- DEFAULT_POOL_ACQUIRE_TIMEOUT - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default acquisition timeout (milliseconds) before error.
- DEFAULT_POOL_LEASING_STRATEGY - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default leasing strategy (fifo, lifo), fallback to fifo.
- DEFAULT_POOL_MAX_CONNECTIONS - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default max connections.
- DEFAULT_POOL_MAX_IDLE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default max idle time, fallback - max idle time is not specified.
- DEFAULT_POOL_MAX_LIFE_TIME - Static variable in interface reactor.netty.resources.ConnectionProvider
-
Default max life time, fallback - max life time is not specified.
- DEFAULT_SHUTDOWN_QUIET_PERIOD - Static variable in interface reactor.netty.resources.LoopResources
-
Default quiet period that guarantees that the disposal of the underlying LoopResources
will not happen, fallback to 2 seconds.
- DEFAULT_SHUTDOWN_TIMEOUT - Static variable in interface reactor.netty.resources.LoopResources
-
Default maximum amount of time to wait until the disposal of the underlying LoopResources
regardless if a task was submitted during the quiet period, fallback to 15 seconds.
- DEFAULT_VALIDATE_HEADERS - Static variable in class reactor.netty.http.HttpDecoderSpec
-
- defaultAddressResolverGroup() - Method in class reactor.netty.http.client.HttpClientConfig
-
- defaultAddressResolverGroup() - Method in class reactor.netty.tcp.TcpClientConfig
-
- defaultAddressResolverGroup() - Method in class reactor.netty.transport.ClientTransportConfig
-
- defaultAddressResolverGroup() - Method in class reactor.netty.udp.UdpClientConfig
-
- defaultChildObserver() - Method in class reactor.netty.transport.ServerTransportConfig
-
- defaultClientProvider() - Static method in class reactor.netty.tcp.SslProvider
-
Return the default client ssl provider.
- defaultConfiguration() - Method in class reactor.netty.http.Http11SslContextSpec
-
- defaultConfiguration() - Method in class reactor.netty.http.Http2SslContextSpec
-
- defaultConfiguration() - Method in class reactor.netty.tcp.AbstractProtocolSslContextSpec
-
- defaultConfiguration() - Method in class reactor.netty.tcp.DefaultSslContextSpec
-
- defaultConfiguration(SslProvider.DefaultConfigurationType) - Method in interface reactor.netty.tcp.SslProvider.DefaultConfigurationSpec
-
Deprecated.
- defaultConfiguration() - Method in class reactor.netty.tcp.TcpSslContextSpec
-
- defaultConnectionObserver() - Method in class reactor.netty.http.client.HttpClientConfig
-
- defaultConnectionObserver() - Method in class reactor.netty.incubator.quic.QuicClientConfig
-
- defaultConnectionObserver() - Method in class reactor.netty.incubator.quic.QuicServerConfig
-
- defaultConnectionObserver() - Method in class reactor.netty.transport.ClientTransportConfig
-
- defaultConnectionObserver() - Method in class reactor.netty.transport.ServerTransportConfig
-
- defaultConnectionObserver() - Method in class reactor.netty.transport.TransportConfig
-
- defaultConnectionObserver() - Method in class reactor.netty.udp.UdpServerConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.http.client.HttpClientConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.http.server.HttpServerConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.incubator.quic.QuicClientConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.incubator.quic.QuicServerConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.tcp.TcpClientConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.tcp.TcpServerConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.transport.TransportConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.udp.UdpClientConfig
-
- defaultLoggingHandler() - Method in class reactor.netty.udp.UdpServerConfig
-
- defaultLoopResources() - Method in class reactor.netty.http.client.HttpClientConfig
-
- defaultLoopResources() - Method in class reactor.netty.http.server.HttpServerConfig
-
- defaultLoopResources() - Method in class reactor.netty.tcp.TcpClientConfig
-
- defaultLoopResources() - Method in class reactor.netty.tcp.TcpServerConfig
-
- defaultLoopResources() - Method in class reactor.netty.transport.TransportConfig
-
- defaultLoopResources() - Method in class reactor.netty.udp.UdpClientConfig
-
- defaultLoopResources() - Method in class reactor.netty.udp.UdpServerConfig
-
- defaultMetricsRecorder() - Method in class reactor.netty.http.client.HttpClientConfig
-
- defaultMetricsRecorder() - Method in class reactor.netty.http.server.HttpServerConfig
-
- defaultMetricsRecorder() - Method in class reactor.netty.incubator.quic.QuicClientConfig
-
- defaultMetricsRecorder() - Method in class reactor.netty.incubator.quic.QuicServerConfig
-
- defaultMetricsRecorder() - Method in class reactor.netty.tcp.TcpClientConfig
-
- defaultMetricsRecorder() - Method in class reactor.netty.tcp.TcpServerConfig
-
- defaultMetricsRecorder() - Method in class reactor.netty.transport.TransportConfig
-
Return the configured metrics recorder.
- defaultMetricsRecorder() - Method in class reactor.netty.udp.UdpClientConfig
-
- defaultMetricsRecorder() - Method in class reactor.netty.udp.UdpServerConfig
-
- defaultOnChannelInit() - Method in class reactor.netty.http.client.HttpClientConfig
-
- defaultOnChannelInit() - Method in class reactor.netty.http.server.HttpServerConfig
-
- defaultOnChannelInit() - Method in class reactor.netty.tcp.TcpClientConfig
-
- defaultOnChannelInit() - Method in class reactor.netty.tcp.TcpServerConfig
-
- defaultOnChannelInit() - Method in class reactor.netty.transport.ClientTransportConfig
-
- defaultOnChannelInit() - Method in class reactor.netty.transport.ServerTransportConfig
-
- defaultOnChannelInit() - Method in class reactor.netty.transport.TransportConfig
-
- defaultOnChannelInit() - Method in class reactor.netty.udp.UdpServerConfig
-
- DefaultSslContextSpec - Class in reactor.netty.tcp
-
SslContext builder that does not provide any default configuration.
- deferFuture(Supplier<F>) - Static method in class reactor.netty.FutureMono
-
Convert a supplied
Future
for each subscriber into
Mono
.
- delete() - Method in class reactor.netty.http.client.HttpClient
-
- delete(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP DELETE on the passed path to be used as a routing condition.
- deRegisterDefaultMetrics(String, SocketAddress) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- deRegisterMetrics(String, String, SocketAddress) - Method in interface reactor.netty.resources.ConnectionProvider.MeterRegistrar
-
Invoked when a connection pool is disposed.
- DIRECT_ARENAS - Static variable in class reactor.netty.Metrics
-
The number of direct arenas.
- directory(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.
- directory(String, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.The
content of the provided
directory
will be served.
- disableOptionalRecord(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Disables the automatic inclusion of an optional record that tries to hint the remote DNS server about
how much data the resolver can read per response.
- disableRecursionDesired(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Specifies whether this resolver has to send a DNS query with the recursion desired (RD) flag set.
- disableRetry(boolean) - Method in class reactor.netty.http.client.HttpClient
-
- discard() - Method in class reactor.netty.channel.ChannelOperations
-
Drop pending content and complete inbound.
- discardWhenNoReceiver() - Method in class reactor.netty.channel.ChannelOperations
-
Drop pending content and complete inbound.
- DISCONNECTING - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection is being fully closed
- DisposableChannel - Interface in reactor.netty
-
Holds contextual information for the underlying channel and provides
non-blocking resource disposing API.
- DisposableServer - Interface in reactor.netty
-
Holds contextual information for the underlying server.
- dispose() - Method in class reactor.netty.channel.ChannelOperations
-
- dispose() - Method in interface reactor.netty.DisposableChannel
-
Releases or closes the underlying
Channel
.
- dispose() - Method in class reactor.netty.incubator.quic.QuicResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global QUIC resources which has a longer lifecycle than regular
LoopResources
.
- dispose() - Method in interface reactor.netty.resources.ConnectionProvider
-
Dispose this ConnectionProvider.
- dispose() - Method in interface reactor.netty.resources.LoopResources
-
Dispose the underlying LoopResources.
- dispose() - Method in class reactor.netty.tcp.TcpResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global TCP resources which has a longer lifecycle than regular
LoopResources
and
ConnectionProvider
.
- dispose() - Method in class reactor.netty.udp.UdpResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global UDP resources which has a longer lifecycle than regular
LoopResources
.
- disposeInactivePoolsInBackground(Duration, Duration) - Method in class reactor.netty.resources.ConnectionProvider.Builder
-
Set the options to use for configuring
ConnectionProvider
background disposal for inactive connection pools.
- disposeLater() - Method in class reactor.netty.incubator.quic.QuicResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global QUIC resources which has a longer lifecycle than regular
LoopResources
.
- disposeLater(Duration, Duration) - Method in class reactor.netty.incubator.quic.QuicResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global QUIC resources which has a longer lifecycle than regular
LoopResources
.
- disposeLater() - Method in interface reactor.netty.resources.ConnectionProvider
-
Returns a Mono that triggers the disposal of the ConnectionProvider when subscribed to.
- disposeLater() - Method in interface reactor.netty.resources.LoopResources
-
Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
- disposeLater(Duration, Duration) - Method in interface reactor.netty.resources.LoopResources
-
Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
- disposeLater() - Method in class reactor.netty.resources.PooledConnectionProvider
-
- disposeLater() - Method in class reactor.netty.tcp.TcpResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global TCP resources which has a longer lifecycle than regular
LoopResources
and
ConnectionProvider
.
- disposeLater(Duration, Duration) - Method in class reactor.netty.tcp.TcpResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global TCP resources which has a longer lifecycle than regular
LoopResources
and
ConnectionProvider
.
- disposeLater() - Method in class reactor.netty.udp.UdpResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global UDP resources which has a longer lifecycle than regular
LoopResources
.
- disposeLater(Duration, Duration) - Method in class reactor.netty.udp.UdpResources
-
This has a
NOOP
implementation by default in order to prevent unintended disposal of
the global UDP resources which has a longer lifecycle than regular
LoopResources
.
- disposeLoops() - Static method in class reactor.netty.incubator.quic.QuicResources
-
Shutdown the global
QuicResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnections() - Static method in class reactor.netty.http.HttpResources
-
Shutdown the global
HttpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnections() - Static method in class reactor.netty.tcp.TcpResources
-
Shutdown the global
TcpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.http.HttpResources
-
Prepare to shutdown the global
HttpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater(Duration, Duration) - Static method in class reactor.netty.http.HttpResources
-
Prepare to shutdown the global
HttpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.tcp.TcpResources
-
Prepare to shutdown the global
TcpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater(Duration, Duration) - Static method in class reactor.netty.tcp.TcpResources
-
Prepare to shutdown the global
TcpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsLater() - Static method in class reactor.netty.incubator.quic.QuicResources
-
Prepare to shut down the global
QuicResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeLoopsLater(Duration, Duration) - Static method in class reactor.netty.incubator.quic.QuicResources
-
Prepare to shut down the global
QuicResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- disposeNow() - Method in interface reactor.netty.DisposableChannel
-
Releases or closes the underlying
Channel
in a blocking fashion with
3
seconds default timeout.
- disposeNow(Duration) - Method in interface reactor.netty.DisposableChannel
-
Releases or closes the underlying
Channel
in a blocking fashion with
the provided timeout.
- disposeSubscriber() - Method in class reactor.netty.channel.ChannelOperations
-
- disposeSubscriber() - Method in interface reactor.netty.DisposableChannel
-
- disposeTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.Builder
-
- disposeWhen(SocketAddress) - Method in class reactor.netty.http.HttpResources
-
- disposeWhen(SocketAddress) - Method in interface reactor.netty.resources.ConnectionProvider
-
Dispose all connection pools for the specified remote address.
- disposeWhen(SocketAddress) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- disposeWhen(SocketAddress) - Method in class reactor.netty.tcp.TcpResources
-
Dispose all connection pools for the specified remote address.
- dnsAddressResolverGroupProvider() - Method in class reactor.netty.transport.NameResolverProvider
-
- dnsAddressResolverGroupProvider(Function<DnsNameResolverBuilder, DnsAddressResolverGroup>) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
- doAfterRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
- doAfterResolve(BiConsumer<? super Connection, ? super SocketAddress>) - Method in class reactor.netty.transport.ClientTransport
-
Set or add a callback called after
SocketAddress
is resolved successfully.
- doAfterResponseSuccess(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnBind(Consumer<? super TcpServerConfig>) - Method in class reactor.netty.tcp.TcpServer
-
- doOnBind(Consumer<? super CONF>) - Method in class reactor.netty.transport.ServerTransport
-
Set or add a callback called when
ServerTransport
is about to start listening for incoming traffic.
- doOnBind() - Method in class reactor.netty.transport.ServerTransportConfig
-
Return the configured callback or null.
- doOnBind(Consumer<? super UdpServerConfig>) - Method in class reactor.netty.udp.UdpServer
-
Set or add a callback called when
UdpServer
is about to start listening for incoming traffic.
- doOnBind() - Method in class reactor.netty.udp.UdpServerConfig
-
Return the configured callback or null.
- doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
-
- doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
-
- doOnBound() - Method in class reactor.netty.transport.ServerTransportConfig
-
Return the configured callback or null.
- doOnBound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
-
Set or add a callback called after
UdpServer
has been started.
- doOnBound() - Method in class reactor.netty.udp.UdpServerConfig
-
Return the configured callback or null.
- doOnChannelInit(ChannelPipelineConfigurer) - Method in class reactor.netty.transport.Transport
-
Configure the channel pipeline while initializing the channel.
- doOnChannelInit() - Method in class reactor.netty.transport.TransportConfig
-
- doOnConnect(Consumer<? super QuicClientConfig>) - Method in class reactor.netty.incubator.quic.QuicClient
-
Set or add a callback called when
QuicClient
is about to connect to the remote endpoint.
- doOnConnect() - Method in class reactor.netty.incubator.quic.QuicClientConfig
-
Return the configured callback or null.
- doOnConnect(Consumer<? super TcpClientConfig>) - Method in class reactor.netty.tcp.TcpClient
-
- doOnConnect(Consumer<? super CONF>) - Method in class reactor.netty.transport.ClientTransport
-
Set or add a callback called when
ClientTransport
is about to connect to the remote endpoint.
- doOnConnect() - Method in class reactor.netty.transport.ClientTransportConfig
-
Return the configured callback or null.
- doOnConnect(Consumer<? super UdpClientConfig>) - Method in class reactor.netty.udp.UdpClient
-
- doOnConnected(Consumer<? super QuicConnection>) - Method in class reactor.netty.incubator.quic.QuicClient
-
- doOnConnected() - Method in class reactor.netty.incubator.quic.QuicClientConfig
-
Return the configured callback or null.
- doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
-
- doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
-
Set or add a callback called after
Connection
has been connected.
- doOnConnected() - Method in class reactor.netty.transport.ClientTransportConfig
-
Return the configured callback or null.
- doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
-
- doOnConnection(Consumer<? super QuicConnection>) - Method in class reactor.netty.incubator.quic.QuicServer
-
- doOnConnection() - Method in class reactor.netty.incubator.quic.QuicServerConfig
-
Return the configured callback or null.
- doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpServer
-
- doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.transport.ServerTransport
-
Set or add a callback called on new remote
Connection
.
- doOnConnection() - Method in class reactor.netty.transport.ServerTransportConfig
-
Return the configured callback or null.
- doOnDisconnected(Consumer<? super QuicConnection>) - Method in class reactor.netty.incubator.quic.QuicClient
-
Set or add a callback called after
QuicConnection
has been disconnected.
- doOnDisconnected() - Method in class reactor.netty.incubator.quic.QuicClientConfig
-
Return the configured callback or null.
- doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
-
- doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
-
Set or add a callback called after
Connection
has been disconnected.
- doOnDisconnected() - Method in class reactor.netty.transport.ClientTransportConfig
-
Return the configured callback or null.
- doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
-
- doOnError(BiConsumer<? super HttpClientRequest, ? super Throwable>, BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnRedirect(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
Setup a callback called after
HttpClientResponse
headers have been
received and the request is about to be redirected.
- doOnRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnRequestError(BiConsumer<? super HttpClientRequest, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnResolve(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
-
- doOnResolveError(BiConsumer<? super Connection, ? super Throwable>) - Method in class reactor.netty.transport.ClientTransport
-
Set or add a callback called if an exception happens while resolving to a
SocketAddress
.
- doOnResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnResponseError(BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
-
- doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
-
- doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
-
- doOnUnbound() - Method in class reactor.netty.transport.ServerTransportConfig
-
Return the configured callback or null.
- doOnUnbound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
-
Set or add a callback called after
UdpServer
has been shutdown.
- doOnUnbound() - Method in class reactor.netty.udp.UdpServerConfig
-
Return the configured callback or null.
- duplicate() - Method in class reactor.netty.transport.Transport
-
Return a new
Transport
inheriting the current configuration.
- duration() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the request/response duration.
- get(Channel) - Static method in class reactor.netty.channel.ChannelOperations
-
- get() - Method in class reactor.netty.http.client.HttpClient
-
- get() - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
-
- get() - Method in class reactor.netty.http.Http11SslContextSpec
-
- get() - Method in class reactor.netty.http.Http2SslContextSpec
-
- get() - Static method in class reactor.netty.http.HttpResources
-
Return the global HTTP resources for event loops and pooling.
- get() - Method in class reactor.netty.http.server.HttpRequestDecoderSpec
-
- get(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP GET on the passed path to be used as a routing condition.
- get() - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
- get() - Static method in class reactor.netty.incubator.quic.QuicResources
-
Return the global QUIC resources for loops.
- get() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
- get() - Method in class reactor.netty.tcp.DefaultSslContextSpec
-
- get() - Static method in class reactor.netty.tcp.TcpResources
-
Return the global TCP resources for event loops and pooling.
- get() - Method in class reactor.netty.tcp.TcpSslContextSpec
-
- get() - Static method in class reactor.netty.udp.UdpResources
-
Return the global UDP resources for pooling.
- getAddress() - Method in class reactor.netty.transport.ProxyProvider
-
The supplier for the address to connect to.
- getAllCachedCookies() - Method in class reactor.netty.http.server.ServerCookies
-
Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.
- getCachedCookies() - Method in class reactor.netty.http.Cookies
-
Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.
- getCachedCookies() - Method in class reactor.netty.http.server.ServerCookies
-
- getChannelContext(Channel) - Static method in class reactor.netty.ReactorNetty
-
Returns
ContextView
from the channel attributes when exists otherwise returns
null
.
- getDefaultConfigurationType() - Method in class reactor.netty.tcp.SslProvider
-
Returns the configured default configuration type.
- getDefaultHostPort(String) - Static method in class reactor.netty.http.server.ConnectionInfo
-
Returns the default host port number based on scheme.
- getHostAddress() - Method in class reactor.netty.http.server.ConnectionInfo
-
Return the host address of the connection.
- getHostName() - Method in class reactor.netty.http.server.ConnectionInfo
-
Returns the connection host name.
- getHostPort() - Method in class reactor.netty.http.server.ConnectionInfo
-
Returns the connection host port.
- getMethod() - Method in interface reactor.netty.http.server.HttpRouteHandlerMetadata
-
Get the http method this handler can handle.
- getNameResolverProvider() - Method in class reactor.netty.transport.ClientTransportConfig
-
- getNonProxyHostsPredicate() - Method in class reactor.netty.transport.ProxyProvider
-
A predicate
Predicate
on
SocketAddress
that returns true when the provided address should be
reached directly, bypassing the proxy.
- getOrCreate(LoopResources, Function<LoopResources, QuicResources>, String) - Static method in class reactor.netty.incubator.quic.QuicResources
-
Safely check if existing resource exist and proceed to update/cleanup if new
resources references are passed.
- getOrCreate(AtomicReference<T>, LoopResources, ConnectionProvider, BiFunction<LoopResources, ConnectionProvider, T>, String) - Static method in class reactor.netty.tcp.TcpResources
-
Safely check if existing resource exist and proceed to update/cleanup if new
resources references are passed.
- getOrCreate(LoopResources, Function<LoopResources, UdpResources>, String) - Static method in class reactor.netty.udp.UdpResources
-
Safely check if existing resource exist and proceed to update/cleanup if new
resources references are passed.
- getOrCreateDefaultResolver() - Method in class reactor.netty.http.HttpResources
-
- getOrCreateDefaultResolver() - Method in class reactor.netty.tcp.TcpResources
-
Safely checks whether a name resolver exists and proceed with a creation if it does not exist.
- getOrCreateHttp2ConnectionProvider(Function<ConnectionProvider, ConnectionProvider>) - Method in class reactor.netty.http.HttpResources
-
Safely checks whether a
ConnectionProvider
for HTTP/2 traffic exists
and proceed with a creation if it does not exist.
- getPath() - Method in interface reactor.netty.http.server.HttpRouteHandlerMetadata
-
Get the http path this handler can handle.
- getPermits(int) - Method in class reactor.netty.http.client.Http2AllocationStrategy
-
- getPermits(int) - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
-
Try to get the permission to allocate a desired
positive number of new connections.
- getRemoteAddress() - Method in class reactor.netty.http.server.ConnectionInfo
-
Return the remote address of the connection.
- getResolveAddressTimer(String, String, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- getScheme() - Method in class reactor.netty.http.server.ConnectionInfo
-
Return the connection scheme.
- getSpanName(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTracingObservationHandler
-
- getSslContext() - Method in class reactor.netty.tcp.SslProvider
-
Returns SslContext
instance with configured settings.
- getTimer() - Method in interface reactor.netty.observability.ReactorNettyHandlerContext
-
Obtain the timer associated to this reactor netty context.
- getTlsHandshakeTimer(String, String, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- getTlsHandshakeTimer(String, String, String, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
Returns TLS handshake timer.
- getType() - Method in class reactor.netty.transport.ProxyProvider
-
The proxy type.
- h2cMaxContentLength - Variable in class reactor.netty.http.HttpDecoderSpec
-
- h2cMaxContentLength(int) - Method in class reactor.netty.http.HttpDecoderSpec
-
Configure the maximum length of the content of the HTTP/2.0 clear-text upgrade request.
- h2cMaxContentLength() - Method in class reactor.netty.http.HttpDecoderSpec
-
Return the configured maximum length of the content of the HTTP/2.0 clear-text upgrade request.
- H2CUpgradeHandler - Static variable in interface reactor.netty.NettyPipeline
-
- H2Flush - Static variable in interface reactor.netty.NettyPipeline
-
- H2MultiplexHandler - Static variable in interface reactor.netty.NettyPipeline
-
- H2OrHttp11Codec - Static variable in interface reactor.netty.NettyPipeline
-
- H2ToHttp11Codec - Static variable in interface reactor.netty.NettyPipeline
-
- handle(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
-
- handle(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in class reactor.netty.http.server.HttpServer
-
Attach an I/O handler to react on a connected client.
- handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpClient
-
Attach an IO handler to react on connected client.
- handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpServer
-
Attaches an I/O handler to react on a connected client.
- handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpClient
-
Attach an IO handler to react on connected client.
- handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpServer
-
Attach an IO handler to react on connected client.
- handlePing(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
Sets flag whether to proxy websocket ping frames or respond to them.
- handlePing() - Method in interface reactor.netty.http.websocket.WebsocketSpec
-
Returns whether to proxy websocket PING frames or respond to them.
- handlePing() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
-
- handlerConfigurator(Consumer<? super SslHandler>) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set a configurator callback to mutate any property from the provided
SslHandler
.
- handshakeTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL handshake timeout.
- handshakeTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Set the options to use for configuring SSL handshake timeout.
- hashCode() - Method in class reactor.netty.channel.MeterKey
-
- hashCode() - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
-
- hashCode() - Method in class reactor.netty.http.Http2SettingsSpec
-
- hashCode() - Method in class reactor.netty.http.HttpDecoderSpec
-
- hashCode() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
-
- hashCode() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
-
- hashCode() - Method in class reactor.netty.tcp.SslProvider
-
- hashCode() - Method in class reactor.netty.transport.NameResolverProvider
-
- hashCode() - Method in class reactor.netty.transport.ProxyProvider
-
- hasNativeSupport() - Static method in interface reactor.netty.resources.LoopResources
-
Return true if environment supports native connections.
- hasProxy() - Method in class reactor.netty.transport.ClientTransportConfig
-
- hasReadCookies() - Method in class reactor.netty.http.Cookies
-
- hasSentBody() - Method in class reactor.netty.http.HttpOperations
-
Has Body been sent.
- hasSentHeaders() - Method in class reactor.netty.http.HttpOperations
-
Has headers been sent.
- hasSentHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Returns true if headers and status have been sent to the client.
- head() - Method in class reactor.netty.http.client.HttpClient
-
- head(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP HEAD on the passed path to be used as a routing condition.
- header(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Set an outbound header, replacing any pre-existing value.
- header(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets an outbound HTTP header, replacing any pre-existing value.
- headers(Consumer<? super HttpHeaders>) - Method in class reactor.netty.http.client.HttpClient
-
Apply headers configuration.
- headers() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return a copy of the request headers.
- headers(HttpHeaders) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Set outbound headers from the passed headers.
- headers() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
-
Returns the request/response headers.
- headers(HttpHeaders) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets outbound HTTP headers, replacing any pre-existing value for these headers.
- headers() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Returns the websocket remote headers sent during handshake.
- headersWhen(Function<? super HttpHeaders, Mono<? extends HttpHeaders>>) - Method in class reactor.netty.http.client.HttpClient
-
Apply headers configuration emitted by the returned Mono before requesting.
- headerTableSize(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
-
Sets the SETTINGS_HEADER_TABLE_SIZE
value.
- headerTableSize() - Method in class reactor.netty.http.Http2SettingsSpec
-
Returns the configured SETTINGS_HEADER_TABLE_SIZE
value or null.
- headerValueFunction() - Method in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
-
Returns the function that is used for sanitizing the headers values.
- HEAP_ARENAS - Static variable in class reactor.netty.Metrics
-
The number of heap arenas.
- host() - Method in interface reactor.netty.DisposableServer
-
Returns the server's host string.
- host(String) - Method in class reactor.netty.http.server.HttpServer
-
- host(String) - Method in class reactor.netty.incubator.quic.QuicClient
-
The host to which this client should connect.
- host(String) - Method in class reactor.netty.incubator.quic.QuicServer
-
The host to which this server should bind.
- host(String) - Method in class reactor.netty.tcp.TcpClient
-
- host(String) - Method in class reactor.netty.tcp.TcpServer
-
- host(String) - Method in class reactor.netty.transport.ClientTransport
-
The host to which this client should connect.
- host(String) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
-
The proxy host to connect to.
- host(String) - Method in class reactor.netty.transport.ServerTransport
-
The host to which this server should bind.
- host(String) - Method in class reactor.netty.udp.UdpClient
-
- host(String) - Method in class reactor.netty.udp.UdpServer
-
The host to which this server should bind.
- hostAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
-
Returns the address of the host which received the request, possibly null
in case of Unix Domain Sockets.
- hostAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
-
- hostName() - Method in interface reactor.netty.http.server.ConnectionInformation
-
Returns the host name derived from the Host
/X-Forwarded-Host
/Forwarded
header
associated with this request.
- HOSTNAME_VERIFICATION_CONFIGURER - Static variable in class reactor.netty.http.client.HttpClientSecurityUtils
-
Enables the hostname verification.
- hostPort() - Method in interface reactor.netty.http.server.ConnectionInformation
-
Returns the host port derived from the Host
/X-Forwarded-*
/Forwarded
header
associated with this request.
- hostsFileEntriesResolver() - Method in class reactor.netty.transport.NameResolverProvider
-
- hostsFileEntriesResolver(HostsFileEntriesResolver) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
- HostSpecificSpec() - Constructor for class reactor.netty.resources.ConnectionProvider.HostSpecificSpec
-
- Http11SslContextSpec - Class in reactor.netty.http
-
SslContext builder that provides default configuration specific to HTTP/1.x as follows:
SslProvider
will be set depending on
OpenSsl.isAvailable()
The default cipher suites will be used
Application protocol negotiation configuration is disabled
- Http2AllocationStrategy - Class in reactor.netty.http.client
-
HTTP/2 ConnectionProvider.AllocationStrategy
.
- Http2AllocationStrategy.Builder - Interface in reactor.netty.http.client
-
- http2Settings(Consumer<Http2SettingsSpec.Builder>) - Method in class reactor.netty.http.client.HttpClient
-
Apply HTTP/2 configuration.
- http2Settings(Consumer<Http2SettingsSpec.Builder>) - Method in class reactor.netty.http.server.HttpServer
-
Apply HTTP/2 configuration.
- http2SettingsSpec() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return the HTTP/2 configuration.
- Http2SettingsSpec - Class in reactor.netty.http
-
- http2SettingsSpec() - Method in class reactor.netty.http.server.HttpServerConfig
-
Return the HTTP/2 configuration.
- Http2SettingsSpec.Builder - Interface in reactor.netty.http
-
- Http2SslContextSpec - Class in reactor.netty.http
-
SslContext builder that provides default configuration specific to HTTP/2 as follows:
SslProvider
will be set depending on
OpenSsl.isAlpnSupported()
Http2SecurityUtil.CIPHERS
Application protocol negotiation configuration is enabled
HTTP/1.1 and HTTP/2 support in order to support upgrade to HTTP/2
- HTTP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the HTTP client's metrics
registered in Micrometer's global registry.
- HTTP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the HTTP server's metrics
registered in Micrometer's global registry.
- HttpAggregator - Static variable in interface reactor.netty.NettyPipeline
-
- HttpClient - Class in reactor.netty.http.client
-
An HttpClient allows building in a safe immutable way an http client that is
materialized and connecting when
ClientTransport.connect()
is ultimately called.
- HttpClient() - Constructor for class reactor.netty.http.client.HttpClient
-
- HttpClient.RedirectSendHandler - Interface in reactor.netty.http.client
-
- HttpClient.RequestSender - Interface in reactor.netty.http.client
-
- HttpClient.ResponseReceiver<S extends HttpClient.ResponseReceiver<?>> - Interface in reactor.netty.http.client
-
A response extractor for this configured
HttpClient
.
- HttpClient.UriConfiguration<S extends HttpClient.UriConfiguration<?>> - Interface in reactor.netty.http.client
-
A URI configuration.
- HttpClient.WebsocketReceiver<S extends HttpClient.WebsocketReceiver<?>> - Interface in reactor.netty.http.client
-
Allow a websocket handling.
- HttpClient.WebsocketSender - Interface in reactor.netty.http.client
-
- HttpClientConfig - Class in reactor.netty.http.client
-
Encapsulate all necessary configuration for HTTP client transport.
- HttpClientForm - Interface in reactor.netty.http.client
-
An HTTP Form builder.
- HttpClientInfos - Interface in reactor.netty.http.client
-
An Http Reactive Channel with several accessors related to HTTP flow: resource URL,
information for redirections etc...
- HttpClientMetricsRecorder - Interface in reactor.netty.http.client
-
Interface for collecting metrics on HTTP client level.
- HttpClientRequest - Interface in reactor.netty.http.client
-
An Http Reactive client metadata contract for outgoing requests.
- HttpClientResponse - Interface in reactor.netty.http.client
-
An HttpClient Reactive metadata contract for incoming response.
- HttpClientSecurityUtils - Class in reactor.netty.http.client
-
Provides utilities for
HttpClient
SSL/TLS configuration.
- HttpClientState - Enum in reactor.netty.http.client
-
- HttpCodec - Static variable in interface reactor.netty.NettyPipeline
-
- HttpDecoderSpec<T extends HttpDecoderSpec<T>> - Class in reactor.netty.http
-
A configuration builder to fine tune the HttpCodec
(or more precisely
the settings for the decoder).
- HttpDecoderSpec() - Constructor for class reactor.netty.http.HttpDecoderSpec
-
- HttpDecompressor - Static variable in interface reactor.netty.NettyPipeline
-
- httpFormDecoder(Consumer<HttpServerFormDecoderProvider.Builder>) - Method in class reactor.netty.http.server.HttpServer
-
Apply HTTP form decoder configuration.
- httpHeaders(Consumer<HttpHeaders>) - Method in interface reactor.netty.transport.ProxyProvider.Builder
-
A consumer to add request headers for the http proxy.
- HttpInfos - Interface in reactor.netty.http
-
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
- HttpMessageArgProvider - Interface in reactor.netty.http.logging
-
A provider of the args required for logging
HttpMessage
details.
- HttpMessageArgProviderFactory - Class in reactor.netty.http.logging
-
- httpMessageLogFactory(HttpMessageLogFactory) - Method in class reactor.netty.http.client.HttpClient
-
When
HttpMessage
is about to be logged the configured factory will be used for
generating a sanitized log message.
- httpMessageLogFactory() - Method in class reactor.netty.http.HttpOperations
-
- HttpMessageLogFactory - Interface in reactor.netty.http.logging
-
- httpMessageLogFactory(HttpMessageLogFactory) - Method in class reactor.netty.http.server.HttpServer
-
When
HttpMessage
is about to be logged the configured factory will be used for
generating a sanitized log message.
- HttpMessageLogUtils - Class in reactor.netty.http.logging
-
- httpMessageType() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
-
- HttpMessageType - Enum in reactor.netty.http.logging
-
- HttpMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
-
- HttpMetricsRecorder - Interface in reactor.netty.http
-
Interface for recording metrics for HTTP protocol.
- HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.http
-
An HTTP ready
ChannelOperations
with state management for status and headers
(first HTTP response packet).
- HttpOperations(HttpOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.http.HttpOperations
-
- HttpOperations(Connection, ConnectionObserver, HttpMessageLogFactory) - Constructor for class reactor.netty.http.HttpOperations
-
- HttpOperations.PostHeadersNettyOutbound - Class in reactor.netty.http
-
- HttpProtocol - Enum in reactor.netty.http
-
An enum defining various HTTP negotiations between H2, H2C-upgrade,
H2C-prior-knowledge and HTTP/1.1.
- httpRequestDecoder(Function<HttpRequestDecoderSpec, HttpRequestDecoderSpec>) - Method in class reactor.netty.http.server.HttpServer
-
- HttpRequestDecoderSpec - Class in reactor.netty.http.server
-
- HttpResources - Class in reactor.netty.http
-
Hold the default HTTP/1.x resources.
- httpResponseDecoder(Function<HttpResponseDecoderSpec, HttpResponseDecoderSpec>) - Method in class reactor.netty.http.client.HttpClient
-
- HttpResponseDecoderSpec - Class in reactor.netty.http.client
-
- HttpRouteHandlerMetadata - Interface in reactor.netty.http.server
-
Provides the metadata that a given handler can handle.
- HttpServer - Class in reactor.netty.http.server
-
An HttpServer allows building in a safe immutable way an HTTP server that is
materialized and connecting when
ServerTransport.bind()
is ultimately called.
- HttpServer() - Constructor for class reactor.netty.http.server.HttpServer
-
- HttpServerConfig - Class in reactor.netty.http.server
-
Encapsulate all necessary configuration for HTTP server transport.
- HttpServerFormDecoderProvider - Class in reactor.netty.http.server
-
A configuration builder to fine tune the HTTP form decoder.
- HttpServerFormDecoderProvider.Builder - Interface in reactor.netty.http.server
-
- HttpServerInfos - Interface in reactor.netty.http.server
-
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
- HttpServerMetricsRecorder - Interface in reactor.netty.http.server
-
Interface for collecting metrics on HTTP server level.
- HttpServerRequest - Interface in reactor.netty.http.server
-
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
- HttpServerResponse - Interface in reactor.netty.http.server
-
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
- HttpServerRoutes - Interface in reactor.netty.http.server
-
Server routes are unique and only the first matching in order of declaration will be
invoked.
- HttpServerState - Enum in reactor.netty.http.server
-
- HttpTrafficHandler - Static variable in interface reactor.netty.NettyPipeline
-
- ID - Static variable in class reactor.netty.Metrics
-
- IDLE_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The number of the idle connections.
- idleSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Measure the current number of idle resources in the pool.
- idleTime() - Method in interface reactor.netty.resources.ConnectionProvider.ConnectionMetadata
-
Returns the time in ms that the connection has been idle.
- idleTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer
-
Specifies an idle timeout on the connection when it is waiting for an HTTP request (resolution: ms).
- idleTimeout() - Method in class reactor.netty.http.server.HttpServerConfig
-
Return the configured idle timeout for the connection when it is waiting for an HTTP request or null.
- IdleTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
-
- inbound() - Method in class reactor.netty.channel.ChannelOperations
-
- inbound() - Method in interface reactor.netty.Connection
-
- inboundHandler(BiConsumer<? super ChannelHandlerContext, Object>) - Static method in interface reactor.netty.NettyPipeline
-
- incrementErrorsCount(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Increments the number of the errors that have occurred.
- incrementErrorsCount(SocketAddress, SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Increments the number of the errors that have occurred.
- incrementErrorsCount(ContextView, SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Increments the number of the errors that have occurred.
- incrementErrorsCount(ContextView, SocketAddress, SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Increments the number of the errors that have occurred.
- incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- incrementErrorsCount(SocketAddress, SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- incrementErrorsCount(SocketAddress, SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- incrementErrorsCount(ContextView, SocketAddress, SocketAddress, String) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Increments the number of the errors that have occurred.
- incrementErrorsCount(SocketAddress, SocketAddress, String) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- incrementErrorsCount(SocketAddress, SocketAddress, String) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Increments the number of the errors that have occurred.
- incrementErrorsCount(ContextView, SocketAddress, String) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
-
Increments the number of the errors that are occurred.
- incrementErrorsCount(SocketAddress, String) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
-
- incrementErrorsCount(SocketAddress, String) - Method in interface reactor.netty.http.HttpMetricsRecorder
-
Increments the number of the errors that are occurred.
- incrementErrorsCount(SocketAddress, String) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- index(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
This route will be invoked when GET "/path" or "/path/" like uri are requested.
- INDEX_PREDICATE - Static variable in interface reactor.netty.http.server.HttpServerRoutes
-
- info(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
-
- info(HttpMessageArgProvider) - Method in interface reactor.netty.http.logging.HttpMessageLogFactory
-
- initialBufferSize - Variable in class reactor.netty.http.HttpDecoderSpec
-
- initialBufferSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
-
Configure the initial buffer size for HTTP request decoding.
- initialBufferSize() - Method in class reactor.netty.http.HttpDecoderSpec
-
Return the configured initial buffer size for HTTP request decoding.
- initialWindowSize(int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
-
Sets the SETTINGS_INITIAL_WINDOW_SIZE
value.
- initialWindowSize() - Method in class reactor.netty.http.Http2SettingsSpec
-
Returns the configured SETTINGS_INITIAL_WINDOW_SIZE
value or null.
- initShortId() - Method in class reactor.netty.channel.ChannelOperations
-
- initShortId() - Method in class reactor.netty.http.HttpOperations
-
- INSTANCE - Static variable in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
-
- IO_SELECT_COUNT - Static variable in class reactor.netty.ReactorNetty
-
Default selector thread count, fallback to -1 (no selector thread)
- IO_WORKER_COUNT - Static variable in class reactor.netty.ReactorNetty
-
Default worker thread count, fallback to available processor
(but with a minimum value of 4).
- isAcceptGzip() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return whether GZip compression is enabled.
- isCompleteOncePreferredResolved() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns
true
if the resolver notifies the returned
Future
as
soon as all queries for the preferred address type are complete.
- isConnectionReset(Throwable) - Static method in exception reactor.netty.channel.AbortedException
-
Return true if connection has been simply aborted on a tcp level by verifying if
the given inbound error.
- isContentAlwaysEmpty() - Method in class reactor.netty.http.HttpOperations
-
- isDisableOptionalRecord() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns true
if an optional record inclusion is disabled.
- isDisableRecursionDesired() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns true
if recursion desired is disabled.
- isDisposed() - Method in class reactor.netty.channel.ChannelOperations
-
- isDisposed() - Method in interface reactor.netty.DisposableChannel
-
- isDisposed() - Method in class reactor.netty.incubator.quic.QuicResources
-
- isDisposed() - Method in class reactor.netty.resources.PooledConnectionProvider
-
- isDisposed() - Method in class reactor.netty.tcp.TcpResources
-
- isDisposed() - Method in class reactor.netty.udp.UdpResources
-
- isFollowRedirect() - Method in interface reactor.netty.http.client.HttpClientRequest
-
Return true if redirected will be followed.
- isFormUrlencoded() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns true if the request has Content-Type
with value application/x-www-form-urlencoded
.
- isForwarded() - Method in class reactor.netty.http.server.HttpServerConfig
-
Returns whether that
HttpServer
supports the
"Forwarded"
and
"X-Forwarded-*"
HTTP request headers for deriving information about the connection.
- isInboundCancelled() - Method in class reactor.netty.channel.ChannelOperations
-
Return true if inbound traffic is not expected anymore.
- isInboundComplete() - Method in class reactor.netty.channel.ChannelOperations
-
Return true if inbound traffic is not incoming or expected anymore.
- isInboundDisposed() - Method in class reactor.netty.channel.ChannelOperations
-
Return true if inbound traffic is not incoming or expected anymore.
- isKeepAlive() - Method in interface reactor.netty.http.HttpInfos
-
Is the request keep alive.
- isLocalStream() - Method in interface reactor.netty.incubator.quic.QuicStreamInfo
-
Returns true
if the stream was created by this peer.
- isMicrometerAvailable() - Static method in class reactor.netty.internal.util.Metrics
-
Check if the current runtime supports metrics, by verifying if Micrometer Core is on the classpath.
- isMultipart() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns true if the request has Content-Type
with value multipart/form-data
.
- isPersistent() - Method in class reactor.netty.channel.ChannelOperations
-
- isPersistent() - Method in interface reactor.netty.Connection
-
Return false if it will force a close on terminal protocol events thus defeating
any pooling strategy
Return true (default) if it will release on terminal protocol events thus
keeping alive the channel if possible.
- isPreferNative() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns true
if prefer native event loop and channel factory (e.g.
- isPreferNative() - Method in class reactor.netty.transport.TransportConfig
-
Return true
if prefer native event loop and channel factory (e.g.
- isRetryDisabled() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return true if retry once
is disabled, false otherwise.
- isRetryTcpOnTimeout() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns true
if the resolver will also fallback to TCP if a timeout is detected.
- isRoundRobinSelection() - Method in class reactor.netty.transport.NameResolverProvider
-
- isSecure() - Method in class reactor.netty.http.client.HttpClientConfig
-
Returns true if that
HttpClient
secured via SSL transport.
- isSecure() - Method in class reactor.netty.http.server.HttpServerConfig
-
Returns true if that
HttpServer
secured via SSL transport.
- isSecure() - Method in class reactor.netty.tcp.TcpClientConfig
-
Return true if that
TcpClient
secured via SSL transport.
- isSecure() - Method in class reactor.netty.tcp.TcpServerConfig
-
Returns true if that
TcpServer
secured via SSL transport.
- isSubscriptionDisposed() - Method in class reactor.netty.channel.ChannelOperations
-
Return true if dispose subscription has been terminated.
- isTracingAvailable() - Static method in class reactor.netty.internal.util.Metrics
-
Check if the current runtime supports tracing, by verifying if Micrometer Tracing is on the classpath.
- isWebsocket() - Method in interface reactor.netty.http.HttpInfos
-
Returns true if websocket connection (upgraded).
- isWebsocket() - Method in class reactor.netty.http.HttpOperations
-
- mapConnect(Function<? super Mono<? extends Connection>, ? extends Mono<? extends Connection>>) - Method in class reactor.netty.http.client.HttpClient
-
Intercept the connection lifecycle and allows delaying, transform or inject a
context.
- mapHandle(BiFunction<? super Mono<Void>, ? super Connection, ? extends Mono<Void>>) - Method in class reactor.netty.http.server.HttpServer
-
Decorate the configured I/O handler.
- MapUtils - Class in reactor.netty.internal.util
-
This class contains temporary workarounds for Java 8
Map
issues.
- markPersistent(boolean) - Method in interface reactor.netty.Connection
-
Mark the underlying channel as persistent or not.
- markReadCookies() - Method in class reactor.netty.http.Cookies
-
- markReadingCookies() - Method in class reactor.netty.http.Cookies
-
- markSentBody() - Method in class reactor.netty.http.HttpOperations
-
Mark the body sent.
- markSentHeaderAndBody(Object...) - Method in class reactor.netty.http.HttpOperations
-
Mark the headers and body sent.
- markSentHeaders(Object...) - Method in class reactor.netty.http.HttpOperations
-
Mark the headers sent.
- MAX_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The maximum number of active connections that are allowed.
- MAX_PENDING_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The maximum number of requests that will be queued while waiting for a ready connection.
- maxAllocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Get the maximum number of live resources this Pool will allow.
- maxChunkSize - Variable in class reactor.netty.http.HttpDecoderSpec
-
- maxChunkSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
-
- maxChunkSize() - Method in class reactor.netty.http.HttpDecoderSpec
-
- maxConcurrentStreams(long) - Method in interface reactor.netty.http.client.Http2AllocationStrategy.Builder
-
Configures the maximum number of the concurrent streams that can be opened to the remote peer.
- maxConcurrentStreams() - Method in class reactor.netty.http.client.Http2AllocationStrategy
-
Returns the configured maximum number of the concurrent streams that can be opened to the remote peer.
- maxConcurrentStreams(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
-
Sets the SETTINGS_MAX_CONCURRENT_STREAMS
value.
- maxConcurrentStreams() - Method in class reactor.netty.http.Http2SettingsSpec
-
Returns the configured SETTINGS_MAX_CONCURRENT_STREAMS
value or null.
- maxConnections(int) - Method in interface reactor.netty.http.client.Http2AllocationStrategy.Builder
-
Configures the maximum number of live connections to keep in the pool.
- maxConnections(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
Set the options to use for configuring
ConnectionProvider
maximum connections per connection pool.
- maxConnections() - Method in interface reactor.netty.resources.ConnectionProvider
-
Returns the maximum number of connections before starting pending.
- maxConnections() - Method in class reactor.netty.resources.PooledConnectionProvider
-
- maxConnections() - Method in class reactor.netty.tcp.TcpResources
-
- maxConnectionsPerHost() - Method in interface reactor.netty.resources.ConnectionProvider
-
Returns the maximum number of connections per host before starting pending.
- maxConnectionsPerHost() - Method in class reactor.netty.resources.PooledConnectionProvider
-
- maxConnectionsPerHost() - Method in class reactor.netty.tcp.TcpResources
-
- maxData(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
-
Set the initial maximum data limit.
- maxData() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
-
Return the configured initial maximum data limit.
- maxFramePayloadLength(int) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
Sets a custom maximum allowable frame payload length.
- maxFramePayloadLength() - Method in interface reactor.netty.http.websocket.WebsocketSpec
-
Returns the configured maximum allowable frame payload length.
- maxFramePayloadLength() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
-
- maxFrameSize(int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
-
Sets the SETTINGS_MAX_FRAME_SIZE
value.
- maxFrameSize() - Method in class reactor.netty.http.Http2SettingsSpec
-
Returns the configured SETTINGS_MAX_FRAME_SIZE
value or null.
- maxHeaderListSize(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
-
Sets the SETTINGS_MAX_HEADER_LIST_SIZE
value.
- maxHeaderListSize() - Method in class reactor.netty.http.Http2SettingsSpec
-
- maxHeaderSize - Variable in class reactor.netty.http.HttpDecoderSpec
-
- maxHeaderSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
-
Configure the maximum header size that can be decoded for the HTTP request.
- maxHeaderSize() - Method in class reactor.netty.http.HttpDecoderSpec
-
Return the configured maximum header size that can be decoded for the HTTP request.
- maxIdleTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
- maxIdleTime() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
-
- maxInitialLineLength - Variable in class reactor.netty.http.HttpDecoderSpec
-
- maxInitialLineLength(int) - Method in class reactor.netty.http.HttpDecoderSpec
-
Configure the maximum length that can be decoded for the HTTP request's initial
line.
- maxInitialLineLength() - Method in class reactor.netty.http.HttpDecoderSpec
-
Return the configured maximum length that can be decoded for the HTTP request's initial line.
- maxInMemorySize(long) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
-
- maxInMemorySize() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
-
Returns the configured maximum size after which an
Attribute
/
FileUpload
starts being stored on disk rather than in memory.
- maxKeepAliveRequests(int) - Method in class reactor.netty.http.server.HttpServer
-
The maximum number of HTTP/1.1 requests which can be served until the connection is closed by the server.
- maxKeepAliveRequests() - Method in class reactor.netty.http.server.HttpServerConfig
-
The configured maximum number of HTTP/1.1 requests which can be served until the connection is closed by the server.
- maxLifeTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
- maxLifeTime() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
-
- maxPayloadSize() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns the configured capacity of the datagram packet buffer.
- maxPayloadSize(int) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets the capacity of the datagram packet buffer (in bytes).
- maxPendingAcquireSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Get the maximum number of Pool.acquire()
this Pool can queue in a pending state
when no available resource is immediately handy (and the Pool cannot allocate more
resources).
- maxQueriesPerResolve() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns the configured maximum allowed number of DNS queries to send when resolving a host name.
- maxQueriesPerResolve(int) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets the maximum allowed number of DNS queries to send when resolving a host name.
- maxSize(long) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
-
- maxSize() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
-
- maxStreamDataBidirectionalLocal(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
-
Set the initial maximum data limit for local bidirectional streams.
- maxStreamDataBidirectionalLocal() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
-
Return the configured initial maximum data limit for local bidirectional streams.
- maxStreamDataBidirectionalRemote(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
-
Set the initial maximum data limit for remote bidirectional streams.
- maxStreamDataBidirectionalRemote() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
-
Return the configured initial maximum data limit for remote bidirectional streams.
- maxStreamDataUnidirectional(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
-
Set the initial maximum data limit for unidirectional streams.
- maxStreamDataUnidirectional() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
-
Return the configured initial maximum data limit for unidirectional streams.
- maxStreams(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
-
The connection is marked for closing once the number of all-time streams reaches maxStreams
.
- maxStreams() - Method in class reactor.netty.http.Http2SettingsSpec
-
Returns the configured maxStreams
value or null.
- maxStreamsBidirectional(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
-
Set the initial maximum stream limit for bidirectional streams.
- maxStreamsBidirectional() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
-
Return the configured initial maximum stream limit for bidirectional streams.
- maxStreamsUnidirectional(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
-
Set the initial maximum stream limit for unidirectional streams.
- maxStreamsUnidirectional() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
-
Return the configured initial maximum stream limit for unidirectional streams.
- MeterKey - Class in reactor.netty.channel
-
Contains meters' tags values.
- MeterKey(String, String, String, String) - Constructor for class reactor.netty.channel.MeterKey
-
- MeterKey(String, String, String, String, String) - Constructor for class reactor.netty.channel.MeterKey
-
Creates a new meter key.
- method() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return the configured request method.
- method() - Method in interface reactor.netty.http.HttpInfos
-
Returns the resolved request method (HTTP 1.1 etc.).
- method() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
-
Returns the name of this method, (e.g.
- method() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the name of this method, (e.g.
- METHOD - Static variable in class reactor.netty.Metrics
-
- metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient
-
Whether to enable metrics to be collected and registered in Micrometer's
globalRegistry
under the name
Metrics.HTTP_CLIENT_PREFIX
.
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClient
-
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient
-
Specifies whether the metrics are enabled on the
HttpClient
.
- metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
-
Whether to enable metrics to be collected and registered in Micrometer's
globalRegistry
under the name
Metrics.HTTP_SERVER_PREFIX
.
- metrics(boolean, Function<String, String>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
-
Whether to enable metrics to be collected and registered in Micrometer's
globalRegistry
under the name
Metrics.HTTP_SERVER_PREFIX
.
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.server.HttpServer
-
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
-
Specifies whether the metrics are enabled on the
HttpServer
.
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
-
Specifies whether the metrics are enabled on the
HttpServer
.
- Metrics - Class in reactor.netty.internal.util
-
Utility class around instrumentation and metrics with Micrometer.
- Metrics() - Constructor for class reactor.netty.internal.util.Metrics
-
- Metrics - Class in reactor.netty
-
Constants and utilities around metrics.
- Metrics() - Constructor for class reactor.netty.Metrics
-
- metrics(boolean) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
- metrics(boolean, Supplier<? extends ConnectionProvider.MeterRegistrar>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
- metrics(boolean) - Method in class reactor.netty.tcp.TcpClient
-
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpClient
-
- metrics(boolean) - Method in class reactor.netty.tcp.TcpServer
-
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpServer
-
- metrics(boolean) - Method in class reactor.netty.transport.Transport
-
Whether to enable metrics to be collected and registered in Micrometer's
globalRegistry
.
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.transport.Transport
-
Specifies whether the metrics are enabled on the
Transport
.
- metrics(boolean) - Method in class reactor.netty.udp.UdpClient
-
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpClient
-
- metrics(boolean) - Method in class reactor.netty.udp.UdpServer
-
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpServer
-
- metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClientConfig
-
- metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.server.HttpServerConfig
-
- metricsRecorder() - Method in class reactor.netty.transport.TransportConfig
-
- metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.transport.TransportConfig
-
- metricsRecorderInternal() - Method in class reactor.netty.transport.TransportConfig
-
- MicrometerChannelMetricsHandler - Class in reactor.netty.channel
-
- MicrometerChannelMetricsRecorder - Class in reactor.netty.channel
-
- MicrometerChannelMetricsRecorder(String, String) - Constructor for class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- MicrometerChannelMetricsRecorder(String, String, boolean) - Constructor for class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- MicrometerHttpMetricsRecorder - Class in reactor.netty.http
-
- MicrometerHttpMetricsRecorder(String, String) - Constructor for class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- MicrometerHttpMetricsRecorder(String, String, boolean) - Constructor for class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- minCompressionSize() - Method in class reactor.netty.http.server.HttpServerConfig
-
Compression is performed once response size exceeds the minimum compression size in bytes.
- minConnections(int) - Method in interface reactor.netty.http.client.Http2AllocationStrategy.Builder
-
Configures the minimum number of live connections to keep in the pool (can be the best effort).
- multicast() - Method in class reactor.netty.ByteBufFlux
-
Allow multiple consumers downstream of the flux while also disabling auto memory
release on each buffer published (retaining in order to prevent premature recycling).
- multipart(boolean) - Method in interface reactor.netty.http.client.HttpClientForm
-
Define if this request will be encoded as Multipart.
- mutate() - Method in interface reactor.netty.resources.ConnectionProvider
-
- mutate() - Method in class reactor.netty.resources.PooledConnectionProvider
-
- mutate() - Method in class reactor.netty.tcp.TcpResources
-
- param(CharSequence) - Method in interface reactor.netty.http.server.HttpServerRequest
-
URI parameter captured via {}
e.g.
- params() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns all URI parameters captured via {}
e.g.
- paramsResolver(Function<? super String, Map<String, String>>) - Method in interface reactor.netty.http.server.HttpServerRequest
-
Specifies a params resolver.
- parentChannelInitializer() - Method in class reactor.netty.incubator.quic.QuicClientConfig
-
- parentChannelInitializer() - Method in class reactor.netty.incubator.quic.QuicServerConfig
-
- parseAddress(String, int) - Static method in class reactor.netty.transport.AddressUtils
-
Parse unresolved InetSocketAddress.
- parseAddress(String, int, boolean) - Static method in class reactor.netty.transport.AddressUtils
-
Parse unresolved InetSocketAddress.
- parseHttpAfterConnectRequest(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
-
Configure whether the HTTP decoding will continue even after HTTP CONNECT.
- password(Function<? super String, ? extends String>) - Method in interface reactor.netty.transport.ProxyProvider.Builder
-
A function to supply the proxy's password from the username.
- patch() - Method in class reactor.netty.http.client.HttpClient
-
- path() - Method in interface reactor.netty.DisposableServer
-
Returns the server's path to the domain socket.
- path() - Method in interface reactor.netty.http.HttpInfos
-
Returns the decoded path portion from the
HttpInfos.uri()
without the leading and trailing '/' if present.
- PENDING_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The number of requests that are waiting for a connection.
- PENDING_STREAMS - Static variable in class reactor.netty.Metrics
-
The number of requests that are waiting for opening HTTP/2 stream.
- PENDING_TASKS - Static variable in class reactor.netty.Metrics
-
The number of tasks that are pending for processing on an event loop.
- pendingAcquireMaxCount(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
Set the options to use for configuring
ConnectionProvider
the maximum number of registered
requests for acquire to keep in a pending queue
When invoked with -1 the pending queue will not have upper limit.
- pendingAcquireSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
-
Measure the current number of "pending" acquire Monos in the Pool.
- pendingAcquireTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
Set the options to use for configuring
ConnectionProvider
acquire timeout (resolution: ms).
- pendingAcquireTimer(BiFunction<Runnable, Duration, Disposable>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
-
- permitGranted() - Method in class reactor.netty.http.client.Http2AllocationStrategy
-
- permitGranted() - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
-
Returns the best estimate of the number of permits currently granted, between 0 and
Integer.MAX_VALUE
.
- permitMaximum() - Method in class reactor.netty.http.client.Http2AllocationStrategy
-
- permitMaximum() - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
-
Returns the maximum number of permits this strategy can grant in total, or
Integer.MAX_VALUE
for unbounded.
- permitMinimum() - Method in class reactor.netty.http.client.Http2AllocationStrategy
-
- permitMinimum() - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
-
Return the minimum number of permits this strategy tries to maintain granted
(reflecting a minimal size for the pool), or 0
for scale-to-zero.
- POOL_ACQUIRE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
-
Default acquisition timeout (milliseconds) before error.
- POOL_GET_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty
-
Default getPermitsSamplingRate
(between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy
.
- POOL_LEASING_STRATEGY - Static variable in class reactor.netty.ReactorNetty
-
Default leasing strategy (fifo, lifo), fallback to fifo.
- POOL_MAX_CONNECTIONS - Static variable in class reactor.netty.ReactorNetty
-
Default max connections.
- POOL_MAX_IDLE_TIME - Static variable in class reactor.netty.ReactorNetty
-
Default max idle time, fallback - max idle time is not specified.
- POOL_MAX_LIFE_TIME - Static variable in class reactor.netty.ReactorNetty
-
Default max life time, fallback - max life time is not specified.
- POOL_RETURN_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty
-
Default returnPermitsSamplingRate
(between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy
.
- PooledConnectionProvider<T extends Connection> - Class in reactor.netty.resources
-
- PooledConnectionProvider(ConnectionProvider.Builder) - Constructor for class reactor.netty.resources.PooledConnectionProvider
-
- PooledConnectionProvider.PoolFactory<T extends Connection> - Class in reactor.netty.resources
-
- poolFactory(SocketAddress) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- port() - Method in interface reactor.netty.DisposableServer
-
Returns this server's port.
- port(int) - Method in class reactor.netty.http.client.HttpClient
-
The port to which this client should connect.
- port(int) - Method in class reactor.netty.http.server.HttpServer
-
The port to which this server should bind.
- port(int) - Method in class reactor.netty.incubator.quic.QuicClient
-
The port to which this client should connect.
- port(int) - Method in class reactor.netty.incubator.quic.QuicServer
-
The port to which this server should bind.
- port(int) - Method in class reactor.netty.tcp.TcpClient
-
The port to which this client should connect.
- port(int) - Method in class reactor.netty.tcp.TcpServer
-
The port to which this server should bind.
- port(int) - Method in class reactor.netty.transport.ClientTransport
-
The port to which this client should connect.
- port(int) - Method in interface reactor.netty.transport.ProxyProvider.Builder
-
The proxy port to connect to.
- port(int) - Method in class reactor.netty.transport.ServerTransport
-
The port to which this server should bind.
- port(int) - Method in class reactor.netty.udp.UdpClient
-
The port to which this client should connect.
- port(int) - Method in class reactor.netty.udp.UdpServer
-
The port to which this server should bind.
- post() - Method in class reactor.netty.http.client.HttpClient
-
- post(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP POST on the passed path to be used as a routing condition.
- PostHeadersNettyOutbound(Mono<Void>, HttpOperations<?, ?>, ByteBuf) - Constructor for class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- PREDICATE_GROUP_FLUSH - Static variable in class reactor.netty.ReactorNetty
-
- PrematureCloseException - Exception in reactor.netty.http.client
-
- protocol() - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- protocol(HttpProtocol...) - Method in class reactor.netty.http.client.HttpClient
-
The HTTP protocol to support.
- protocol() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
-
Returns the protocol version, (e.g.
- protocol(HttpProtocol...) - Method in class reactor.netty.http.server.HttpServer
-
The HTTP protocol to support.
- protocol() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns the inbound protocol and version.
- protocol() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the protocol version, (e.g.
- protocols() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return the HTTP protocol to support.
- protocols() - Method in class reactor.netty.http.server.HttpServerConfig
-
Return the HTTP protocol to support.
- protocols(String) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
-
Sets sub-protocol to use in websocket handshake signature.
- protocols() - Method in interface reactor.netty.http.websocket.WebsocketSpec
-
Returns the configured sub protocols.
- protocols() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
-
- proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.tcp.TcpClient
-
- proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.transport.ClientTransport
-
Apply a proxy configuration.
- PROXY_ADDRESS - Static variable in class reactor.netty.Metrics
-
- ProxyHandler - Static variable in interface reactor.netty.NettyPipeline
-
- ProxyLoggingHandler - Static variable in interface reactor.netty.NettyPipeline
-
- proxyProtocol(ProxyProtocolSupportType) - Method in class reactor.netty.http.server.HttpServer
-
Specifies whether support for the "HAProxy proxy protocol"
for deriving information about the address of the remote peer is enabled.
- ProxyProtocolDecoder - Static variable in interface reactor.netty.NettyPipeline
-
- ProxyProtocolReader - Static variable in interface reactor.netty.NettyPipeline
-
- proxyProtocolSupportType() - Method in class reactor.netty.http.server.HttpServerConfig
-
Return the supported type for the "HAProxy proxy protocol"
.
- ProxyProtocolSupportType - Enum in reactor.netty.http.server
-
Proxy protocol support type, this enum class defines how the HttpServer handles proxy protocol.
- proxyProvider(ProxyProvider) - Method in class reactor.netty.http.client.HttpClientConfig
-
- proxyProvider() - Method in class reactor.netty.transport.ClientTransportConfig
-
- proxyProvider(ProxyProvider) - Method in class reactor.netty.transport.ClientTransportConfig
-
- ProxyProvider - Class in reactor.netty.transport
-
Proxy configuration.
- ProxyProvider.AddressSpec - Interface in reactor.netty.transport
-
- ProxyProvider.Builder - Interface in reactor.netty.transport
-
- ProxyProvider.Proxy - Enum in reactor.netty.transport
-
Proxy Type.
- ProxyProvider.TypeSpec - Interface in reactor.netty.transport
-
- proxyWithSystemProperties() - Method in class reactor.netty.transport.ClientTransport
-
Set up a proxy from the java system properties.
- pushEnabled() - Method in class reactor.netty.http.Http2SettingsSpec
-
Returns the configured SETTINGS_ENABLE_PUSH
value or null.
- put() - Method in class reactor.netty.http.client.HttpClient
-
- put(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
Listens for HTTP PUT on the passed path to be used as a routing condition.
- ReactiveBridge - Static variable in interface reactor.netty.NettyPipeline
-
- reactor.netty - package reactor.netty
-
Main Reactor Netty Contracts used by all client and server implementations.
- reactor.netty.channel - package reactor.netty.channel
-
Netty <-> Reactive Streams bridge via channel handler.
- reactor.netty.contextpropagation - package reactor.netty.contextpropagation
-
This package contains context propagation utilities.
- reactor.netty.http - package reactor.netty.http
-
Common components for writing HTTP-based clients and servers using Reactor
abstractions.
- reactor.netty.http.client - package reactor.netty.http.client
-
Http Client abstractions and factory.
- reactor.netty.http.logging - package reactor.netty.http.logging
-
Http message log factory.
- reactor.netty.http.observability - package reactor.netty.http.observability
-
- reactor.netty.http.server - package reactor.netty.http.server
-
Http Server abstractions and factory.
- reactor.netty.http.server.logging - package reactor.netty.http.server.logging
-
Http access log.
- reactor.netty.http.websocket - package reactor.netty.http.websocket
-
Common components for Websocket using Reactor abstractions.
- reactor.netty.incubator.quic - package reactor.netty.incubator.quic
-
Components for writing QUIC-based clients and servers using Reactor abstractions.
- reactor.netty.internal.util - package reactor.netty.internal.util
-
Reactor Netty internal utilities.
- reactor.netty.observability - package reactor.netty.observability
-
This package contains core tracing observation handlers.
- reactor.netty.resources - package reactor.netty.resources
-
- reactor.netty.tcp - package reactor.netty.tcp
-
Components for writing TCP-based clients and servers using Reactor abstractions.
- reactor.netty.transport - package reactor.netty.transport
-
Transport builders for clients and servers.
- reactor.netty.transport.logging - package reactor.netty.transport.logging
-
- reactor.netty.udp - package reactor.netty.udp
-
Components for writing UDP-based clients and servers using Reactor abstractions.
- ReactorNetty - Class in reactor.netty
-
Internal helpers for reactor-netty contracts.
- ReactorNettyHandlerContext - Interface in reactor.netty.observability
-
Abstraction over all Reactor Netty contexts.
- ReactorNettyHttpMessageLogFactory - Class in reactor.netty.http.logging
-
- ReactorNettyHttpMessageLogFactory() - Constructor for class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
-
- ReactorNettyPropagatingReceiverTracingObservationHandler - Class in reactor.netty.http.observability
-
Reactor Netty specific PropagatingReceiverTracingObservationHandler
.
- ReactorNettyPropagatingReceiverTracingObservationHandler(Tracer, Propagator) - Constructor for class reactor.netty.http.observability.ReactorNettyPropagatingReceiverTracingObservationHandler
-
- ReactorNettyPropagatingSenderTracingObservationHandler - Class in reactor.netty.http.observability
-
Reactor Netty specific PropagatingSenderTracingObservationHandler
.
- ReactorNettyPropagatingSenderTracingObservationHandler(Tracer, Propagator) - Constructor for class reactor.netty.http.observability.ReactorNettyPropagatingSenderTracingObservationHandler
-
- ReactorNettyTimerObservationHandler - Class in reactor.netty.observability
-
Reactor Netty timer observation handler.
- ReactorNettyTimerObservationHandler(MeterRegistry) - Constructor for class reactor.netty.observability.ReactorNettyTimerObservationHandler
-
- ReactorNettyTracingObservationHandler - Class in reactor.netty.observability
-
Abstraction over all Reactor Netty handlers.
- ReactorNettyTracingObservationHandler(Tracer) - Constructor for class reactor.netty.observability.ReactorNettyTracingObservationHandler
-
- readableType() - Method in class reactor.netty.contextpropagation.ChannelContextAccessor
-
- readTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer
-
Specifies the maximum duration allowed between each network-level read operation while reading a given request
content (resolution: ms).
- readTimeout() - Method in class reactor.netty.http.server.HttpServerConfig
-
Return the configured read timeout for the request or null.
- ReadTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
-
- readValue(Channel, Object) - Method in class reactor.netty.contextpropagation.ChannelContextAccessor
-
- readValues(Channel, Predicate<Object>, Map<Object, Object>) - Method in class reactor.netty.contextpropagation.ChannelContextAccessor
-
- rebind(Connection) - Method in interface reactor.netty.Connection
-
Bind a new
Connection
reference or null to the channel
attributes only if this instance is currently bound.
- receive() - Method in class reactor.netty.channel.ChannelOperations
-
- receive() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
-
Negotiate a websocket upgrade and extract a flux from the underlying
WebsocketInbound
.
- receive() - Method in interface reactor.netty.NettyInbound
-
A
Flux
extension that allows for extra decoding operators.
- receiveCloseStatus() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Receive the close status code and reason if sent by the remote peer,
or empty if the connection completes otherwise.
- receiveContent() - Method in interface reactor.netty.http.server.HttpServerRequest
-
- receiveForm() - Method in interface reactor.netty.http.server.HttpServerRequest
-
When the request is
POST
and have
Content-Type
with value
application/x-www-form-urlencoded
or
multipart/form-data
,
returns a
Flux
of
HttpData
containing received
Attribute
/
FileUpload
.
- receiveForm(Consumer<HttpServerFormDecoderProvider.Builder>) - Method in interface reactor.netty.http.server.HttpServerRequest
-
When the request is
POST
and have
Content-Type
with value
application/x-www-form-urlencoded
or
multipart/form-data
,
returns a
Flux
of
HttpData
containing received
Attribute
/
FileUpload
.
- receiveFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
- receiveObject() - Method in class reactor.netty.channel.ChannelOperations
-
- receiveObject() - Method in interface reactor.netty.NettyInbound
-
- recordConnectTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the time that is spent for connecting to the remote address.
- recordConnectTime(SocketAddress, SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the time that is spent for connecting to the remote address.
- recordConnectTime(ContextView, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Records the time that is spent for connecting to the remote address.
- recordConnectTime(ContextView, SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Records the time that is spent for connecting to the remote address.
- recordConnectTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- recordConnectTime(SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- recordConnectTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordConnectTime(SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordDataReceived(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the amount of the data that is received, in bytes.
- recordDataReceived(SocketAddress, SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the amount of the data that is received, in bytes.
- recordDataReceived(ContextView, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Records the amount of the data that is received, in bytes.
- recordDataReceived(ContextView, SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Records the amount of the data that is received, in bytes.
- recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- recordDataReceived(SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordDataReceived(SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordDataReceived(ContextView, SocketAddress, SocketAddress, String, long) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Records the amount of the data that is received, in bytes.
- recordDataReceived(SocketAddress, SocketAddress, String, long) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- recordDataReceived(SocketAddress, SocketAddress, String, long) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the amount of the data that is received, in bytes.
- recordDataReceived(ContextView, SocketAddress, String, long) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
-
Records the amount of the data that is received, in bytes.
- recordDataReceived(SocketAddress, String, long) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
-
- recordDataReceived(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder
-
Records the amount of the data that is received, in bytes.
- recordDataReceived(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- recordDataReceivedTime(ContextView, SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Records the time that is spent in consuming incoming data.
- recordDataReceivedTime(ContextView, SocketAddress, SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Records the time that is spent in consuming incoming data.
- recordDataReceivedTime(SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- recordDataReceivedTime(SocketAddress, SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- recordDataReceivedTime(SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the time that is spent in consuming incoming data.
- recordDataReceivedTime(SocketAddress, SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the time that is spent in consuming incoming data.
- recordDataReceivedTime(ContextView, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
-
Records the time that is spent in consuming incoming data.
- recordDataReceivedTime(String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
-
- recordDataReceivedTime(String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Records the time that is spent in consuming incoming data.
- recordDataSent(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the amount of the data that is sent, in bytes.
- recordDataSent(SocketAddress, SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the amount of the data that is sent, in bytes.
- recordDataSent(ContextView, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Records the amount of the data that is sent, in bytes.
- recordDataSent(ContextView, SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Records the amount of the data that is sent, in bytes.
- recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- recordDataSent(SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordDataSent(SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordDataSent(ContextView, SocketAddress, SocketAddress, String, long) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Records the amount of the data that is sent, in bytes.
- recordDataSent(SocketAddress, SocketAddress, String, long) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- recordDataSent(SocketAddress, SocketAddress, String, long) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the amount of the data that is sent, in bytes.
- recordDataSent(ContextView, SocketAddress, String, long) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
-
Records the amount of the data that is sent, in bytes.
- recordDataSent(SocketAddress, String, long) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
-
- recordDataSent(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder
-
Records the amount of the data that is sent, in bytes.
- recordDataSent(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- recordDataSentTime(ContextView, SocketAddress, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Records the time that is spent in sending outgoing data.
- recordDataSentTime(ContextView, SocketAddress, SocketAddress, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Records the time that is spent in sending outgoing data.
- recordDataSentTime(SocketAddress, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- recordDataSentTime(SocketAddress, SocketAddress, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- recordDataSentTime(SocketAddress, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the time that is spent in sending outgoing data.
- recordDataSentTime(SocketAddress, SocketAddress, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the time that is spent in sending outgoing data.
- recordDataSentTime(ContextView, String, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
-
Records the time that is spent in sending outgoing data.
- recordDataSentTime(String, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
-
- recordDataSentTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Records the time that is spent in sending outgoing data.
- recorder() - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- recorder() - Method in class reactor.netty.channel.ChannelMetricsHandler
-
- recorder() - Method in class reactor.netty.channel.MicrometerChannelMetricsHandler
-
- recordException(ChannelHandlerContext, SocketAddress) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- recordRead(ChannelHandlerContext, SocketAddress, long) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- recordResolveAddressTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the time that is spent for resolving the remote address.
- recordResolveAddressTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordResponseTime(ContextView, SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Records the total time for the request/response.
- recordResponseTime(ContextView, SocketAddress, SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
Records the total time for the request/response.
- recordResponseTime(SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- recordResponseTime(SocketAddress, SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
-
- recordResponseTime(SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the total time for the request/response.
- recordResponseTime(SocketAddress, SocketAddress, String, String, String, Duration) - Method in interface reactor.netty.http.client.HttpClientMetricsRecorder
-
Records the total time for the request/response.
- recordResponseTime(ContextView, String, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
-
Records the total time for the request/response.
- recordResponseTime(String, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
-
- recordResponseTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Records the total time for the request/response.
- recordServerConnectionActive(SocketAddress) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Record a new active in-use http connection.
- recordServerConnectionClosed(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records a just disconnected server connection.
- recordServerConnectionClosed(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordServerConnectionInactive(SocketAddress) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Record an inactive http connection.
- recordServerConnectionOpened(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records a just accepted server connection.
- recordServerConnectionOpened(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordStreamClosed(SocketAddress) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Record a closed HTTP/2 stream.
- recordStreamOpened(SocketAddress) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
-
Record an opened HTTP/2 stream.
- recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the time that is spent for TLS handshake.
- recordTlsHandshakeTime(SocketAddress, SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
-
Records the time that is spent for TLS handshake.
- recordTlsHandshakeTime(ContextView, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Records the time that is spent for TLS handshake.
- recordTlsHandshakeTime(ContextView, SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
Records the time that is spent for TLS handshake.
- recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- recordTlsHandshakeTime(SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
-
- recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordTlsHandshakeTime(SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
-
- recordWrite(ChannelHandlerContext, SocketAddress, long) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientInfos
-
Return the previous redirections or empty array.
- redirectHttpToHttps() - Method in class reactor.netty.http.server.HttpServerConfig
-
Returns true if that
HttpServer
will redirect HTTP to HTTPS by changing
the scheme only but otherwise leaving the port the same when SSL is enabled.
- redirectRequestBiConsumer() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return the configured redirect request
BiConsumer
or null.
- redirectRequestConsumer() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return the configured redirect request consumer or null.
- registerDefaultMetrics(String, SocketAddress, InstrumentedPool.PoolMetrics) - Method in class reactor.netty.resources.PooledConnectionProvider
-
- registerMetrics(String, String, SocketAddress, ConnectionPoolMetrics) - Method in interface reactor.netty.resources.ConnectionProvider.MeterRegistrar
-
Invoked when a connection pool is created.
- REGISTRY - Static variable in class reactor.netty.Metrics
-
- RELEASED - Static variable in interface reactor.netty.ConnectionObserver.State
-
Propagated when a connection has been released but not fully closed
(keep-alive or pooling)
- releaseTimestamp() - Method in interface reactor.netty.resources.ConnectionProvider.ConnectionMetadata
-
Returns a timestamp that denotes the order in which the connection was last released, to millisecond
precision.
- REMOTE_ADDRESS - Static variable in class reactor.netty.Metrics
-
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient
-
- remoteAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
-
Returns the address of the client that initiated the request, possibly null
in case of Unix Domain Sockets.
- remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
-
- remoteAddress() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.incubator.quic.QuicClient
-
The address to which this client should connect on each subscribe.
- remoteAddress() - Method in class reactor.netty.incubator.quic.QuicClientConfig
-
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
-
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.transport.ClientTransport
-
The address to which this client should connect on each subscribe.
- remoteAddress() - Method in class reactor.netty.transport.ClientTransportConfig
-
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
-
- removeHandler(String) - Method in interface reactor.netty.Connection
-
Remove a named handler if present and return this context.
- removeIf(Predicate<? super HttpRouteHandlerMetadata>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
- replaceHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection
-
Replace a named handler if present and return this context.
- replaceUnresolvedNumericIp(InetSocketAddress) - Static method in class reactor.netty.transport.AddressUtils
-
Replaces an unresolved InetSocketAddress with a resolved instance in the case that
the passed address is a numeric IP address (both IPv4 and IPv6 are supported).
- replaceWithResolved(InetSocketAddress) - Static method in class reactor.netty.transport.AddressUtils
-
Replaces an unresolved InetSocketAddress with a resolved instance in the case that
the passed address is unresolved.
- request(HttpMethod) - Method in class reactor.netty.http.client.HttpClient
-
Use the passed HTTP method to connect the
HttpClient
.
- requestHeader(CharSequence) - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the value of a request header with the specified name
or null
is case such request header does not exist.
- requestHeaders() - Method in interface reactor.netty.http.client.HttpClientInfos
-
Return outbound headers to be sent.
- requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest
-
- requestId() - Method in interface reactor.netty.http.HttpInfos
-
Return a unique id for the request.
- requestId() - Method in class reactor.netty.http.HttpOperations
-
- requestTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer
-
Specifies the maximum duration for reading a given request content (resolution: ms).
- requestTimeout() - Method in class reactor.netty.http.server.HttpServerConfig
-
Return the configured request timeout for the request or null.
- reset() - Static method in class reactor.netty.http.HttpResources
-
Reset http resources to default and return its instance.
- reset() - Static method in class reactor.netty.incubator.quic.QuicResources
-
Reset QUIC resources to default and return its instance.
- reset() - Static method in class reactor.netty.tcp.TcpResources
-
Reset TCP resources to default and return its instance.
- reset() - Static method in class reactor.netty.udp.UdpResources
-
Reset UDP resources to default and return its instance.
- resolveCache(DnsCache) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets the resolve cache to use for DNS resolution.
- resolveCache() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns the configured DNS resolver cache or null.
- resolvedAddressTypes(ResolvedAddressTypes) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets the list of the protocol families of the address resolved.
- resolvedAddressTypes() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns the configured list of the protocol families of the address resolved or null.
- resolvePath(String) - Static method in class reactor.netty.http.HttpOperations
-
Returns the decoded path portion from the provided uri
.
- resolver(AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpClient
-
- resolver(AddressResolverGroup<?>) - Method in class reactor.netty.transport.ClientTransport
-
- resolver(Consumer<NameResolverProvider.NameResolverSpec>) - Method in class reactor.netty.transport.ClientTransport
-
Apply a name resolver configuration.
- resolver() - Method in class reactor.netty.transport.ClientTransportConfig
-
- resolverInternal() - Method in class reactor.netty.http.client.HttpClientConfig
-
- resolverInternal() - Method in class reactor.netty.transport.ClientTransportConfig
-
- resourceUrl() - Method in interface reactor.netty.http.client.HttpClientInfos
-
Return the fully qualified URL of the requested resource.
- response() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- response(BiFunction<? super HttpClientResponse, ? super ByteBufFlux, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- RESPONSE_TIME - Static variable in class reactor.netty.Metrics
-
Total time for the request/response.
- responseConnection(BiFunction<? super HttpClientResponse, ? super Connection, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- responseContent() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- responseHeader(CharSequence) - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the value of a response header with the specified name
or null
is case such response header does not exist.
- responseHeaders() - Method in interface reactor.netty.http.client.HttpClientResponse
-
Return response HTTP headers.
- responseHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Returns the outbound HTTP headers, sent back to the clients.
- responseSingle(BiFunction<? super HttpClientResponse, ? super ByteBufMono, ? extends Mono<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
-
- responseTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
-
- responseTimeout(Duration) - Method in class reactor.netty.http.client.HttpClient
-
Specifies the maximum duration allowed between each network-level read operation while reading a given response
(resolution: ms).
- responseTimeout() - Method in class reactor.netty.http.client.HttpClientConfig
-
Return the configured response timeout or null.
- responseTimeout(Duration) - Method in interface reactor.netty.http.client.HttpClientRequest
-
Specifies the maximum duration allowed between each network-level read operation while reading a given response
(resolution: ms).
- ResponseTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
-
- retain() - Method in class reactor.netty.ByteBufFlux
-
Disable auto memory release on each buffer published, retaining in order to prevent
premature recycling when buffers are accumulated downstream (async).
- retain() - Method in class reactor.netty.ByteBufMono
-
Disable auto memory release on each signal published in order to prevent premature
recycling when buffers are accumulated downstream (async).
- retryTcpOnTimeout(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Specifies whether this resolver will also fallback to TCP if a timeout is detected.
- returnPermits(int) - Method in class reactor.netty.http.client.Http2AllocationStrategy
-
- returnPermits(int) - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
-
Update the strategy to indicate that N connections were discarded, potentially leaving space
for N new ones to be allocated.
- RIGHT - Static variable in interface reactor.netty.NettyPipeline
-
- roundRobinSelection(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
- route(Consumer<? super HttpServerRoutes>) - Method in class reactor.netty.http.server.HttpServer
-
- route(Predicate<? super HttpServerRequest>, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
-
A generic route predicate that if matched invoke the passed I/O handler.
- run() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpClient
-
- runOn(LoopResources) - Method in class reactor.netty.tcp.TcpClient
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpClient
-
- runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpServer
-
- runOn(LoopResources) - Method in class reactor.netty.tcp.TcpServer
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpServer
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.transport.ClientTransport
-
- runOn(EventLoopGroup) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Performs the communication with the DNS servers on the given
EventLoopGroup
.
- runOn(LoopResources) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
- runOn(LoopResources, boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
- runOn(EventLoopGroup) - Method in class reactor.netty.transport.Transport
-
- runOn(LoopResources) - Method in class reactor.netty.transport.Transport
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.transport.Transport
-
- runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpClient
-
- runOn(LoopResources) - Method in class reactor.netty.udp.UdpClient
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpClient
-
- runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpClient
-
- runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpServer
-
- runOn(LoopResources) - Method in class reactor.netty.udp.UdpServer
-
- runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpServer
-
- runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpServer
-
- safeRelease(Object) - Static method in class reactor.netty.ReactorNetty
-
- scheduler(Scheduler) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
-
Sets the scheduler to be used for offloading disk operations in the decoding phase.
- scheduler() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
-
Returns the configured scheduler to be used for offloading disk operations in the decoding phase.
- scheme() - Method in interface reactor.netty.http.server.ConnectionInformation
-
Returns the current protocol scheme.
- searchDomains(List<String>) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets the list of search domains of the resolver.
- searchDomains() - Method in class reactor.netty.transport.NameResolverProvider
-
Returns the configured list of search domains of the resolver or null.
- secure() - Method in class reactor.netty.http.client.HttpClient
-
Enable default sslContext support.
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.client.HttpClient
-
Apply an SSL configuration customization via the passed builder.
- secure(SslProvider) - Method in class reactor.netty.http.client.HttpClient
-
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.server.HttpServer
-
Apply an SSL configuration customization via the passed builder.
- secure(Consumer<? super SslProvider.SslContextSpec>, boolean) - Method in class reactor.netty.http.server.HttpServer
-
Apply an SSL configuration customization via the passed builder.
- secure(SslProvider) - Method in class reactor.netty.http.server.HttpServer
-
Applies an SSL configuration via the passed
SslProvider
.
- secure(SslProvider, boolean) - Method in class reactor.netty.http.server.HttpServer
-
Applies an SSL configuration via the passed
SslProvider
.
- secure() - Method in class reactor.netty.tcp.TcpClient
-
Enable default sslContext support.
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpClient
-
Apply an SSL configuration customization via the passed builder.
- secure(SslProvider) - Method in class reactor.netty.tcp.TcpClient
-
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpServer
-
Apply an SSL configuration customization via the passed builder.
- secure(SslProvider) - Method in class reactor.netty.tcp.TcpServer
-
Applies an SSL configuration via the passed
SslProvider
.
- selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketInbound
-
Returns the websocket subprotocol negotiated by the client and server during
the websocket handshake, or null if none was requested.
- selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Returns the websocket subprotocol negotiated by the client and server during
the websocket handshake, or null if none was requested.
- send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.channel.ChannelOperations
-
- send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
-
Configure a body to send on request.
- send(BiFunction<? super HttpClientRequest, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
-
Configure a body to send on request using the
NettyOutbound
sending
builder and returning a
Publisher
to signal end of the request.
- send(Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketSender
-
Configure headers to send on request using the returned
Publisher
to
signal end of the request.
- send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- send(Publisher<? extends ByteBuf>) - Method in class reactor.netty.http.HttpOperations
-
- send() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sends the HTTP headers and empty content thus delimiting a full empty body http response.
- send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
- send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.NettyOutbound
-
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in interface reactor.netty.NettyOutbound
-
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendByteArray(Publisher<? extends byte[]>) - Method in interface reactor.netty.NettyOutbound
-
Sends bytes to the peer, listens for any error on write and closes on terminal
signal (complete|error).
- sendClose() - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Prepare to send a close frame on subscribe then close the underlying channel.
- sendClose(int) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Prepare to send a close frame on subscribe then close the underlying channel.
- sendClose(int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Prepare to send a close frame on subscribe then close the underlying channel.
- sendClose(int, int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
Prepare to send a close frame on subscribe then close the underlying channel.
- sendFile(Path, long, long) - Method in class reactor.netty.http.HttpOperations
-
- sendFile(Path) - Method in interface reactor.netty.NettyOutbound
-
- sendFile(Path, long, long) - Method in interface reactor.netty.NettyOutbound
-
- sendFileChunked(Path, long, long) - Method in interface reactor.netty.NettyOutbound
-
Sends content from given
Path
using chunked read/write.
- sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
-
Prepare to send an HTTP Form including Multipart encoded Form which support
chunked file upload.
- sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>, Consumer<Flux<Long>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
-
Prepare to send an HTTP Form including Multipart encoded Form which support
chunked file upload.
- sendGroups(Publisher<? extends Publisher<? extends ByteBuf>>) - Method in interface reactor.netty.NettyOutbound
-
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendNotFound() - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.channel.ChannelOperations
-
- sendObject(Object) - Method in class reactor.netty.channel.ChannelOperations
-
- sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- sendObject(Object) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- sendObject(Object) - Method in class reactor.netty.http.HttpOperations
-
- sendObject(Publisher<?>) - Method in interface reactor.netty.NettyOutbound
-
Sends an object through Netty pipeline.
- sendObject(Publisher<?>, Predicate<Object>) - Method in interface reactor.netty.NettyOutbound
-
Sends an object through Netty pipeline.
- sendObject(Object) - Method in interface reactor.netty.NettyOutbound
-
Sends data to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendRedirect(String) - Method in interface reactor.netty.http.server.HttpServerResponse
-
- sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
-
- sendString(Publisher<? extends String>) - Method in interface reactor.netty.NettyOutbound
-
Sends String to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.NettyOutbound
-
Sends String to the peer, listens for any error on write and closes on terminal signal
(complete|error).
- sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in class reactor.netty.channel.ChannelOperations
-
- sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in interface reactor.netty.NettyOutbound
-
Binds a send to a starting/cleanup lifecycle
- sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Upgrades the connection to websocket.
- sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Upgrades the connection to websocket.
- ServerCookies - Class in reactor.netty.http.server
-
Cookies
holder from server request headers.
- serverNames(SNIServerName...) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
- ServerTransport<T extends ServerTransport<T,CONF>,CONF extends ServerTransportConfig<CONF>> - Class in reactor.netty.transport
-
- ServerTransport() - Constructor for class reactor.netty.transport.ServerTransport
-
- ServerTransportConfig<CONF extends TransportConfig> - Class in reactor.netty.transport
-
Encapsulate all necessary configuration for server transport.
- ServerTransportConfig(Map<ChannelOption<?>, ?>, Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.ServerTransportConfig
-
Default ServerTransportConfig with options.
- ServerTransportConfig(ServerTransportConfig<CONF>) - Constructor for class reactor.netty.transport.ServerTransportConfig
-
- set(ConnectionProvider) - Static method in class reactor.netty.http.HttpResources
-
Update pooling resources and return the global HTTP/1.x resources.
- set(LoopResources) - Static method in class reactor.netty.http.HttpResources
-
Update event loops resources and return the global HTTP/1.x resources.
- set(LoopResources) - Static method in class reactor.netty.incubator.quic.QuicResources
-
Update event loops resources and return the global QUIC resources.
- set(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpResources
-
Update pooling resources and return the global TCP resources.
- set(LoopResources) - Static method in class reactor.netty.tcp.TcpResources
-
Update event loops resources and return the global TCP resources.
- set(LoopResources) - Static method in class reactor.netty.udp.UdpResources
-
Update event loops resources and return the global UDP resources.
- setChannelContext(Channel, ContextView) - Static method in class reactor.netty.ReactorNetty
-
- setSniAsyncMappings(AsyncMapping<String, SslProvider>) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Sets the provided mappings of domain names to
SslProvider
.
- setSniMappings(Map<String, Consumer<? super SslProvider.SslContextSpec>>) - Method in interface reactor.netty.tcp.SslProvider.Builder
-
Sets the provided mappings of domain names to
SslProvider
builders.
- shouldProxy(SocketAddress) - Method in class reactor.netty.transport.ProxyProvider
-
Returns true when the given
SocketAddress
should be reached via the configured proxy.
- shutdown() - Static method in class reactor.netty.udp.UdpResources
-
Shutdown the global
UdpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- SHUTDOWN_QUIET_PERIOD - Static variable in class reactor.netty.ReactorNetty
-
Default quiet period that guarantees that the disposal of the underlying LoopResources
will not happen, fallback to 2 seconds.
- SHUTDOWN_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
-
Default maximum amount of time to wait until the disposal of the underlying LoopResources
regardless if a task was submitted during the quiet period, fallback to 15 seconds.
- shutdownLater() - Static method in class reactor.netty.udp.UdpResources
-
Prepare to shutdown the global
UdpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- shutdownLater(Duration, Duration) - Static method in class reactor.netty.udp.UdpResources
-
Prepare to shutdown the global
UdpResources
without resetting them,
effectively cleaning up associated resources without creating new ones.
- SMALL_CACHE_SIZE - Static variable in class reactor.netty.Metrics
-
The size of the small cache.
- sse() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Adds "text/event-stream" content-type for Server-Sent Events.
- SSL_CLIENT_DEBUG - Static variable in class reactor.netty.ReactorNetty
-
Default value whether the SSL debugging on the client side will be enabled/disabled,
fallback to SSL debugging disabled.
- SSL_HANDSHAKE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
-
Default SSL handshake timeout (milliseconds), fallback to 10 seconds.
- SSL_SERVER_DEBUG - Static variable in class reactor.netty.ReactorNetty
-
Default value whether the SSL debugging on the server side will be enabled/disabled,
fallback to SSL debugging disabled.
- sslContext() - Method in class reactor.netty.tcp.AbstractProtocolSslContextSpec
-
- sslContext() - Method in interface reactor.netty.tcp.SslProvider.ProtocolSslContextSpec
-
Create a new
SslContext
instance with the configured settings.
- sslContext(SslProvider.ProtocolSslContextSpec) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
-
SslContext builder that provides, specific for the protocol, default configuration
e.g.
- sslContext(SslContext) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
-
The SslContext to set when configuring SSL.
- sslContext(SslContextBuilder) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
-
- SslHandler - Static variable in interface reactor.netty.NettyPipeline
-
- SslLoggingHandler - Static variable in interface reactor.netty.NettyPipeline
-
- sslProvider() - Method in class reactor.netty.http.client.HttpClientConfig
-
- sslProvider() - Method in class reactor.netty.http.server.HttpServerConfig
-
- SslProvider - Class in reactor.netty.tcp
-
SSL Provider.
- sslProvider() - Method in class reactor.netty.tcp.TcpClientConfig
-
- sslProvider() - Method in class reactor.netty.tcp.TcpServerConfig
-
- SslProvider.Builder - Interface in reactor.netty.tcp
-
- SslProvider.DefaultConfigurationSpec - Interface in reactor.netty.tcp
-
- SslProvider.DefaultConfigurationType - Enum in reactor.netty.tcp
-
- SslProvider.ProtocolSslContextSpec - Interface in reactor.netty.tcp
-
SslContext builder that provides, specific for the protocol, default configuration.
- SslProvider.SslContextSpec - Interface in reactor.netty.tcp
-
- SslReader - Static variable in interface reactor.netty.NettyPipeline
-
- status() - Method in interface reactor.netty.http.client.HttpClientResponse
-
Return the resolved HTTP Response Status.
- status() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
-
Returns the response status, (e.g.
- status() - Method in interface reactor.netty.http.server.HttpServerResponse
-
Returns the assigned HTTP status.
- status(HttpResponseStatus) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets an HTTP status to be sent along with the headers.
- status(int) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Sets an HTTP status to be sent along with the headers.
- status() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
-
Returns the response status, (e.g.
- STATUS - Static variable in class reactor.netty.Metrics
-
- streamId() - Method in interface reactor.netty.incubator.quic.QuicStreamInfo
-
The id of the stream.
- streaming(boolean) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
-
When set to true
, the data is streamed directly from the parsed input buffer stream,
which means it is not stored either in memory or file.
- streaming() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
-
Returns whether the streaming mode is enabled.
- STREAMS_ACTIVE - Static variable in class reactor.netty.Metrics
-
The number of active HTTP/2 streams.
- streamType() - Method in interface reactor.netty.incubator.quic.QuicStreamInfo
-
Returns the QuicStreamType
of the stream.
- stringToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound
-
- subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufFlux
-
- subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufMono
-
- subscribe(Subscriber<? super Void>) - Method in interface reactor.netty.NettyOutbound
-
Subscribes a Void
subscriber to this outbound and trigger all eventual
parent outbound send.
- SUCCESS - Static variable in class reactor.netty.Metrics
-
- supportsContext(Observation.Context) - Method in class reactor.netty.http.observability.ReactorNettyPropagatingReceiverTracingObservationHandler
-
- supportsContext(Observation.Context) - Method in class reactor.netty.http.observability.ReactorNettyPropagatingSenderTracingObservationHandler
-
- supportsContext(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTimerObservationHandler
-
- supportsContext(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTracingObservationHandler
-
- tagSpan(ReceiverContext<HttpRequest>, Span) - Method in class reactor.netty.http.observability.ReactorNettyPropagatingReceiverTracingObservationHandler
-
- tagSpan(SenderContext<HttpRequest>, Span) - Method in class reactor.netty.http.observability.ReactorNettyPropagatingSenderTracingObservationHandler
-
- tagSpan(Observation.Context, Span) - Method in class reactor.netty.observability.ReactorNettyTracingObservationHandler
-
- TCP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the TCP client's metrics
registered in Micrometer's global registry.
- TCP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
-
Name prefix that will be used for the TCP server's metrics
registered in Micrometer's global registry.
- TcpClient - Class in reactor.netty.tcp
-
A TcpClient allows building in a safe immutable way a TCP client that
is materialized and connecting when
TcpClient.connect()
is ultimately called.
- TcpClient() - Constructor for class reactor.netty.tcp.TcpClient
-
- TcpClientConfig - Class in reactor.netty.tcp
-
Encapsulate all necessary configuration for TCP client transport.
- tcpConfiguration(Function<? super TcpClient, ? extends TcpClient>) - Method in class reactor.netty.http.client.HttpClient
-
- tcpConfiguration(Function<? super TcpServer, ? extends TcpServer>) - Method in class reactor.netty.http.server.HttpServer
-
- TcpResources - Class in reactor.netty.tcp
-
Hold the default Tcp resources.
- TcpResources(LoopResources, ConnectionProvider) - Constructor for class reactor.netty.tcp.TcpResources
-
- TcpServer - Class in reactor.netty.tcp
-
A TcpServer allows building in a safe immutable way a TCP server that is materialized
and connecting when
ServerTransport.bind()
is ultimately called.
- TcpServer() - Constructor for class reactor.netty.tcp.TcpServer
-
- TcpServerConfig - Class in reactor.netty.tcp
-
Encapsulate all necessary configuration for TCP server transport.
- TcpSslContextSpec - Class in reactor.netty.tcp
-
SslContext builder that provides default configuration specific to TCP as follows:
SslProvider
will be set depending on
OpenSsl.isAvailable()
The default cipher suites will be used
Application protocol negotiation configuration is disabled
- terminate() - Method in class reactor.netty.channel.ChannelOperations
-
Final release/close (last packet).
- TEST_EXCEPTION - Static variable in exception reactor.netty.http.client.PrematureCloseException
-
- textFile(String, File) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute for a text file.
- textFile(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute for a text file.
- textFile(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute for a text file.
- textFile(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm
-
Add an HTTP File Upload attribute for a text file.
- then(ChannelPipelineConfigurer) - Method in interface reactor.netty.ChannelPipelineConfigurer
-
- then(ConnectionObserver) - Method in interface reactor.netty.ConnectionObserver
-
- then() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
-
- then() - Method in class reactor.netty.http.HttpOperations
-
- then() - Method in interface reactor.netty.NettyOutbound
-
Obtains a
Mono
of pending outbound(s) write completion.
- then(Publisher<Void>) - Method in interface reactor.netty.NettyOutbound
-
- then(Publisher<Void>, Runnable) - Method in interface reactor.netty.NettyOutbound
-
- THREAD_LOCAL_CACHES - Static variable in class reactor.netty.Metrics
-
The number of thread local caches.
- timestamp() - Method in interface reactor.netty.http.server.HttpServerRequest
-
Returns the time when the request was received.
- TLS_HANDSHAKE_TIME - Static variable in class reactor.netty.Metrics
-
Time spent for TLS handshake.
- tlsMetricsHandler() - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
-
- tlsMetricsHandler() - Method in class reactor.netty.channel.ChannelMetricsHandler
-
- tlsMetricsHandler() - Method in class reactor.netty.channel.MicrometerChannelMetricsHandler
-
- TlsMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
-
- tokenHandler(QuicTokenHandler) - Method in class reactor.netty.incubator.quic.QuicServer
-
Configure the QuicTokenHandler
that is used to generate and validate tokens.
- tokenHandler() - Method in class reactor.netty.incubator.quic.QuicServerConfig
-
Return the configured QuicTokenHandler
or null.
- toLoggingHandler(String, LogLevel, Charset) - Method in enum reactor.netty.transport.logging.AdvancedByteBufFormat
-
Creates the matching LoggingHandler regarding the format.
- toPrettyHexDump(Object) - Static method in class reactor.netty.ReactorNetty
-
- toString() - Method in class reactor.netty.channel.ChannelOperations
-
- toString() - Method in class reactor.netty.http.HttpOperations
-
- toString() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
-
- toString() - Method in class reactor.netty.tcp.SslProvider
-
- toString() - Method in class reactor.netty.transport.ProxyProvider
-
- TOTAL_CONNECTIONS - Static variable in class reactor.netty.Metrics
-
The number of all connections, active or idle.
- trace(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
-
- trace(HttpMessageArgProvider) - Method in interface reactor.netty.http.logging.HttpMessageLogFactory
-
- trace(String, LogLevel) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
-
Sets a specific category and log level to be used by this resolver when generating a detailed trace
information in case of resolution failure.
- trailerHeaders() - Method in interface reactor.netty.http.client.HttpClientResponse
-
Return response trailer headers.
- trailerHeaders(Consumer<? super HttpHeaders>) - Method in interface reactor.netty.http.server.HttpServerResponse
-
Callback for setting outbound trailer headers.
- trailingHeaders() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
-
Returns the request/response trailing headers.
- Transport<T extends Transport<T,C>,C extends TransportConfig> - Class in reactor.netty.transport
-
An immutable transport builder for clients and servers.
- Transport() - Constructor for class reactor.netty.transport.Transport
-
- TransportConfig - Class in reactor.netty.transport
-
A basic configuration holder.
- TransportConfig(Map<ChannelOption<?>, ?>) - Constructor for class reactor.netty.transport.TransportConfig
-
Default TransportConfig with options.
- TransportConfig(Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.TransportConfig
-
Default TransportConfig with options.
- TransportConfig(TransportConfig) - Constructor for class reactor.netty.transport.TransportConfig
-
Create TransportConfig from an existing one.
- TransportConnector - Class in reactor.netty.transport
-
- TYPE - Static variable in class reactor.netty.Metrics
-
- type(ProxyProvider.Proxy) - Method in interface reactor.netty.transport.ProxyProvider.TypeSpec
-
The proxy type.
- validateHeaders - Variable in class reactor.netty.http.HttpDecoderSpec
-
- validateHeaders(boolean) - Method in class reactor.netty.http.HttpDecoderSpec
-
Configure whether to validate headers when decoding requests.
- validateHeaders() - Method in class reactor.netty.http.HttpDecoderSpec
-
Return the configuration whether to validate headers when decoding requests.
- valueOf(String) - Static method in enum reactor.netty.channel.ChannelMeters.ChannelMetersTags
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.channel.ChannelMeters.ConnectionsTotalMeterTags
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.channel.ChannelMeters
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.client.HttpClientState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.HttpProtocol
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.logging.HttpMessageType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.server.HttpServerState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.http.server.ProxyProtocolSupportType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType
-
Deprecated.
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.transport.logging.AdvancedByteBufFormat
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum reactor.netty.transport.ProxyProvider.Proxy
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum reactor.netty.channel.ChannelMeters.ChannelMetersTags
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.channel.ChannelMeters.ConnectionsTotalMeterTags
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.channel.ChannelMeters
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.client.HttpClientState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.HttpProtocol
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.logging.HttpMessageType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.server.HttpServerState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.http.server.ProxyProtocolSupportType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType
-
Deprecated.
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.transport.logging.AdvancedByteBufFormat
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum reactor.netty.transport.ProxyProvider.Proxy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- version(WebSocketVersion) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
-
Sets websocket version to use.
- version() - Method in interface reactor.netty.http.client.WebsocketClientSpec
-
Returns the configured WebSocket version.
- version() - Method in interface reactor.netty.http.HttpInfos
-
Returns the resolved request version (HTTP 1.1 etc).