Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- 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
- 
BaseChannelHandlerfor collecting metrics on protocol level.
- 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
- 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
- 
Enable or disable the access log and customize it through anAccessLogFactory.
- accessLog(Function<AccessLogArgProvider, AccessLog>) - Method in class reactor.netty.http.server.HttpServer
- 
Deprecated.
- AccessLog - Class in reactor.netty.http.server.logging
- 
Log the http access information into a Logger namedreactor.netty.http.server.AccessLogat INFO level.
- AccessLog(String, Object...) - Constructor for class reactor.netty.http.server.logging.AccessLog
- 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
- 
An interface to declare more concisely aFunctionthat apply anAccessLogby anAccessLogArgProvider.
- AccessLogHandler - Static variable in interface reactor.netty.NettyPipeline
- AccessLogHandlerFactory - Enum in reactor.netty.http.server.logging
- 
Use to create an access-log handler.
- ackDelayExponent() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured delay exponent used for ACKs or the default.
- ackDelayExponent(long) - Method in class reactor.netty.quic.QuicServer
- 
Set the delay exponent used for ACKs.
- acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in interface reactor.netty.resources.ConnectionProvider
- 
Return an existing or newConnectionon 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.
- activeMigration(boolean) - Method in class reactor.netty.quic.QuicServer
- 
Enable/disable active migration.
- activeStreamSize() - Method in interface reactor.netty.http.client.HttpConnectionPoolMetrics
- 
Measure the current number of active HTTP/2 or HTTP/3 streams in the connection pool.
- adapt() - Method in class reactor.netty.http.server.compression.HttpCompressionOptionsSpec
- 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
- 
Deprecated.as of 1.0.17. UseConnection.addHandlerFirst(ChannelHandler)orConnection.addHandlerLast(ChannelHandler). This method will be removed in version 1.2.0.
- addHandler(String, ChannelHandler) - Method in interface reactor.netty.Connection
- 
Deprecated.as of 1.0.17. UseConnection.addHandlerFirst(String, ChannelHandler)orConnection.addHandlerLast(String, ChannelHandler). This method will be removed in version 1.2.0.
- 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 newSslProviderwith a prepending handler configurator callback to inject default settings to an existing provider configuration.
- addHandlerFirst(ChannelHandler) - Method in interface reactor.netty.Connection
- 
Add aChannelHandlerto the beginning of the "user"ChannelPipeline, that is just after the reactor-added codecs.
- addHandlerFirst(String, ChannelHandler) - Method in interface reactor.netty.Connection
- 
Add aChannelHandlerto the beginning of the "user"ChannelPipeline, that is just after the reactor-added codecs.
- addHandlerLast(ChannelHandler) - Method in interface reactor.netty.Connection
- 
Add aChannelHandlerto the end of the "user"ChannelPipeline, that is just before the reactor-added handlers likeNettyPipeline.ReactiveBridge.
- addHandlerLast(String, ChannelHandler) - Method in interface reactor.netty.Connection
- 
Add aChannelHandlerto the end of the "user"ChannelPipeline, that is just before the reactor-added handlers likeNettyPipeline.ReactiveBridge.
- 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
- 
AddNettyPipeline.ChannelMetricsHandlerto the channel pipeline.
- addProxyHandler(Channel) - Method in class reactor.netty.transport.ProxyProvider
- addReactiveBridge(Channel, ChannelOperations.OnSetup, ConnectionObserver) - Static method in class reactor.netty.channel.ChannelOperations
- 
AddNettyPipeline.ReactiveBridgehandler at the end ofChannelpipeline.
- 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
- 
Deprecated.as of 1.2.0. Prefer usingProxyProvider.AddressSpec.socketAddress(SocketAddress). This method will be removed in 1.3.0.
- address(Supplier<? extends InetSocketAddress>) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
- 
Deprecated.as of 1.2.0. Prefer usingProxyProvider.AddressSpec.socketAddress(SocketAddress). This method will be removed in 1.3.0.
- 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
- 
Deprecated.UseTcpClient.remoteAddress(Supplier). This method will be removed in version 1.1.0.
- 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'sNetUtil.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 anSslProviderbuilder.
- addSniMappings(Map<String, Consumer<? super SslProvider.SslContextSpec>>) - Method in interface reactor.netty.tcp.SslProvider.Builder
- 
Adds the provided mappings of domain names toSslProviderbuilders to the existing mappings.
- addSslHandler(Channel, SocketAddress, boolean) - Method in class reactor.netty.tcp.SslProvider
- AdvancedByteBufFormat - Enum in reactor.netty.transport.logging
- 
Used to control the format and verbosity of logging forByteBufs andByteBufHolders.
- 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 thisWebsocketInboundinto 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 thisWebsocketInboundinto 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
- 
Returns the assignedByteBufAllocator.
- allocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
- 
Measure the current number of allocated resources in the pool, acquired or idle.
- allocationStrategy() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
- allocationStrategy(ConnectionProvider.AllocationStrategy<?>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Limits in how many connections can be allocated and managed by the pool are driven by the providedConnectionProvider.AllocationStrategy.
- 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() - Method in class reactor.netty.http.HttpDecoderSpec
- 
Return the configuration whether to allow duplicateContent-Lengthheaders.
- allowDuplicateContentLengths(boolean) - Method in class reactor.netty.http.HttpDecoderSpec
- 
Configure whether to allow duplicateContent-Lengthheaders.
- allowPartialChunks - Variable in class reactor.netty.http.HttpDecoderSpec
- allowPartialChunks() - Method in class reactor.netty.http.HttpDecoderSpec
- 
Return the configuration whether chunks can be split into multiple messages, if their chunk size exceeds the size of the input buffer.
- allowPartialChunks(boolean) - Method in class reactor.netty.http.HttpDecoderSpec
- 
Configure whether chunks can be split into multiple messages, if their chunk size exceeds the size of the input buffer.
- apply(CONF, List<? extends SocketAddress>) - Method in interface reactor.netty.transport.ClientTransport.ResolvedAddressSelector
- 
Selects the resolved addresses to be used for a connection.
- as(Class<T>) - Method in class reactor.netty.channel.ChannelOperations
- as(Class<T>) - Method in interface reactor.netty.Connection
- 
Return an existingConnectionthat must match the given type wrapper or null.
- asByteArray() - Method in class reactor.netty.ByteBufFlux
- 
Convert to a byte[] inboundFlux.
- asByteArray() - Method in class reactor.netty.ByteBufMono
- 
a byte[] inboundMono.
- asByteBuffer() - Method in class reactor.netty.ByteBufFlux
- 
Convert to aByteBufferinboundFlux.
- asByteBuffer() - Method in class reactor.netty.ByteBufMono
- 
aByteBufferinboundMono.
- 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
- 
Convert to anInputStreaminboundFlux
- asInputStream() - Method in class reactor.netty.ByteBufMono
- 
Convert to anInputStreaminboundMono
- 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() - Method in class reactor.netty.ByteBufMono
- asString(Charset) - Method in class reactor.netty.ByteBufFlux
- asString(Charset) - Method in class reactor.netty.ByteBufMono
- 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
- attr(String, String) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP Form attribute.
- attributes() - Method in class reactor.netty.transport.TransportConfig
- 
Return the read-only default channel attributes.
- AUTO - Enum constant in enum reactor.netty.http.server.ProxyProtocolSupportType
- 
Each connection of the sameHttpServerwill auto detect whether there is proxy protocol.
B
- baseDirectory() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
- 
Returns the configured directory where to store diskAttribute/FileUpload.
- baseDirectory(Path) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
- 
Sets the directory where to store diskAttribute/FileUpload.
- baseUrl() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return the configured base URL to use for this request/response or null.
- baseUrl(String) - Method in class reactor.netty.http.client.HttpClient
- 
Configure URI to use for this request/response.
- beforeMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
- beforeSend() - Static method in exception reactor.netty.channel.AbortedException
- bind() - Method in interface reactor.netty.Connection
- 
Bind theConnectionto the channel scope via an attribute.
- bind() - Method in class reactor.netty.quic.QuicServer
- bind() - Method in class reactor.netty.transport.ServerTransport
- bind() - Method in class reactor.netty.udp.UdpServer
- bind(TransportConfig, ChannelInitializer<Channel>, SocketAddress, boolean) - Static method in class reactor.netty.transport.TransportConnector
- 
Binds aChannel.
- bindAddress() - Method in class reactor.netty.transport.TransportConfig
- 
Return the localSocketAddresssupplier that will be bound or null.
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClientConfig
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.server.HttpServer
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpServer
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.transport.Transport
- 
Set a new local address to which this transport should bind on subscribe.
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.transport.TransportConfig
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpClient
- bindAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.udp.UdpServer
- bindAddressSupplier() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the configured supplier of local address to bind to or null.
- bindAddressSupplier(Supplier<? extends SocketAddress>) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Set a new local address supplier that supply the address to bind to.
- bindNow() - Method in class reactor.netty.quic.QuicServer
- 
Starts the server in a blocking fashion, and waits for it to finish initializing or the startup timeout expires (the startup timeout is45seconds).
- bindNow() - Method in class reactor.netty.transport.ServerTransport
- 
Starts the server in a blocking fashion, and waits for it to finish initializing or the startup timeout expires (the startup timeout is45seconds).
- bindNow() - Method in class reactor.netty.udp.UdpServer
- 
Starts the server in a blocking fashion, and waits for it to finish initializing or the startup timeout expires (the startup timeout is45seconds).
- bindNow(Duration) - Method in class reactor.netty.quic.QuicServer
- 
Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.
- bindNow(Duration) - Method in class reactor.netty.transport.ServerTransport
- 
Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.
- bindNow(Duration) - Method in class reactor.netty.udp.UdpServer
- 
Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.
- bindUntilJavaShutdown(Duration, Consumer<DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
- 
Start the server in a fully blocking fashion, not only waiting for it to initialize but also blocking during the full lifecycle of the server.
- blockSize(int) - Method in interface reactor.netty.http.server.compression.ZstdOption.Builder
- 
Sets the zstd block size.
- bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.tcp.TcpClient
- 
Deprecated.as of 0.9.10. Use the other methods exposed byTcpClientto achieve the same configurations. The method will be removed in version 1.1.0.
- build() - Method in interface reactor.netty.http.client.Http2AllocationStrategy.Builder
- 
Build a newHttp2AllocationStrategy.
- build() - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
- 
Builds newWebsocketClientSpec.
- build() - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Build a newHttp2SettingsSpec.
- build() - Method in interface reactor.netty.http.Http3SettingsSpec.Builder
- 
Build a newHttp3SettingsSpec.
- build() - Method in interface reactor.netty.http.server.compression.DeflateOption.Builder
- 
Build a newDeflateOption.
- build() - Method in interface reactor.netty.http.server.compression.GzipOption.Builder
- 
Build a newGzipOption.
- build() - Method in interface reactor.netty.http.server.compression.ZstdOption.Builder
- 
Build a newZstdOption.
- build() - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
- 
Builds newWebsocketServerSpec.
- build() - Method in class reactor.netty.resources.ConnectionProvider.Builder
- 
Builds new ConnectionProvider.
- build() - Method in interface reactor.netty.tcp.SslProvider.Builder
- 
Builds new SslProvider.
- build() - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Build a newNameResolverProvider.
- build() - Method in interface reactor.netty.transport.ProxyProvider.Builder
- 
Builds new ProxyProvider.
- builder() - Static method in class reactor.netty.http.client.Http2AllocationStrategy
- 
Creates a builder forHttp2AllocationStrategy.
- builder() - Static method in interface reactor.netty.http.client.WebsocketClientSpec
- 
Create builder with default properties.
 version =WebSocketVersion.V13
 protocols = null
 maxFramePayloadLength = 65536
 handlePing = false
 compress = false
 compressionAllowClientNoContext = false
 compressionRequestedServerNoContext = false
- builder() - Static method in class reactor.netty.http.Http2SettingsSpec
- 
Creates a builder forHttp2SettingsSpec.
- builder() - Static method in class reactor.netty.http.Http3SettingsSpec
- 
Creates a builder forHttp3SettingsSpec.
- builder() - Static method in class reactor.netty.http.server.compression.DeflateOption
- 
Creates a builder forDeflateOption.
- builder() - Static method in class reactor.netty.http.server.compression.GzipOption
- 
Creates a builder forGzipOption.
- builder() - Static method in class reactor.netty.http.server.compression.ZstdOption
- 
Creates a builder forZstdOption.
- builder() - Static method in interface reactor.netty.http.server.WebsocketServerSpec
- 
Create builder with default properties.
 protocols = null
 maxFramePayloadLength = 65536
 handlePing = false
 compress = false
 compressionAllowServerNoContext = false
 compressionPreferredClientNoContext = false
- builder() - Static method in class reactor.netty.tcp.SslProvider
- 
Creates a builder forSslProvider.
- builder() - Static method in class reactor.netty.transport.NameResolverProvider
- 
Creates a builder forNameResolverProvider.
- builder() - Static method in class reactor.netty.transport.ProxyProvider
- 
Creates a builder forProxyProvider.
- builder(String) - Static method in interface reactor.netty.resources.ConnectionProvider
- 
Creates a builder forConnectionProvider.
- Builder() - Constructor for class reactor.netty.http.websocket.WebsocketSpec.Builder
- BYTE_BUF_ALLOCATOR_PREFIX - Static variable in class reactor.netty.Metrics
- 
Name prefix that will be used for the ByteBufAllocator's metrics registered in Micrometer's global registry.
- ByteBufFlux - Class in reactor.netty
- ByteBufMono - Class in reactor.netty
- bytebufToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound
C
- 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.
- cause() - Method in interface reactor.netty.http.server.logging.error.ErrorLogArgProvider
- 
Returns the exception that occurred.
- cause() - Method in interface reactor.netty.http.server.logging.error.ErrorLogEvent
- 
Returns the throwable that occurred.
- channel() - Method in class reactor.netty.channel.ChannelOperations
- channel() - Method in interface reactor.netty.DisposableChannel
- 
Returns the underlyingChannel.
- 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
- ChannelContextAccessor() - Constructor for class reactor.netty.contextpropagation.ChannelContextAccessor
- channelGroup() - Method in class reactor.netty.transport.TransportConfig
- 
Return the configuredChannelGroupor null.
- 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 aChannelGroupto hold all active connected channels.
- 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.http.client.HttpClientConfig
- channelInitializer(ConnectionObserver, SocketAddress, boolean) - Method in class reactor.netty.http.server.HttpServerConfig
- channelInitializer(ConnectionObserver, SocketAddress, boolean) - Method in class reactor.netty.transport.TransportConfig
- 
Return theChannelInitializerthat will be used for initializing the channel pipeline.
- 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
- 
ChannelHandlerfor collecting metrics on protocol level.
- 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
- 
Create a newChannelOperationsattached to theChannel.
- ChannelOperations(Connection, ConnectionObserver, ChannelOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.channel.ChannelOperations
- ChannelOperations.OnSetup - Interface in reactor.netty.channel
- 
AChannelOperationsfactory.
- 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 associatedChannelOperations.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.http.client.HttpClientConfig
- channelType(boolean) - Method in class reactor.netty.http.server.HttpServerConfig
- channelType(boolean) - Method in class reactor.netty.quic.QuicServerConfig
- 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() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
- 
Returns the configured charset forAttribute/FileUpload.
- charset(Charset) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Set the FormCharset.
- charset(Charset) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
- childAttr(AttributeKey<A>, A) - Method in class reactor.netty.transport.ServerTransport
- 
Injects default attribute to the future childChannelconnections.
- 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
- 
Set or add the givenConnectionObserverfor each remote connection.
- childObserver() - Method in class reactor.netty.transport.ServerTransportConfig
- 
Return the configuredConnectionObserverif any orConnectionObserver.emptyListener()for each remote connection.
- childOption(ChannelOption<A>, A) - Method in class reactor.netty.transport.ServerTransport
- 
Injects default options to the future childChannelconnections.
- childOptions() - Method in class reactor.netty.transport.ServerTransportConfig
- 
Return the read-onlyChannelOptionmap 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 
- 
A generic clientTransportthat willClientTransport.connect()to a remote address and provide aConnection.
- ClientTransport() - Constructor for class reactor.netty.transport.ClientTransport
- ClientTransport.ResolvedAddressSelector<CONF> - Interface in reactor.netty.transport
- 
An interface for selecting resolved addresses based on configuration and available socket addresses.
- 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 delegatingEventLoopGroupwhich 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 providedComparatorto 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 theHttpServerRoutes.noComparator()method (which is the default).
- completeOncePreferredResolved(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Iftrue, the resolver notifies the returnedFutureas soon as all queries for the preferred address type are complete.
- 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
- compress(boolean) - Method in class reactor.netty.http.client.HttpClient
- 
Specifies whether compression (gzip, Brotli, and zstd) is enabled.
- 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(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(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(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 providedPredicatematches.
- compression(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse
- 
Enables/Disables compression handling (gzip/deflate) for the underlying response.
- compressionAllowClientNoContext() - Method in interface reactor.netty.http.client.WebsocketClientSpec
- 
Returns whether the server is allowed to activateclient_no_context_takeover.
- compressionAllowClientNoContext(boolean) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
- 
Allows the server to activateclient_no_context_takeoverDefault to false.
- compressionAllowServerNoContext() - Method in interface reactor.netty.http.server.WebsocketServerSpec
- 
Returns whether the client is allowed to activateserver_no_context_takeover.
- compressionAllowServerNoContext(boolean) - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
- 
Allows the client to activateserver_no_context_takeover.
- CompressionHandler - Static variable in interface reactor.netty.NettyPipeline
- compressionLevel(int) - Method in interface reactor.netty.http.server.compression.DeflateOption.Builder
- 
Sets the deflate compression level.
- compressionLevel(int) - Method in interface reactor.netty.http.server.compression.GzipOption.Builder
- 
Sets the gzip compression level.
- compressionLevel(int) - Method in interface reactor.netty.http.server.compression.ZstdOption.Builder
- 
Sets the zstd compression level.
- compressionPreferredClientNoContext() - Method in interface reactor.netty.http.server.WebsocketServerSpec
- 
Returns whether the server prefers to activateclient_no_context_takeover.
- compressionPreferredClientNoContext(boolean) - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
- 
Indicates if the server prefers to activateclient_no_context_takeoverif client is compatible with.
- compressionRequestedServerNoContext() - Method in interface reactor.netty.http.client.WebsocketClientSpec
- 
Returns whether the client needs to activateserver_no_context_takeover.
- compressionRequestedServerNoContext(boolean) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
- 
Indicates if the client needs to activateserver_no_context_takeoverif the server is compatible with.
- compressOptions(HttpCompressionOption...) - Method in class reactor.netty.http.server.HttpServer
- 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
- 
Return aTransportConfig.
- configure(SslHandler) - Method in class reactor.netty.tcp.SslProvider
- configure(Consumer<B>) - Method in interface reactor.netty.tcp.SslProvider.GenericSslContextSpec
- 
Configures the underlyingSslContext.
- configure(Consumer<B>) - Method in interface reactor.netty.tcp.SslProvider.GenericSslContextSpecWithSniSupport
- 
Configures the underlyingSslContext.
- configure(Consumer<QuicSslContextBuilder>) - Method in class reactor.netty.http.Http3SslContextSpec
- configure(Consumer<SslContextBuilder>) - Method in class reactor.netty.tcp.AbstractProtocolSslContextSpec
- 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
- congestionControlAlgorithm() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configuredQuicCongestionControlAlgorithmor the default.
- congestionControlAlgorithm(QuicCongestionControlAlgorithm) - Method in class reactor.netty.quic.QuicServer
- 
Set the congestion control algorithm to use.
- connect() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
- 
Negotiate a websocket upgrade and return aMonoofConnection.
- connect() - Method in class reactor.netty.quic.QuicClient
- connect() - Method in class reactor.netty.tcp.TcpClient
- connect() - Method in class reactor.netty.transport.ClientTransport
- connect() - Method in class reactor.netty.udp.UdpClient
- connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>) - Static method in class reactor.netty.transport.TransportConnector
- 
Connect aChannelto the remote peer.
- connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, EventLoop) - Static method in class reactor.netty.transport.TransportConnector
- 
Connect aChannelto the remote peer.
- connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, EventLoop, ContextView) - Static method in class reactor.netty.transport.TransportConnector
- 
Connect aChannelto the remote peer.
- connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, ContextView) - Static method in class reactor.netty.transport.TransportConnector
- 
Connect aChannelto the remote peer.
- 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 IOConnectionfor low-level IO access.
- Connection - Interface in reactor.netty
- 
Hold contextual information for the underlyingChannel.
- 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
- 
Return theChannelFactorywhich is used to createChannelinstances.
- 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, possiblynullin case of Unix Domain Sockets.
- connectionIdAddressGenerator() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configuredQuicConnectionIdGeneratoror the default.
- connectionIdAddressGenerator(QuicConnectionIdGenerator) - Method in class reactor.netty.quic.QuicServer
- 
Set theQuicConnectionIdGeneratorto use.
- 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() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns the information about the current connection.
- ConnectionInformation - Interface in reactor.netty.http.server
- 
Resolve information about the connection from which an http request is received.
- connectionObserver() - Method in class reactor.netty.transport.TransportConfig
- 
Return the configuredConnectionObserverif any orConnectionObserver.emptyListener().
- ConnectionObserver - Interface in reactor.netty
- 
Event listeners for connection lifecycle.
- ConnectionObserver.State - Interface in reactor.netty
- 
A marker interface for various state signals used inConnectionObserver.onStateChange(Connection, State)
- ConnectionPoolMetrics - Interface in reactor.netty.resources
- connectionProvider() - Method in class reactor.netty.http.client.HttpClientConfig
- connectionProvider() - Method in class reactor.netty.transport.ClientTransportConfig
- 
Return theConnectionProvider.
- ConnectionProvider - Interface in reactor.netty.resources
- 
AConnectionProviderwill produceConnection.
- ConnectionProvider.AllocationStrategy<A extends ConnectionProvider.AllocationStrategy<A>> - Interface in reactor.netty.resources
- ConnectionProvider.Builder - Class in reactor.netty.resources
- 
Build aConnectionProviderto cache and reuse a fixed maximum number ofConnection.
- 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, possiblynullin 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 - Enum constant in enum reactor.netty.channel.ChannelMeters
- 
The number of all opened connections on the server.
- 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.quic.QuicClient
- 
Block theQuicClientand return aQuicConnection.
- connectNow() - Method in class reactor.netty.tcp.TcpClient
- connectNow() - Method in class reactor.netty.transport.ClientTransport
- 
Block theClientTransportand return aConnection.
- connectNow() - Method in class reactor.netty.udp.UdpClient
- connectNow(Duration) - Method in class reactor.netty.quic.QuicClient
- 
Block theQuicClientand return aQuicConnection.
- connectNow(Duration) - Method in class reactor.netty.tcp.TcpClient
- connectNow(Duration) - Method in class reactor.netty.transport.ClientTransport
- 
Block theClientTransportand return aConnection.
- connectNow(Duration) - Method in class reactor.netty.udp.UdpClient
- connectProtocolEnabled() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configuredSETTINGS_ENABLE_CONNECT_PROTOCOLvalue or null.
- connectProtocolEnabled(boolean) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Sets theSETTINGS_ENABLE_CONNECT_PROTOCOLvalue.
- 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
- 
Return the data which is held by theHttpMessage.
- CONTENT - Enum constant in enum reactor.netty.http.logging.HttpMessageType
- 
RepresentsHttpContent.
- 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
- 
ContextViewaware class for recording metrics on protocol level.
- ContextAwareChannelMetricsRecorder() - Constructor for class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- ContextAwareHttpClientMetricsRecorder - Class in reactor.netty.http.client
- 
ContextViewaware class for collecting metrics on HTTP client level.
- ContextAwareHttpClientMetricsRecorder() - Constructor for class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
- ContextAwareHttpMetricsRecorder - Class in reactor.netty.http
- 
ContextViewaware class for recording metrics for HTTP protocol.
- ContextAwareHttpMetricsRecorder() - Constructor for class reactor.netty.http.ContextAwareHttpMetricsRecorder
- ContextAwareHttpServerMetricsRecorder - Class in reactor.netty.http.server
- 
ContextViewaware 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
- 
Deprecated.as of 1.1.0. UseHttpClient.cookie(Cookie)for configuring cookies. This will be removed in 2.0.0.
- cookieCodec(ClientCookieEncoder) - Method in class reactor.netty.http.client.HttpClient
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 supports only strict validation.
- cookieCodec(ClientCookieEncoder, ClientCookieDecoder) - Method in class reactor.netty.http.client.HttpClient
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 supports only strict validation.
- cookieCodec(ServerCookieEncoder) - Method in class reactor.netty.http.server.HttpServer
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 supports only strict validation.
- cookieCodec(ServerCookieEncoder, ServerCookieDecoder) - Method in class reactor.netty.http.server.HttpServer
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 supports only strict validation.
- cookieDecoder() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 supports only strict validation.
- cookieDecoder() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 supports only strict validation.
- cookieEncoder() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 supports only strict validation.
- cookieEncoder() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 supports only strict validation.
- 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.
- Cookies - Class in reactor.netty.http
- 
Store cookies for the http channel.
- Cookies(HttpHeaders, CharSequence, boolean, CookieDecoder) - Constructor for class reactor.netty.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() - Static method in class reactor.netty.http.client.HttpClient
- 
Prepare a pooledHttpClient.
- create() - Static method in class reactor.netty.http.server.HttpServer
- 
Prepare anHttpServer.
- create() - Static method in class reactor.netty.quic.QuicClient
- 
Prepare aQuicClient.
- create() - Static method in class reactor.netty.quic.QuicServer
- 
Prepare aQuicServer.
- create() - Static method in class reactor.netty.tcp.TcpClient
- 
Prepare a pooledTcpClient.
- create() - Static method in class reactor.netty.tcp.TcpServer
- 
Prepare aTcpServer.
- create() - Static method in class reactor.netty.udp.UdpClient
- 
Prepare aUdpClient.
- create() - Static method in class reactor.netty.udp.UdpServer
- 
Prepare aUdpServer.
- create(Function<AccessLogArgProvider, AccessLog>) - Method in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
- 
Create an access log handler,AccessLogHandlerH1orAccessLogHandlerH2.
- create(Object) - Static method in class reactor.netty.http.logging.HttpMessageArgProviderFactory
- 
CreatesHttpContentArgProviderbased on the provided HTTP object.
- create(String) - Static method in interface reactor.netty.resources.ConnectionProvider
- 
Create a newConnectionProviderto cache and reuse a fixed maximum number ofConnection.
- create(String) - Static method in interface reactor.netty.resources.LoopResources
- create(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider
- 
Create a newConnectionProviderto cache and reuse a fixed maximum number ofConnection.
- create(String, int, boolean) - Static method in interface reactor.netty.resources.ConnectionProvider
- 
Create a newConnectionProviderto cache and reuse a fixed maximum number ofConnection.
- 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(String, Object...) - Static method in class reactor.netty.http.server.logging.AccessLog
- create(String, Object...) - Static method in interface reactor.netty.http.server.logging.error.ErrorLog
- 
Creates a defaultErrorLogwith the given log format and arguments.
- create(Throwable) - Static method in interface reactor.netty.http.server.logging.error.ErrorLogEvent
- 
Creates a defaultErrorLogEventwith the given throwable.
- create(Connection, ConnectionObserver, Object) - Method in interface reactor.netty.channel.ChannelOperations.OnSetup
- 
Create a newChannelOperationsgiven a netty channel, a parentConnectionObserverand an optional message (nullable).
- create(ConnectionProvider) - Static method in class reactor.netty.http.client.HttpClient
- 
Prepare anHttpClient.
- create(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpClient
- 
Prepare aTcpClient.
- createDisposableAcquire(TransportConfig, ConnectionObserver, long, InstrumentedPool<T>, SocketAddress, MonoSink<Connection>, Context) - Method in class reactor.netty.resources.PooledConnectionProvider
- createDisposableAcquire(TransportConfig, ConnectionObserver, long, InstrumentedPool<T>, 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.
- createFilter(Predicate<ErrorLogArgProvider>) - Static method in interface reactor.netty.http.server.logging.error.ErrorLogFactory
- 
Helper method to create an error log factory that selectively enables error logs.
- createFilter(Predicate<ErrorLogArgProvider>, ErrorLogFactory) - Static method in interface reactor.netty.http.server.logging.error.ErrorLogFactory
- 
Helper method to create an error log factory that selectively enables error logs and customizes the format to apply.
- createInetSocketAddress(String, int, boolean) - Static method in class reactor.netty.transport.AddressUtils
- 
Creates InetSocketAddress instance.
- createPool(String, TransportConfig, PooledConnectionProvider.PoolFactory<T>, SocketAddress, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
- createPool(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(QuicStreamType, BiFunction<? super QuicInbound, ? super QuicOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.quic.QuicConnection
- 
Creates a stream.
- createStream(BiFunction<? super QuicInbound, ? super QuicOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.quic.QuicConnection
- 
Creates a bidirectional 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
- 
Connection listenerContext.
- currentContext() - Method in interface reactor.netty.http.client.HttpClientInfos
- 
Deprecated.UseHttpClientInfos.currentContextView(). This method will be removed in version 1.1.0.
- currentContextView() - Method in interface reactor.netty.http.client.HttpClientInfos
- 
Return the currentContextViewassociated with the Mono/Flux exposed viaHttpClient.ResponseReceiver.response()or related terminating API.
- currentObservation(ContextView) - Static method in class reactor.netty.Metrics
D
- daemon() - Method in class reactor.netty.quic.QuicResources
- daemon() - Method in interface reactor.netty.resources.LoopResources
- 
return true ifEventLoopGroupshould not be shutdown.
- daemon() - Method in class reactor.netty.tcp.TcpResources
- daemon() - Method in class reactor.netty.udp.UdpResources
- DATA_RECEIVED - Enum constant in enum reactor.netty.channel.ChannelMeters
- 
Amount of the data received, in bytes.
- 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 - Enum constant in enum reactor.netty.channel.ChannelMeters
- 
Amount of the data sent, in bytes.
- 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.
- datagram(int, int) - Method in class reactor.netty.quic.QuicServer
- 
If configured this will enable Datagram support.
- datagramChannelStrategy() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the configured customDnsNameResolverChannelStrategy.
- datagramChannelStrategy(DnsNameResolverChannelStrategy) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Sets the strategy that is used to determine how aDatagramChannelis used by the resolver for sending queries over UDP protocol.
- 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
- 
Generates a log message based on a givenHttpMessageArgProviderfor a log with a levelDEBUG.
- 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
- 
Returns the result of decoding theHttpMessage.
- 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_ALLOW_PARTIAL_CHUNKS - 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
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 does not support this configuration.
- 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, io_uring, 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
- 
Provides a globalAddressResolverGroupfromHttpResourcesthat is shared amongst all HTTP clients.
- defaultAddressResolverGroup() - Method in class reactor.netty.tcp.TcpClientConfig
- 
Provides a globalAddressResolverGroupfromTcpResourcesthat is shared amongst all TCP clients.
- defaultAddressResolverGroup() - Method in class reactor.netty.transport.ClientTransportConfig
- 
Provides a globalAddressResolverGroupthat is shared amongst all clients.
- defaultAddressResolverGroup() - Method in class reactor.netty.udp.UdpClientConfig
- 
Provides a globalAddressResolverGroupfromUdpResourcesthat is shared amongst all UDP clients.
- defaultChildObserver() - Method in class reactor.netty.transport.ServerTransportConfig
- 
Return the configured child lifecycleConnectionObserverif any orConnectionObserver.emptyListener().
- 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() - Method in class reactor.netty.tcp.TcpSslContextSpec
- defaultConnectionObserver() - Method in class reactor.netty.http.client.HttpClientConfig
- defaultConnectionObserver() - Method in class reactor.netty.quic.QuicClientConfig
- defaultConnectionObserver() - Method in class reactor.netty.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
- 
Return the configured defaultConnectionObserver.
- defaultConnectionObserver() - Method in class reactor.netty.udp.UdpServerConfig
- DefaultErrorLogHandler - Class in reactor.netty.http.server.logging.error
- 
Handler for logging errors that occur in the HTTP Server.
- DefaultErrorLogHandler(Function<ErrorLogArgProvider, ErrorLog>) - Constructor for class reactor.netty.http.server.logging.error.DefaultErrorLogHandler
- defaultLoggingHandler() - Method in class reactor.netty.http.client.HttpClientConfig
- defaultLoggingHandler() - Method in class reactor.netty.http.server.HttpServerConfig
- defaultLoggingHandler() - Method in class reactor.netty.quic.QuicClientConfig
- defaultLoggingHandler() - Method in class reactor.netty.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
- 
Return the defaultLoggingHandlerto wiretap this transport.
- 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.quic.QuicServerConfig
- defaultLoopResources() - Method in class reactor.netty.tcp.TcpClientConfig
- defaultLoopResources() - Method in class reactor.netty.tcp.TcpServerConfig
- defaultLoopResources() - Method in class reactor.netty.transport.TransportConfig
- 
Return the defaultLoopResourcesfor this transport.
- 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.quic.QuicClientConfig
- defaultMetricsRecorder() - Method in class reactor.netty.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.quic.QuicServerConfig
- 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
- 
Return the default callback if any orChannelPipelineConfigurer.emptyConfigurer().
- 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
- DeflateOption - Class in reactor.netty.http.server.compression
- 
Deflate compression option configuration.
- DeflateOption.Builder - Interface in reactor.netty.http.server.compression
- delegateConnectionPoolMetrics(InstrumentedPool.PoolMetrics) - Method in class reactor.netty.resources.PooledConnectionProvider
- delete() - Method in class reactor.netty.http.client.HttpClient
- 
HTTP DELETE to connect theHttpClient.
- 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 provideddirectorywill 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
- 
Option to disableretry oncesupport for the outgoing requests that fail withAbortedException.isConnectionReset(Throwable).
- 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 underlyingChannel.
- dispose() - Method in class reactor.netty.quic.QuicResources
- 
This has aNOOPimplementation by default in order to prevent unintended disposal of the global QUIC resources which has a longer lifecycle than regularLoopResources.
- 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 aNOOPimplementation by default in order to prevent unintended disposal of the global TCP resources which has a longer lifecycle than regularLoopResourcesandConnectionProvider.
- dispose() - Method in class reactor.netty.udp.UdpResources
- 
This has aNOOPimplementation by default in order to prevent unintended disposal of the global UDP resources which has a longer lifecycle than regularLoopResources.
- disposeInactivePoolsInBackground(Duration, Duration) - Method in class reactor.netty.resources.ConnectionProvider.Builder
- 
Set the options to use for configuringConnectionProviderbackground disposal for inactive connection pools.
- disposeLater() - Method in class reactor.netty.quic.QuicResources
- 
This has aNOOPimplementation by default in order to prevent unintended disposal of the global QUIC resources which has a longer lifecycle than regularLoopResources.
- 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() - Method in class reactor.netty.resources.PooledConnectionProvider
- disposeLater() - Method in class reactor.netty.tcp.TcpResources
- 
This has aNOOPimplementation by default in order to prevent unintended disposal of the global TCP resources which has a longer lifecycle than regularLoopResourcesandConnectionProvider.
- disposeLater() - Method in class reactor.netty.udp.UdpResources
- 
This has aNOOPimplementation by default in order to prevent unintended disposal of the global UDP resources which has a longer lifecycle than regularLoopResources.
- disposeLater(Duration, Duration) - Method in class reactor.netty.quic.QuicResources
- 
This has aNOOPimplementation by default in order to prevent unintended disposal of the global QUIC resources which has a longer lifecycle than regularLoopResources.
- 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(Duration, Duration) - Method in class reactor.netty.tcp.TcpResources
- 
This has aNOOPimplementation by default in order to prevent unintended disposal of the global TCP resources which has a longer lifecycle than regularLoopResourcesandConnectionProvider.
- disposeLater(Duration, Duration) - Method in class reactor.netty.udp.UdpResources
- 
This has aNOOPimplementation by default in order to prevent unintended disposal of the global UDP resources which has a longer lifecycle than regularLoopResources.
- disposeLoops() - Static method in class reactor.netty.quic.QuicResources
- 
Shutdown the globalQuicResourceswithout resetting them, effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnections() - Static method in class reactor.netty.http.HttpResources
- 
Shutdown the globalHttpResourceswithout resetting them, effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnections() - Static method in class reactor.netty.tcp.TcpResources
- 
Shutdown the globalTcpResourceswithout resetting them, effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.http.HttpResources
- 
Prepare to shutdown the globalHttpResourceswithout resetting them, effectively cleaning up associated resources without creating new ones.
- disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.tcp.TcpResources
- 
Prepare to shutdown the globalTcpResourceswithout 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 globalHttpResourceswithout 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 globalTcpResourceswithout resetting them, effectively cleaning up associated resources without creating new ones.
- disposeLoopsLater() - Static method in class reactor.netty.quic.QuicResources
- 
Prepare to shut down the globalQuicResourceswithout resetting them, effectively cleaning up associated resources without creating new ones.
- disposeLoopsLater(Duration, Duration) - Static method in class reactor.netty.quic.QuicResources
- 
Prepare to shut down the globalQuicResourceswithout resetting them, effectively cleaning up associated resources without creating new ones.
- disposeNow() - Method in interface reactor.netty.DisposableChannel
- 
Releases or closes the underlyingChannelin a blocking fashion with3seconds default timeout.
- disposeNow(Duration) - Method in interface reactor.netty.DisposableChannel
- 
Releases or closes the underlyingChannelin a blocking fashion with the provided timeout.
- disposeSubscriber() - Method in class reactor.netty.channel.ChannelOperations
- disposeSubscriber() - Method in interface reactor.netty.DisposableChannel
- 
Returns aCoreSubscriberthat will dispose on complete or error.
- disposeTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.Builder
- 
WhenConnectionProvider.dispose()orConnectionProvider.disposeLater()is called, trigger agraceful shutdownfor the connection pools, with this grace period timeout.
- 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
- 
Returns the configured custom provider ofDnsAddressResolverGroupor null.
- dnsAddressResolverGroupProvider(Function<DnsNameResolverBuilder, DnsAddressResolverGroup>) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Sets the custom function to build theDnsAddressResolverGroupgiven aDnsNameResolverBuilder.
- doAfterRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
- 
Setup a callback called whenHttpClientRequesthas been sent andHttpClientState.REQUEST_SENThas been emitted.
- doAfterResolve(BiConsumer<? super Connection, ? super SocketAddress>) - Method in class reactor.netty.transport.ClientTransport
- 
Set or add a callback called afterSocketAddressis resolved successfully.
- doAfterResponseSuccess(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
- 
Setup a callback called afterHttpClientResponsehas been fully received andHttpClientState.RESPONSE_COMPLETEDhas been emitted.
- DomainSocketAddressUtils - Class in reactor.netty.transport
- 
Internal utility class for UDS on Java 8.
- doOnBind() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured callback or null.
- doOnBind() - Method in class reactor.netty.transport.ServerTransportConfig
- 
Return the configured callback or null.
- doOnBind() - Method in class reactor.netty.udp.UdpServerConfig
- 
Return the configured callback or null.
- doOnBind(Consumer<? super QuicServerConfig>) - Method in class reactor.netty.quic.QuicServer
- 
Set or add a callback called whenQuicTransportis about to start listening for incoming traffic.
- doOnBind(Consumer<? super CONF>) - Method in class reactor.netty.transport.ServerTransport
- 
Set or add a callback called whenServerTransportis about to start listening for incoming traffic.
- doOnBind(Consumer<? super TcpServerConfig>) - Method in class reactor.netty.tcp.TcpServer
- doOnBind(Consumer<? super UdpServerConfig>) - Method in class reactor.netty.udp.UdpServer
- 
Set or add a callback called whenUdpServeris about to start listening for incoming traffic.
- doOnBound() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured callback or null.
- doOnBound() - Method in class reactor.netty.transport.ServerTransportConfig
- 
Return the configured callback or null.
- doOnBound() - Method in class reactor.netty.udp.UdpServerConfig
- 
Return the configured callback or null.
- doOnBound(Consumer<? super Connection>) - Method in class reactor.netty.quic.QuicServer
- 
Set or add a callback called afterQuicTransporthas been started.
- doOnBound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
- 
Set or add a callback called afterUdpServerhas been started.
- doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
- doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
- 
Set or add a callback called afterDisposableServerhas been started.
- doOnChannelInit() - Method in class reactor.netty.transport.TransportConfig
- 
Return the configured callback if any orChannelPipelineConfigurer.emptyConfigurer().
- doOnChannelInit(ChannelPipelineConfigurer) - Method in class reactor.netty.transport.Transport
- 
Configure the channel pipeline while initializing the channel.
- doOnConnect() - Method in class reactor.netty.quic.QuicClientConfig
- 
Return the configured callback or null.
- doOnConnect() - Method in class reactor.netty.transport.ClientTransportConfig
- 
Return the configured callback or null.
- doOnConnect(Consumer<? super CONF>) - Method in class reactor.netty.transport.ClientTransport
- 
Set or add a callback called whenClientTransportis about to connect to the remote endpoint.
- doOnConnect(Consumer<? super QuicClientConfig>) - Method in class reactor.netty.quic.QuicClient
- 
Set or add a callback called whenQuicClientis about to connect to the remote endpoint.
- doOnConnect(Consumer<? super TcpClientConfig>) - Method in class reactor.netty.tcp.TcpClient
- doOnConnect(Consumer<? super UdpClientConfig>) - Method in class reactor.netty.udp.UdpClient
- doOnConnected() - Method in class reactor.netty.quic.QuicClientConfig
- 
Return the configured callback or null.
- doOnConnected() - Method in class reactor.netty.transport.ClientTransportConfig
- 
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 afterConnectionhas been connected.
- doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
- doOnConnected(Consumer<? super QuicConnection>) - Method in class reactor.netty.quic.QuicClient
- 
Set or add a callback called afterQuicConnectionhas been connected.
- doOnConnection() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured callback or null.
- doOnConnection() - Method in class reactor.netty.transport.ServerTransportConfig
- 
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 remoteConnection.
- doOnConnection(Consumer<? super QuicConnection>) - Method in class reactor.netty.quic.QuicServer
- 
Set or add a callback called on new remoteQuicConnection.
- doOnDisconnected() - Method in class reactor.netty.quic.QuicClientConfig
- 
Return the configured callback or null.
- doOnDisconnected() - Method in class reactor.netty.transport.ClientTransportConfig
- 
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 afterConnectionhas been disconnected.
- doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
- doOnDisconnected(Consumer<? super QuicConnection>) - Method in class reactor.netty.quic.QuicClient
- 
Set or add a callback called afterQuicConnectionhas been disconnected.
- doOnError(BiConsumer<? super HttpClientRequest, ? super Throwable>, BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
- 
Setup a callback called whenHttpClientRequesthas not been sent and whenHttpClientResponsehas not been fully received.
- doOnRedirect(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
- 
Setup a callback called afterHttpClientResponseheaders 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
- 
Setup a callback called whenHttpClientRequestis about to be sent andHttpClientState.REQUEST_PREPAREDhas been emitted.
- doOnRequestError(BiConsumer<? super HttpClientRequest, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
- 
Setup a callback called whenHttpClientRequesthas not been sent.
- doOnResolve(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
- 
Set or add a callback called beforeSocketAddressis resolved.
- 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 aSocketAddress.
- doOnResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
- 
Setup a callback called afterHttpClientResponseheaders have been received andHttpClientState.RESPONSE_RECEIVEDhas been emitted.
- doOnResponseError(BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
- 
Setup a callback called whenHttpClientResponsehas not been fully received,HttpClientState.RESPONSE_INCOMPLETEhas been emitted.
- doOnUnbound() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured callback or null.
- doOnUnbound() - Method in class reactor.netty.transport.ServerTransportConfig
- 
Return the configured callback or null.
- doOnUnbound() - Method in class reactor.netty.udp.UdpServerConfig
- 
Return the configured callback or null.
- doOnUnbound(Consumer<? super Connection>) - Method in class reactor.netty.quic.QuicServer
- 
Set or add a callback called afterQuicTransporthas been shutdown.
- doOnUnbound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
- 
Set or add a callback called afterUdpServerhas been shutdown.
- doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
- doOnUnbound(Consumer<? super DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
- 
Set or add a callback called afterDisposableServerhas been shutdown.
- duplicate() - Method in class reactor.netty.transport.Transport
- 
Return a newTransportinheriting the current configuration.
- duration() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns the request/response duration.
E
- empty() - Static method in interface reactor.netty.channel.ChannelOperations.OnSetup
- 
Return an empty, no-op factory.
- emptyConfigurer() - Static method in interface reactor.netty.ChannelPipelineConfigurer
- 
Return a noop configurer.
- emptyListener() - Static method in interface reactor.netty.ConnectionObserver
- 
Return a noop connection listener.
- encoding(HttpPostRequestEncoder.EncoderMode) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Set Form encoding.
- equals(Object) - Method in class reactor.netty.http.Http2SettingsSpec
- equals(Object) - Method in class reactor.netty.http.Http3SettingsSpec
- equals(Object) - Method in class reactor.netty.tcp.SslProvider
- equals(Object) - Method in class reactor.netty.transport.NameResolverProvider
- equals(Object) - Method in class reactor.netty.channel.MeterKey
- equals(Object) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
- equals(Object) - Method in class reactor.netty.http.HttpDecoderSpec
- equals(Object) - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
- equals(Object) - Method in class reactor.netty.quic.QuicInitialSettingsSpec
- equals(Object) - Method in class reactor.netty.transport.ProxyProvider
- error(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
- error(HttpMessageArgProvider) - Method in interface reactor.netty.http.logging.HttpMessageLogFactory
- 
Generates a log message based on a givenHttpMessageArgProviderfor a log with a levelERROR.
- ERROR - Static variable in class reactor.netty.Metrics
- ERROR_LOG_ENABLED - Static variable in class reactor.netty.ReactorNetty
- 
Specifies whether the Http Server error log will be enabled.
- errorDateTime() - Method in interface reactor.netty.http.server.logging.error.ErrorLogArgProvider
- 
Returns the date-time of the moment when the exception occurred.
- errorLog(boolean) - Method in class reactor.netty.http.server.HttpServer
- 
Enable or disable the error log.
- errorLog(boolean, ErrorLogFactory) - Method in class reactor.netty.http.server.HttpServer
- 
Enable or disable the error log and customize it through anErrorLogFactory.
- ErrorLog - Interface in reactor.netty.http.server.logging.error
- 
Represents a log entry for HTTP server errors.
- ErrorLogArgProvider - Interface in reactor.netty.http.server.logging.error
- 
A provider of the args required for error log.
- ErrorLogEvent - Interface in reactor.netty.http.server.logging.error
- 
Define an interface to handle error log events propagated through UserEvent.
- ErrorLogFactory - Interface in reactor.netty.http.server.logging.error
- ErrorLogHandler - Static variable in interface reactor.netty.NettyPipeline
- ERRORS - Static variable in class reactor.netty.Metrics
- 
Number of errors that occurred.
- ERRORS_COUNT - Enum constant in enum reactor.netty.channel.ChannelMeters
- 
Number of errors that occurred.
- estimatePermitCount() - Method in class reactor.netty.http.client.Http2AllocationStrategy
- estimatePermitCount() - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
- 
Best-effort peek at the state of the strategy which indicates roughly how many more connections can currently be allocated.
- EVENT_LOOP_PREFIX - Static variable in class reactor.netty.Metrics
- 
Name prefix that will be used for Event Loop Group metrics registered in Micrometer's global registry.
- eventLoopGroup() - Method in class reactor.netty.quic.QuicServerConfig
- eventLoopGroup() - Method in class reactor.netty.transport.ClientTransportConfig
- eventLoopGroup() - Method in class reactor.netty.transport.ServerTransportConfig
- eventLoopGroup() - Method in class reactor.netty.transport.TransportConfig
- 
Return the configuredEventLoopGroup.
- eventLoopGroup() - Method in class reactor.netty.udp.UdpServerConfig
- evictInBackground(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Set the options to use for configuringConnectionProviderbackground eviction.
- evictionPredicate(BiPredicate<Connection, ConnectionProvider.ConnectionMetadata>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Set the options to use for configuringConnectionProvidercustom eviction predicate.
- exceptionCaught(ChannelHandlerContext, Throwable) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
- exceptionCaught(ChannelHandlerContext, Throwable) - Method in class reactor.netty.http.server.logging.error.DefaultErrorLogHandler
F
- factory(HttpDataFactory) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Set Upload factories (allows memory threshold configuration).
- fail(SocketAddress, Throwable) - Static method in exception reactor.netty.ChannelBindException
- 
Build aChannelBindException.
- failOnMissingResponse(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
- 
Configure whether to throw an exception on a channel inactive in case there was a missing response.
- family() - Method in class reactor.netty.udp.UdpClientConfig
- 
Deprecated.as of 1.3.0. PreferUdpClientConfig.socketFamily(). This method will be removed in version 1.4.0.
- family() - Method in class reactor.netty.udp.UdpServerConfig
- 
Deprecated.as of 1.3.0. PreferUdpServerConfig.socketFamily(). This method will be removed in version 1.4.0.
- fifo() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Configure the pool so that if there are idle connections (i.e.
- file(String, File) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute.
- file(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute.
- file(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute.
- file(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute.
- file(String, String) - Method in interface reactor.netty.http.server.HttpServerRoutes
- 
Listens for HTTP GET on the passed path to be used as a routing condition.
- file(String, String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute.
- file(String, String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute.
- file(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.
- file(Predicate<HttpServerRequest>, 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.
- files(String, File[], String[]) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute.
- files(String, File[], String[], boolean[]) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute.
- fillInStackTrace() - Method in exception reactor.netty.ChannelBindException
- fillInStackTrace() - Method in exception reactor.netty.http.client.PrematureCloseException
- filter(M) - Static method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- followRedirect(boolean) - Method in class reactor.netty.http.client.HttpClient
- 
Specifies whether HTTP status 301|302|303|307|308 auto-redirect support is enabled.
- followRedirect(boolean, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
- 
Variant ofHttpClient.followRedirect(boolean)that also acceptsBiConsumerthat provides the headers from the previous request and the current redirect request.
- followRedirect(boolean, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
- 
Variant ofHttpClient.followRedirect(boolean)that also accepts a redirect request processor.
- followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>) - Method in class reactor.netty.http.client.HttpClient
- 
Enables auto-redirect support if the passedPredicatematches.
- followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
- 
Variant ofHttpClient.followRedirect(BiPredicate)that also acceptsBiConsumerthat provides the headers from the previous request and the current redirect request.
- followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, Consumer<HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
- 
Variant ofHttpClient.followRedirect(BiPredicate)that also accepts a redirect request processor.
- followRedirectPredicate() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return the configured follow redirect predicate or null.
- forClient() - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new client-sideSslContext.
- forClient() - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new client-sideSslContext.
- forClient() - Static method in class reactor.netty.http.Http3SslContextSpec
- 
Creates a builder for new client-sideSslContext.
- forClient() - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new client-sideSslContext.
- forClient() - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new client-sideSslContext.
- format(Channel, String) - Static method in class reactor.netty.ReactorNetty
- 
Append channel ID to a log message for correlated traces.
- formatName() - Method in class reactor.netty.channel.ChannelOperations
- 
Return formatted name of this operation.
- formatSocketAddress(SocketAddress) - Static method in class reactor.netty.Metrics
- formDecoderProvider() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Return the configured HTTP form decoder or the default.
- forRemoteHost(SocketAddress, Consumer<ConnectionProvider.HostSpecificSpec>) - Method in class reactor.netty.resources.ConnectionProvider.Builder
- 
Connection pool configuration for a specific remote host.
- forServer(File, String, File) - Static method in class reactor.netty.http.Http3SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(File, File) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(File, File) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(File, File) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(File, File) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(File, File, String) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(File, File, String) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(File, File, String) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(File, File, String) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(InputStream, InputStream) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(InputStream, InputStream) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(InputStream, InputStream) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(InputStream, InputStream) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(InputStream, InputStream, String) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(InputStream, InputStream, String) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(InputStream, InputStream, String) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(InputStream, InputStream, String) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.http.Http3SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, X509Certificate...) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, X509Certificate...) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, X509Certificate...) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(PrivateKey, X509Certificate...) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManager) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManager) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManager) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManager) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManagerFactory) - Static method in class reactor.netty.http.Http11SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManagerFactory) - Static method in class reactor.netty.http.Http2SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManagerFactory) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManagerFactory) - Static method in class reactor.netty.tcp.TcpSslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManagerFactory, String) - Static method in class reactor.netty.http.Http3SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forServer(KeyManager, String) - Static method in class reactor.netty.http.Http3SslContextSpec
- 
Creates a builder for new server-sideSslContext.
- forwarded(boolean) - Method in class reactor.netty.http.server.HttpServer
- 
Specifies whether support for the"Forwarded"and"X-Forwarded-*"HTTP request headers for deriving information about the connection is enabled.
- forwarded(BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo>) - Method in class reactor.netty.http.server.HttpServer
- 
Specifies a custom request handler for deriving information about the connection.
- forwardedPrefix() - Method in interface reactor.netty.http.server.HttpServerRequest
- 
Returns the X-Forwarded-Prefix if it was part of the request headers.
- from(F) - Static method in class reactor.netty.FutureMono
- from(Channel) - Static method in interface reactor.netty.Connection
- 
Return an existingConnectionwrapper or create a simple new one.
- from(TcpClient) - Static method in class reactor.netty.http.client.HttpClient
- 
Deprecated.Use the other methods exposed byHttpClientto achieve the same configurations. This method will be removed in version 1.1.0.
- from(TcpServer) - Static method in class reactor.netty.http.server.HttpServer
- 
Deprecated.Use the other methods exposed byHttpServerto achieve the same configurations. This method will be removed in version 1.1.0.
- fromInbound(Publisher<?>) - Static method in class reactor.netty.ByteBufFlux
- 
Decorate asByteBufFlux.
- fromInbound(Publisher<?>, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
- 
Decorate asByteBufFlux.
- fromPath(Path) - Static method in class reactor.netty.ByteBufFlux
- 
Open aFileChannelfrom a path and streamByteBufchunks with a default maximum size of 500K into the returnedByteBufFlux.
- fromPath(Path, int) - Static method in class reactor.netty.ByteBufFlux
- 
Open aFileChannelfrom a path and streamByteBufchunks with a given maximum size into the returnedByteBufFlux.
- fromPath(Path, int, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
- 
Open aFileChannelfrom a path and streamByteBufchunks with a given maximum size into the returnedByteBufFlux, using the providedByteBufAllocator.
- fromPath(Path, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
- 
Open aFileChannelfrom a path and streamByteBufchunks with a default maximum size of 500K into the returnedByteBufFlux, using the providedByteBufAllocator.
- fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufFlux
- 
Decorate asByteBufFlux.
- fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufMono
- 
Decorate asByteBufMono.
- fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
- 
Decorate asByteBufFlux.
- fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufMono
- 
Decorate asByteBufMono.
- FULL_REQUEST - Enum constant in enum reactor.netty.http.logging.HttpMessageType
- 
RepresentsFullHttpRequest.
- FULL_RESPONSE - Enum constant in enum reactor.netty.http.logging.HttpMessageType
- 
RepresentsFullHttpResponse.
- fullPath() - Method in interface reactor.netty.http.HttpInfos
- 
Returns the decoded path portion from theHttpInfos.uri().
- FutureMono - Class in reactor.netty
- 
Convert Netty Future into voidMono.
- FutureMono() - Constructor for class reactor.netty.FutureMono
G
- get() - Method in class reactor.netty.http.client.HttpClient
- 
HTTP GET to connect theHttpClient.
- 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() - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
- get() - Static method in class reactor.netty.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.
- get(Channel) - Static method in class reactor.netty.channel.ChannelOperations
- 
Return the currentChannelboundChannelOperationsor null if none.
- 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.
- getAddress() - Method in class reactor.netty.transport.ProxyProvider
- 
Deprecated.as of 1.2.0. Prefer usingProxyProvider.getSocketAddress(). This method will be removed in 1.3.0.
- 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
- 
ReturnsContextViewfrom the channel attributes when exists otherwise returnsnull.
- getDefaultHostPort(String) - Static method in class reactor.netty.http.server.ConnectionInfo
- 
Returns the default host port number based on scheme.
- getForwardedPrefix() - Method in class reactor.netty.http.server.ConnectionInfo
- 
Returns the X-Forwarded-Prefix if it was part of the request headers.
- 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
- 
Return the configuredNameResolverProvideror null.
- getNonProxyHostsPredicate() - Method in class reactor.netty.transport.ProxyProvider
- 
A predicatePredicateonSocketAddressthat 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.quic.QuicResources
- 
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.
- 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.
- 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 aConnectionProviderfor HTTP/2 traffic exists and proceed with a creation if it does not exist.
- getOrCreateHttp3ConnectionProvider(Function<ConnectionProvider, ConnectionProvider>) - Method in class reactor.netty.http.HttpResources
- 
Safely checks whether aConnectionProviderfor HTTP/3 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 adesiredpositive number of new connections.
- getProxyAddress() - Method in class reactor.netty.transport.ProxyProvider
- 
The address to connect to.
- 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.
- getServerNames() - Method in class reactor.netty.tcp.SslProvider
- getSocketAddress() - Method in class reactor.netty.transport.ProxyProvider
- 
The supplier for the address to connect to.
- getSpanName(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTracingObservationHandler
- getSslContext() - Method in class reactor.netty.tcp.SslProvider
- 
ReturnsSslContextinstance 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
- 
Deprecated.as of 1.1.19. Prefer theMicrometerChannelMetricsRecorder.getTlsHandshakeTimer(String, String, String, String). This method will be removed in version 1.3.0.
- 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.
- grease(boolean) - Method in class reactor.netty.quic.QuicServer
- 
Set if greasing should be enabled or not.
- GzipOption - Class in reactor.netty.http.server.compression
- 
GZIP compression option configuration.
- GzipOption.Builder - Interface in reactor.netty.http.server.compression
H
- H1 - Enum constant in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
- 
HTTP/1.1.
- H2 - Enum constant in enum reactor.netty.http.HttpProtocol
- 
HTTP/2.0 support with TLS
- H2 - Enum constant in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
- 
HTTP/2.0.
- H2C - Enum constant in enum reactor.netty.http.HttpProtocol
- 
HTTP/2.0 support with clear-text.
- h2cMaxContentLength - Variable in class reactor.netty.http.HttpDecoderSpec
- 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.
- 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.
- 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
- H3 - Enum constant in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
- 
HTTP/3.0.
- H3ToHttp11Codec - Static variable in interface reactor.netty.NettyPipeline
- 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 WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
- 
Negotiate a websocket upgrade and extract a flux from the givenWebsocketInboundandWebsocketOutbound.
- 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() - 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
- handlePing(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
- 
Sets flag whether to proxy websocket ping frames or respond to them.
- handlerConfigurator(Consumer<? super SslHandler>) - Method in interface reactor.netty.tcp.SslProvider.Builder
- 
Set a configurator callback to mutate any property from the providedSslHandler.
- handleStream(BiFunction<? super QuicInbound, ? super QuicOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.quic.QuicServer
- 
Attach an IO handler to react on incoming stream.
- 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.Http3SettingsSpec
- hashCode() - Method in class reactor.netty.http.HttpDecoderSpec
- hashCode() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
- hashCode() - Method in class reactor.netty.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
- 
Return true if thatClientTransportConfigis configured with a proxy.
- 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
- 
HTTP HEAD to connect theHttpClient.
- 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() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return a copy of the request headers.
- headers() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
- 
Returns the request/response headers.
- headers() - Method in interface reactor.netty.http.websocket.WebsocketInbound
- 
Returns the websocket remote headers sent during handshake.
- headers(HttpHeaders) - Method in interface reactor.netty.http.client.HttpClientRequest
- 
Set outbound headers from the passed headers.
- headers(HttpHeaders) - Method in interface reactor.netty.http.server.HttpServerResponse
- 
Sets outbound HTTP headers, replacing any pre-existing value for these headers.
- headers(Consumer<? super HttpHeaders>) - Method in class reactor.netty.http.client.HttpClient
- 
Apply headers configuration.
- 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() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configuredSETTINGS_HEADER_TABLE_SIZEvalue or null.
- headerTableSize(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Sets theSETTINGS_HEADER_TABLE_SIZEvalue.
- 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.
- HEX_DUMP - Enum constant in enum reactor.netty.transport.logging.AdvancedByteBufFormat
- 
When wire logging is enabled with this format, both events and content will be logged.
- 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.quic.QuicClient
- 
The host to which this client should connect.
- host(String) - Method in class reactor.netty.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, possiblynullin 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 theHost/X-Forwarded-Host/Forwardedheader 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 theHost/X-Forwarded-*/Forwardedheader associated with this request.
- hostsFileEntriesResolver() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the configured customHostsFileEntriesResolverto be used for hosts file entries or null.
- hostsFileEntriesResolver(HostsFileEntriesResolver) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Specifies a customHostsFileEntriesResolverto be used for hosts file entries.
- HostSpecificSpec() - Constructor for class reactor.netty.resources.ConnectionProvider.HostSpecificSpec
- HTTP - Enum constant in enum reactor.netty.transport.ProxyProvider.Proxy
- 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.
- HTTP11 - Enum constant in enum reactor.netty.http.HttpProtocol
- 
The default supported HTTP protocol by HttpServer and HttpClient.
- Http11SslContextSpec - Class in reactor.netty.http
- 
SslContext builder that provides default configuration specific to HTTP/1.x as follows:SslProviderwill be set depending onOpenSsl.isAvailable()The default cipher suites will be used Application protocol negotiation configuration is disabled
- Http2AllocationStrategy - Class in reactor.netty.http.client
- 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() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Return the HTTP/2 configuration.
- Http2SettingsSpec - Class in reactor.netty.http
- 
A configuration builder to fine tune theHttp2Settings.
- 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:SslProviderwill be set depending onOpenSsl.isAlpnSupported()Http2SecurityUtil.CIPHERSApplication protocol negotiation configuration is enabled HTTP/1.1 and HTTP/2 support in order to support upgrade to HTTP/2
- Http3 - Class in reactor.netty.http.internal
- 
Utility class around HTTP/3.
- HTTP3 - Enum constant in enum reactor.netty.http.HttpProtocol
- 
HTTP/3.0 support.
- http3Settings(Consumer<Http3SettingsSpec.Builder>) - Method in class reactor.netty.http.client.HttpClient
- 
Apply HTTP/3 configuration.
- http3Settings(Consumer<Http3SettingsSpec.Builder>) - Method in class reactor.netty.http.server.HttpServer
- 
Apply HTTP/3 configuration.
- http3SettingsSpec() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return the HTTP/3 configuration.
- http3SettingsSpec() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Return the HTTP/3 configuration.
- Http3SettingsSpec - Class in reactor.netty.http
- 
A configuration builder to fine tune the HTTP/3 settings.
- Http3SettingsSpec.Builder - Interface in reactor.netty.http
- Http3SslContextSpec - Class in reactor.netty.http
- 
SslContext builder that provides default configuration specific to HTTP/3 as follows: Supported application protocols
- 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 whenClientTransport.connect()is ultimately called.
- HttpClient() - Constructor for class reactor.netty.http.client.HttpClient
- HttpClient.RedirectSendHandler - Interface in reactor.netty.http.client
- 
Marker interface for use withHttpClient.RequestSender.send(BiFunction).
- HttpClient.RequestSender - Interface in reactor.netty.http.client
- 
Allow a request body configuration before calling one of the terminal,Publisherbased,HttpClient.ResponseReceiverAPI.
- HttpClient.ResponseReceiver<S extends HttpClient.ResponseReceiver<?>> - Interface in reactor.netty.http.client
- 
A response extractor for this configuredHttpClient.
- 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
- 
Allow a request body configuration before calling one of the terminal,Publisherbased,HttpClient.WebsocketReceiverAPI.
- 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 forHttpClientSSL/TLS configuration.
- HttpClientState - Enum in reactor.netty.http.client
- 
Specific Http Client state observable byHttpClient.observe(ConnectionObserver).
- HttpCodec - Static variable in interface reactor.netty.NettyPipeline
- HttpCompressionOption - Interface in reactor.netty.http.server.compression
- 
HTTP compression option configuration.
- HttpCompressionOptionsSpec - Class in reactor.netty.http.server.compression
- 
HTTP Compression configuration for the SimpleCompressionHandler.
- HttpCompressionOptionsSpec(HttpCompressionOption...) - Constructor for class reactor.netty.http.server.compression.HttpCompressionOptionsSpec
- HttpConnectionPoolMetrics - Interface in reactor.netty.http.client
- 
Interface for collecting HTTP/2 or HTTP/3 specific connection pool metrics.
- HttpDecoderSpec<T extends HttpDecoderSpec<T>> - Class in reactor.netty.http
- 
A configuration builder to fine tune theHttpCodec(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.
- httpHeaders(Consumer<HttpHeaders>, Function<String, Integer>) - 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 loggingHttpMessagedetails.
- HttpMessageArgProviderFactory - Class in reactor.netty.http.logging
- 
Factory for creatingHttpContentArgProviderbased on the provided HTTP object.
- httpMessageLogFactory() - Method in class reactor.netty.http.HttpOperations
- httpMessageLogFactory(HttpMessageLogFactory) - Method in class reactor.netty.http.client.HttpClient
- 
WhenHttpMessageis about to be logged the configured factory will be used for generating a sanitized log message.
- httpMessageLogFactory(HttpMessageLogFactory) - Method in class reactor.netty.http.server.HttpServer
- 
WhenHttpMessageis about to be logged the configured factory will be used for generating a sanitized log message.
- HttpMessageLogFactory - Interface in reactor.netty.http.logging
- 
Factory for generating a log message based on a givenHttpMessageArgProvider.
- HttpMessageLogUtils - Class in reactor.netty.http.logging
- 
Utilities for creating log message based on a givenHttpMessageArgProvider.
- httpMessageType() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
- 
Returns theHttpMessagetype.
- HttpMessageType - Enum in reactor.netty.http.logging
- 
Representation of variousHttpMessagetypes.
- HttpMeterRegistrarAdapter - Class in reactor.netty.http.client
- 
An abstract adapter class for registering HTTP/2 or HTTP/3 specific metrics in a connection pool.
- HttpMeterRegistrarAdapter() - Constructor for class reactor.netty.http.client.HttpMeterRegistrarAdapter
- 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 readyChannelOperationswith state management for status and headers (first HTTP response packet).
- HttpOperations(Connection, ConnectionObserver, HttpOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.http.HttpOperations
- HttpOperations(Connection, ConnectionObserver, HttpMessageLogFactory) - Constructor for class reactor.netty.http.HttpOperations
- HttpOperations(HttpOperations<INBOUND, OUTBOUND>) - 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
- 
Configure theHttpServerCodec's request decoding options.
- HttpRequestDecoderSpec - Class in reactor.netty.http.server
- 
A configuration builder to fine tune theHttpServerCodec(or more precisely theHttpServerCodec.HttpServerRequestDecoder) for HTTP/1.1 orHttpServerUpgradeHandlerfor H2C.
- 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
- 
Configure theHttpClientCodec's response decoding options.
- HttpResponseDecoderSpec - Class in reactor.netty.http.client
- 
A configuration builder to fine tune theHttpClientCodec(or more precisely theHttpClientCodec.Decoder).
- 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 whenServerTransport.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() - Method in interface reactor.netty.http.server.logging.error.ErrorLogArgProvider
- 
Returns information about the HTTP server-side connection information.
- 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
- 
Specific Http Server state observable byTransport.observe(ConnectionObserver).
- HttpTrafficHandler - Static variable in interface reactor.netty.NettyPipeline
- hystart(boolean) - Method in class reactor.netty.quic.QuicServer
- 
Enable/disable Hystart.
I
- 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() - Method in class reactor.netty.http.Http3SettingsSpec
- 
Return the configured maximum idle timeout or null.
- 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.
- idleTimeout() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured idle timeout or null.
- idleTimeout(Duration) - Method in interface reactor.netty.http.Http3SettingsSpec.Builder
- 
Set the maximum idle timeout (resolution: ms) See set_max_idle_timeout.
- 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(Duration) - Method in class reactor.netty.quic.QuicServer
- 
Set the maximum idle timeout (resolution: ms) See set_max_idle_timeout.
- IdleTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
- inbound() - Method in class reactor.netty.channel.ChannelOperations
- inbound() - Method in interface reactor.netty.Connection
- 
Return theNettyInboundread API from this connection.
- inboundHandler(BiConsumer<? super ChannelHandlerContext, Object>) - Static method in interface reactor.netty.NettyPipeline
- 
Create a newChannelInboundHandlerthat will invokeBiConsumer.accept(T, U)onChannelInboundHandler.channelRead(ChannelHandlerContext, Object).
- incrementErrorsCount(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
- 
Increments the number of the errors that have occurred.
- incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- 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
- incrementErrorsCount(SocketAddress, SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
- 
Increments the number of the errors that have occurred.
- incrementErrorsCount(SocketAddress, SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- incrementErrorsCount(SocketAddress, SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- 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) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- 
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(ContextView, SocketAddress, SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- 
Increments the number of the errors that have occurred.
- incrementErrorsCount(ContextView, SocketAddress, SocketAddress, String) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
- 
Increments the number of the errors that have occurred.
- 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
- 
Generates a log message based on a givenHttpMessageArgProviderfor a log with a levelINFO.
- initialBufferSize - Variable in class reactor.netty.http.HttpDecoderSpec
- initialBufferSize() - Method in class reactor.netty.http.HttpDecoderSpec
- 
Return the configured initial buffer size for HTTP request decoding.
- initialBufferSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
- 
Configure the initial buffer size for HTTP request decoding.
- initialSettings() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured QUIC initial settings or the default.
- initialSettings(Consumer<QuicInitialSettingsSpec.Builder>) - Method in class reactor.netty.quic.QuicServer
- 
Configure QUIC initial settings.
- initialWindowSize() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configuredSETTINGS_INITIAL_WINDOW_SIZEvalue or null.
- initialWindowSize(int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Sets theSETTINGS_INITIAL_WINDOW_SIZEvalue.
- 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).
- isAcceptBrotli() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return whether Brotli compression is enabled.
- isAcceptGzip() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return whether GZip compression is enabled.
- isActiveMigration() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return true if active migration is enabled.
- isCompleteOncePreferredResolved() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returnstrueif the resolver notifies the returnedFutureas 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
- 
Returnstrueif an optional record inclusion is disabled.
- isDisableRecursionDesired() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returnstrueif 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.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
- isDomainSocketAddress(SocketAddress) - Static method in class reactor.netty.transport.DomainSocketAddressUtils
- 
Returns whether theSocketAddressisDomainSocketAddress.
- 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 hasContent-Typewith valueapplication/x-www-form-urlencoded.
- isForwarded() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Returns whether thatHttpServersupports the"Forwarded"and"X-Forwarded-*"HTTP request headers for deriving information about the connection.
- isGrease() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return true if greasing is enabled.
- isHttp3Available() - Static method in class reactor.netty.http.internal.Http3
- 
Check if the current runtime supports HTTP/3, by verifying ifio.netty:netty-codec-native-quicis on the classpath.
- isHystart() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return true if Hystart is enabled.
- 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.quic.QuicStreamInfo
- 
Returnstrueif 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 hasContent-Typewith valuemultipart/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
- 
Returnstrueif prefer native event loop and channel factory (e.g.
- isPreferNative() - Method in class reactor.netty.transport.TransportConfig
- 
Returntrueif prefer native event loop and channel factory (e.g.
- isRetryDisabled() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return true ifretry onceis disabled, false otherwise.
- isRetryTcpOnTimeout() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returnstrueif the resolver will also fallback to TCP if a timeout is detected.
- isRoundRobinSelection() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns true ifRoundRobinDnsAddressResolverGroupis in use.
- isSecure() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Returns true if thatHttpClientsecured via SSL transport.
- isSecure() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Returns true if thatHttpServersecured via SSL transport.
- isSecure() - Method in class reactor.netty.tcp.TcpClientConfig
- 
Return true if thatTcpClientsecured via SSL transport.
- isSecure() - Method in class reactor.netty.tcp.TcpServerConfig
- 
Returns true if thatTcpServersecured 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
J
- join(InetAddress) - Method in interface reactor.netty.udp.UdpOutbound
- 
Join a multicast group.
- join(InetAddress, NetworkInterface) - Method in interface reactor.netty.udp.UdpOutbound
- 
Join a multicast group.
K
- keepAlive(boolean) - Method in class reactor.netty.http.client.HttpClient
- 
Enable or Disable Keep-Alive support for the outgoing request.
- keepAlive(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse
- 
Sets the requestkeepAliveif true otherwise remove the existing connection keep alive header.
L
- LAST_CONTENT - Enum constant in enum reactor.netty.http.logging.HttpMessageType
- 
RepresentsLastHttpContent.
- LEASING_STRATEGY_FIFO - Static variable in interface reactor.netty.resources.ConnectionProvider
- 
The connection selection is first in, first out.
- LEASING_STRATEGY_LIFO - Static variable in interface reactor.netty.resources.ConnectionProvider
- 
The connection selection is last in, first out.
- leave(InetAddress) - Method in interface reactor.netty.udp.UdpOutbound
- 
Leave a multicast group.
- leave(InetAddress, NetworkInterface) - Method in interface reactor.netty.udp.UdpOutbound
- 
Leave a multicast group.
- LEFT - Static variable in interface reactor.netty.NettyPipeline
- lifeTime() - Method in interface reactor.netty.resources.ConnectionProvider.ConnectionMetadata
- 
Returns the age of the connection in ms.
- lifo() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Configure the pool so that if there are idle connections (i.e.
- listener() - Method in class reactor.netty.channel.ChannelOperations
- 
Return the available parentConnectionObserverfor user-facing lifecycle handling.
- LOCAL_ADDRESS - Enum constant in enum reactor.netty.channel.ChannelMeters.ConnectionsTotalMeterTags
- 
Local address.
- LOCAL_ADDRESS - Static variable in class reactor.netty.Metrics
- localConnectionIdLength() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured local connection id length that is used or the default.
- localConnectionIdLength(int) - Method in class reactor.netty.quic.QuicServer
- 
Sets the local connection id length that is used.
- localHost() - Method in exception reactor.netty.ChannelBindException
- 
Return the configured binding host.
- localPort() - Method in exception reactor.netty.ChannelBindException
- 
Return the configured binding port.
- log() - Method in class reactor.netty.http.server.logging.AccessLog
- log() - Method in interface reactor.netty.http.server.logging.error.ErrorLog
- 
Logs the error information.
- loggingHandler() - Method in class reactor.netty.transport.TransportConfig
- 
Return the configuredLoggingHandleror null.
- loggingHandler(LoggingHandler) - Method in class reactor.netty.http.client.HttpClientConfig
- loggingHandler(LoggingHandler) - Method in class reactor.netty.http.server.HttpServerConfig
- loggingHandler(LoggingHandler) - Method in class reactor.netty.transport.TransportConfig
- LoggingHandler - Static variable in interface reactor.netty.NettyPipeline
- logHttpMessage(HttpMessageArgProvider, Function<String, String>, Function<DecoderResult, String>, Function<Map.Entry<String, String>, String>) - Static method in class reactor.netty.http.logging.HttpMessageLogUtils
- 
Creates a log message based on the providedHttpMessageArgProvider.
- logPoolState(Channel, InstrumentedPool<? extends Connection>, String) - Static method in class reactor.netty.resources.PooledConnectionProvider
- logPoolState(Channel, InstrumentedPool<? extends Connection>, String, Throwable) - Static method in class reactor.netty.resources.PooledConnectionProvider
- loopResources() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the configuredLoopResourcesor null.
- loopResources() - Method in class reactor.netty.transport.TransportConfig
- 
Return the configuredLoopResourcesor the default.
- LoopResources - Interface in reactor.netty.resources
- 
AnEventLoopGroupselector with associatedChannelfactories.
M
- 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 8Mapissues.
- 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.
- maxAckDelay() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured the max ACK delay or the default.
- maxAckDelay(Duration) - Method in class reactor.netty.quic.QuicServer
- 
Set max ACK delay (resolution: ms).
- 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() - Method in class reactor.netty.http.HttpDecoderSpec
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 does not support this configuration.
- maxChunkSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 does not support this configuration.
- 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() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configuredSETTINGS_MAX_CONCURRENT_STREAMSvalue or null.
- 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(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Sets theSETTINGS_MAX_CONCURRENT_STREAMSvalue.
- maxConnectionPools(int) - Method in class reactor.netty.resources.ConnectionProvider.Builder
- 
Specifies the maximum number of connection pools that the provider can create.
- 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
- 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 configuringConnectionProvidermaximum connections per connection pool.
- 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() - Method in class reactor.netty.http.Http3SettingsSpec
- 
Return the configured initial maximum data limit.
- maxData() - Method in class reactor.netty.quic.QuicInitialSettingsSpec
- 
Return the configured initial maximum data limit.
- maxData(long) - Method in interface reactor.netty.http.Http3SettingsSpec.Builder
- 
Set the initial maximum data limit.
- maxData(long) - Method in interface reactor.netty.quic.QuicInitialSettingsSpec.Builder
- 
Set the initial maximum data limit.
- maxDecodedRstFramesPerWindow() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configured maximum number RST frames that are allowed per window or null.
- maxDecodedRstFramesPerWindow(int, int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Sets the maximum number RST frames that are allowed per window before the connection is closed.
- maxDecodedRstFramesSecondsPerWindow() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configured maximum seconds per window or null.
- maxEncodedRstFramesPerWindow() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configured maximum number RST frames that are allowed per window or null.
- maxEncodedRstFramesPerWindow(int, int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Sets the maximum number RST frames that are allowed per window before the connection is closed.
- maxEncodedRstFramesSecondsPerWindow() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configured maximum seconds per window or null.
- maxEncodeSize(int) - Method in interface reactor.netty.http.server.compression.ZstdOption.Builder
- 
Sets the zstd memory level.
- 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
- maxFramePayloadLength(int) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
- 
Sets a custom maximum allowable frame payload length.
- maxFrameSize() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configuredSETTINGS_MAX_FRAME_SIZEvalue or null.
- maxFrameSize(int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Sets theSETTINGS_MAX_FRAME_SIZEvalue.
- maxHeaderListSize() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configuredSETTINGS_MAX_HEADER_LIST_SIZEvalue or the defaultHttp2CodecUtil.DEFAULT_HEADER_LIST_SIZE.
- maxHeaderListSize(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
Sets theSETTINGS_MAX_HEADER_LIST_SIZEvalue.
- maxHeaderSize - Variable in class reactor.netty.http.HttpDecoderSpec
- maxHeaderSize() - Method in class reactor.netty.http.HttpDecoderSpec
- 
Return the configured maximum header size that can be decoded for the HTTP request.
- maxHeaderSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
- 
Configure the maximum header size that can be decoded for the HTTP request.
- maxIdleTime() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
- maxIdleTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Set the options to use for configuringConnectionProvidermax idle time (resolution: ms).
- maxInitialLineLength - Variable in class reactor.netty.http.HttpDecoderSpec
- maxInitialLineLength() - Method in class reactor.netty.http.HttpDecoderSpec
- 
Return the configured maximum length that can be decoded for the HTTP request's initial line.
- maxInitialLineLength(int) - Method in class reactor.netty.http.HttpDecoderSpec
- 
Configure the maximum length that can be decoded for the HTTP request's initial line.
- maxInMemorySize() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
- 
Returns the configured maximum size after which anAttribute/FileUploadstarts being stored on disk rather than in memory.
- maxInMemorySize(long) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
- 
Sets the maximum in-memory size perAttribute/FileUploadi.e.
- 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.
- 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.
- maxLifeTime() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
- maxLifeTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Set the options to use for configuringConnectionProvidermax life time (resolution: ms).
- 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 ofPool.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.
- maxRecvUdpPayloadSize() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured the maximum payload size or the default.
- maxRecvUdpPayloadSize(long) - Method in class reactor.netty.quic.QuicServer
- maxSendUdpPayloadSize() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured the maximum payload size or the default.
- maxSendUdpPayloadSize(long) - Method in class reactor.netty.quic.QuicServer
- maxSize() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
- 
Returns the configured maximum allowed size of individualAttribute/FileUpload.
- maxSize(long) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
- 
Set the maximum size perAttribute/FileUpload.
- maxStreamDataBidirectionalLocal() - Method in class reactor.netty.http.Http3SettingsSpec
- 
Return the configured initial maximum data limit for local bidirectional streams.
- maxStreamDataBidirectionalLocal() - Method in class reactor.netty.quic.QuicInitialSettingsSpec
- 
Return the configured initial maximum data limit for local bidirectional streams.
- maxStreamDataBidirectionalLocal(long) - Method in interface reactor.netty.http.Http3SettingsSpec.Builder
- 
Set the initial maximum data limit for local bidirectional streams.
- maxStreamDataBidirectionalLocal(long) - Method in interface reactor.netty.quic.QuicInitialSettingsSpec.Builder
- 
Set the initial maximum data limit for local bidirectional streams.
- maxStreamDataBidirectionalRemote() - Method in class reactor.netty.http.Http3SettingsSpec
- 
Return the configured initial maximum data limit for remote bidirectional streams.
- maxStreamDataBidirectionalRemote() - Method in class reactor.netty.quic.QuicInitialSettingsSpec
- 
Return the configured initial maximum data limit for remote bidirectional streams.
- maxStreamDataBidirectionalRemote(long) - Method in interface reactor.netty.http.Http3SettingsSpec.Builder
- 
Set the initial maximum data limit for remote bidirectional streams.
- maxStreamDataBidirectionalRemote(long) - Method in interface reactor.netty.quic.QuicInitialSettingsSpec.Builder
- 
Set the initial maximum data limit for remote bidirectional streams.
- maxStreamDataUnidirectional() - Method in class reactor.netty.quic.QuicInitialSettingsSpec
- 
Return the configured initial maximum data limit for unidirectional streams.
- maxStreamDataUnidirectional(long) - Method in interface reactor.netty.quic.QuicInitialSettingsSpec.Builder
- 
Set the initial maximum data limit for unidirectional streams.
- maxStreams() - Method in class reactor.netty.http.Http2SettingsSpec
- 
Returns the configuredmaxStreamsvalue or null.
- maxStreams(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
- 
The connection is marked for closing once the number of all-time streams reachesmaxStreams.
- maxStreamsBidirectional() - Method in class reactor.netty.http.Http3SettingsSpec
- 
Return the configured initial maximum stream limit for bidirectional streams.
- maxStreamsBidirectional() - Method in class reactor.netty.quic.QuicInitialSettingsSpec
- 
Return the configured initial maximum stream limit for bidirectional streams.
- maxStreamsBidirectional(long) - Method in interface reactor.netty.http.Http3SettingsSpec.Builder
- 
Set the initial maximum stream limit for bidirectional streams.
- maxStreamsBidirectional(long) - Method in interface reactor.netty.quic.QuicInitialSettingsSpec.Builder
- 
Set the initial maximum stream limit for bidirectional streams.
- maxStreamsUnidirectional() - Method in class reactor.netty.quic.QuicInitialSettingsSpec
- 
Return the configured initial maximum stream limit for unidirectional streams.
- maxStreamsUnidirectional(long) - Method in interface reactor.netty.quic.QuicInitialSettingsSpec.Builder
- 
Set the initial maximum stream limit for unidirectional streams.
- memoryLevel(int) - Method in interface reactor.netty.http.server.compression.DeflateOption.Builder
- 
Sets the deflate memory level.
- memoryLevel(int) - Method in interface reactor.netty.http.server.compression.GzipOption.Builder
- 
Sets the gzip memory level.
- MeterKey - Class in reactor.netty.channel
- 
Contains meters' tags values.
- MeterKey(String, String, String, String) - Constructor for class reactor.netty.channel.MeterKey
- 
Deprecated.as of 1.1.17. Prefer usingMeterKey(String, String, String, String, String)constructor. This method will be removed in version 1.3.0.
- 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) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Whether to enable metrics to be collected and registered in Micrometer'sglobalRegistryunder the nameMetrics.CONNECTION_PROVIDER_PREFIX.
- metrics(boolean) - Method in class reactor.netty.tcp.TcpClient
- metrics(boolean) - 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'sglobalRegistry.
- metrics(boolean) - Method in class reactor.netty.udp.UdpClient
- metrics(boolean) - Method in class reactor.netty.udp.UdpServer
- metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient
- 
Whether to enable metrics to be collected and registered in Micrometer'sglobalRegistryunder the nameMetrics.HTTP_CLIENT_PREFIX.
- metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
- 
Whether to enable metrics to be collected and registered in Micrometer'sglobalRegistryunder the nameMetrics.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'sglobalRegistryunder the nameMetrics.HTTP_SERVER_PREFIX.
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClient
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.server.HttpServer
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpClient
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpServer
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.transport.Transport
- 
Specifies whether the metrics are enabled on theTransport.
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpClient
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpServer
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient
- 
Specifies whether the metrics are enabled on theHttpClient.
- metrics(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
- 
Specifies whether the metrics are enabled on theHttpServer.
- 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 theHttpServer.
- metrics(boolean, Supplier<? extends ConnectionProvider.MeterRegistrar>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Specifies whether the metrics are enabled on theConnectionProvider.
- Metrics - Class in reactor.netty.internal.util
- 
Utility class around instrumentation and metrics with Micrometer.
- Metrics - Class in reactor.netty
- 
Constants and utilities around metrics.
- Metrics() - Constructor for class reactor.netty.internal.util.Metrics
- Metrics() - Constructor for class reactor.netty.Metrics
- metricsRecorder() - Method in class reactor.netty.transport.TransportConfig
- 
Return the configured metrics recorderChannelMetricsRecorderor null.
- 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(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.transport.TransportConfig
- 
Obtains immediately theChannelMetricsRecorderfrom the providedSupplier.
- metricsRecorderInternal() - Method in class reactor.netty.transport.TransportConfig
- MicrometerChannelMetricsHandler - Class in reactor.netty.channel
- 
ChannelHandlerfor collecting metrics on protocol level.
- MicrometerChannelMetricsRecorder - Class in reactor.netty.channel
- 
AChannelMetricsRecorderimplementation for integration with Micrometer.
- 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
- 
AnHttpMetricsRecorderimplementation for integration with Micrometer.
- 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
- 
Returns a builder to mutate properties of thisConnectionProvider.
- mutate() - Method in class reactor.netty.resources.PooledConnectionProvider
- mutate() - Method in class reactor.netty.tcp.TcpResources
N
- NA - Static variable in class reactor.netty.Metrics
- name() - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- name() - Method in interface reactor.netty.resources.ConnectionProvider
- 
ReturnsConnectionProvidername used for metrics.
- name() - Method in class reactor.netty.resources.PooledConnectionProvider
- name() - Method in class reactor.netty.tcp.TcpResources
- name(String) - Method in class reactor.netty.resources.ConnectionProvider.Builder
- 
ConnectionProvidername is used for metrics.
- NAME - Static variable in class reactor.netty.Metrics
- NameResolverProvider - Class in reactor.netty.transport
- 
ANameResolverProviderwill produceDnsAddressResolverGroup.
- NameResolverProvider.NameResolverSpec - Interface in reactor.netty.transport
- NATIVE - Static variable in class reactor.netty.ReactorNetty
- 
Default value whether the native transport (epoll, io_uring, kqueue) will be preferred, fallback it will be preferred when available.
- ndots() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the number of dots which must appear in a name before an initial absolute query is made.
- ndots(int) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Sets the number of dots which must appear in a name before an initial absolute query is made.
- NettyInbound - Interface in reactor.netty
- 
An inbound-traffic API delegating to an underlyingChannel.
- NettyOutbound - Interface in reactor.netty
- 
An outbound-traffic API delegating to an underlyingChannel.
- NettyPipeline - Interface in reactor.netty
- 
Constant for names used when adding/removingChannelHandler.
- neverComplete() - Method in interface reactor.netty.NettyOutbound
- 
Returns a never completingMonoafter thisNettyOutbound.then()has completed.
- newClientResponseHolder(HttpHeaders, ClientCookieDecoder) - Static method in class reactor.netty.http.Cookies
- 
Return a new cookies holder from client response headers.
- newConnection() - Static method in class reactor.netty.http.client.HttpClient
- 
Prepare an unpooledHttpClient.
- newConnection() - Static method in interface reactor.netty.resources.ConnectionProvider
- 
Return aConnectionProviderthat will always create a newConnection.
- newConnection() - Static method in class reactor.netty.tcp.TcpClient
- 
Prepare a non pooledTcpClient.
- newFullBodyMessage(ByteBuf) - Method in class reactor.netty.http.HttpOperations
- newNameResolverGroup(LoopResources, boolean) - Method in class reactor.netty.transport.NameResolverProvider
- 
Provides a newDnsAddressResolverGroup.
- newPool(Publisher<T>, AllocationStrategy, Function<T, Publisher<Void>>, BiPredicate<T, PooledRefMetadata>) - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
- newPool(Publisher<T>, AllocationStrategy, Function<T, Publisher<Void>>, BiPredicate<T, PooledRefMetadata>, Function<PoolConfig<T>, InstrumentedPool<T>>) - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
- newPool(Publisher<T>, Function<T, Publisher<Void>>, BiPredicate<T, PooledRefMetadata>, PoolMetricsRecorder) - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
- newPool(Publisher<T>, Function<T, Publisher<Void>>, BiPredicate<T, PooledRefMetadata>, PoolMetricsRecorder, Function<PoolConfig<T>, InstrumentedPool<T>>) - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
- newProxyHandler() - Method in class reactor.netty.transport.ProxyProvider
- 
Return a new eventualProxyHandler.
- newRoutes() - Static method in interface reactor.netty.http.server.HttpServerRoutes
- 
Returns a new default routing registryHttpServerRoutes.
- newServerRequestHolder(HttpHeaders, ServerCookieDecoder) - Static method in class reactor.netty.http.Cookies
- 
Deprecated.as of 1.0.8. PreferServerCookies.newServerRequestHolder(HttpHeaders, ServerCookieDecoder). This method will be removed in version 1.2.0.
- newServerRequestHolder(HttpHeaders, ServerCookieDecoder) - Static method in class reactor.netty.http.server.ServerCookies
- 
Return a new cookies holder from server request headers.
- noComparator() - Method in interface reactor.netty.http.server.HttpServerRoutes
- 
Removes any previously appliedComparatorcustomization usingHttpServerRoutes.comparator(Comparator), and use the order in which the routes were configured.
- nonProxyHosts(String) - Method in interface reactor.netty.transport.ProxyProvider.Builder
- 
Regular expression (using java.util.regex) for a configured list of hosts that should be reached directly, bypassing the proxy.
- nonProxyHostsPredicate(Predicate<SocketAddress>) - Method in interface reactor.netty.transport.ProxyProvider.Builder
- 
A standard predicate expression for a configured list of hosts that should be reached directly, bypassing the proxy.
- NonSslRedirectDetector - Static variable in interface reactor.netty.NettyPipeline
- NonSslRedirectHandler - Static variable in interface reactor.netty.NettyPipeline
- noProxy() - Method in class reactor.netty.tcp.TcpClient
- noProxy() - Method in class reactor.netty.transport.ClientTransport
- 
Remove any previously applied Proxy configuration customization.
- NORMAL_CACHE_SIZE - Static variable in class reactor.netty.Metrics
- 
The size of the normal cache.
- noSSL() - Method in class reactor.netty.http.client.HttpClient
- 
Removes any previously applied SSL configuration customization.
- noSSL() - Method in class reactor.netty.http.server.HttpServer
- 
Removes any previously applied SSL configuration customization.
- noSSL() - Method in class reactor.netty.tcp.TcpClient
- 
Remove any previously applied SSL configuration customization.
- noSSL() - Method in class reactor.netty.tcp.TcpServer
- 
Removes any previously applied SSL configuration customization.
O
- OBSERVATION_KEY - Static variable in class reactor.netty.Metrics
- OBSERVATION_REGISTRY - Static variable in class reactor.netty.Metrics
- observationRegistry(ObservationRegistry) - Static method in class reactor.netty.Metrics
- 
Set theObservationRegistryto use in Reactor Netty for tracing related purposes.
- observe(ConnectionObserver) - Method in class reactor.netty.http.client.HttpClient
- observe(ConnectionObserver) - Method in class reactor.netty.tcp.TcpClient
- observe(ConnectionObserver) - Method in class reactor.netty.transport.Transport
- 
Set or add the givenConnectionObserverto observe the connection state changes.
- observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpClient
- observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpServer
- OFF - Enum constant in enum reactor.netty.http.server.ProxyProtocolSupportType
- 
Disable the proxy protocol support.
- ON - Enum constant in enum reactor.netty.http.server.ProxyProtocolSupportType
- 
Enable support for the"HAProxy proxy protocol"for deriving information about the address of the remote peer.
- onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.quic.QuicResources
- onChannel(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources
- 
Callback for aChannelselection.
- onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
- onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
- onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.quic.QuicResources
- onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources
- 
Callback for aChannelclass selection.
- onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.tcp.TcpResources
- onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.udp.UdpResources
- onChannelInit(ConnectionObserver, Channel, SocketAddress) - Method in interface reactor.netty.ChannelPipelineConfigurer
- 
Configure the channel pipeline while initializing the channel.
- OnChannelReadIdle - Static variable in interface reactor.netty.NettyPipeline
- OnChannelWriteIdle - Static variable in interface reactor.netty.NettyPipeline
- onClient(boolean) - Method in class reactor.netty.quic.QuicResources
- onClient(boolean) - Method in interface reactor.netty.resources.LoopResources
- 
Callback for clientEventLoopGroupcreation.
- onClient(boolean) - Method in class reactor.netty.tcp.TcpResources
- onClient(boolean) - Method in class reactor.netty.udp.UdpResources
- onComplete() - Method in class reactor.netty.channel.ChannelOperations
- onDispose() - Method in class reactor.netty.channel.ChannelOperations
- onDispose() - Method in interface reactor.netty.DisposableChannel
- 
Returns an observingMonoterminating with success when shutdown successfully or error.
- onDispose(Disposable) - Method in class reactor.netty.channel.ChannelOperations
- onDispose(Disposable) - Method in interface reactor.netty.Connection
- onDispose(Disposable) - Method in interface reactor.netty.DisposableChannel
- 
Assigns aDisposableto be invoked when the channel is closed.
- onDispose(Mono<Void>) - Method in class reactor.netty.resources.PooledConnectionProvider
- onError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
- onHeadersSent() - Method in class reactor.netty.http.HttpOperations
- onInboundCancel() - Method in class reactor.netty.channel.ChannelOperations
- 
React on inbound cancel (receive() subscriber cancelled).
- onInboundClose() - Method in class reactor.netty.channel.ChannelOperations
- 
React on inbound close (channel closed prematurely).
- onInboundComplete() - Method in class reactor.netty.channel.ChannelOperations
- 
React on inbound completion (last packet).
- onInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
- 
React on inbound error.
- onInboundNext(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.ChannelOperations
- 
React on inboundChannel.read().
- onNext(Void) - Method in class reactor.netty.channel.ChannelOperations
- onOutboundComplete() - Method in class reactor.netty.channel.ChannelOperations
- 
React on inbound/outbound completion (last packet).
- onOutboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
- 
React on inbound/outbound error.
- onReadIdle(long, Runnable) - Method in interface reactor.netty.Connection
- 
Assign aRunnableto be invoked when reads have become idle for the given timeout.
- onServer(boolean) - Method in class reactor.netty.quic.QuicResources
- onServer(boolean) - Method in interface reactor.netty.resources.LoopResources
- 
Callback for serverEventLoopGroupcreation, this is theEventLoopGroupfor the child channel.
- onServer(boolean) - Method in class reactor.netty.tcp.TcpResources
- onServer(boolean) - Method in class reactor.netty.udp.UdpResources
- onServerSelect(boolean) - Method in class reactor.netty.quic.QuicResources
- onServerSelect(boolean) - Method in interface reactor.netty.resources.LoopResources
- 
Callback for server selectEventLoopGroupcreation, this is theEventLoopGroupfor the acceptor channel.
- onServerSelect(boolean) - Method in class reactor.netty.tcp.TcpResources
- onServerSelect(boolean) - Method in class reactor.netty.udp.UdpResources
- onStart(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTimerObservationHandler
- onStateChange(Connection, ConnectionObserver.State) - Method in interface reactor.netty.ConnectionObserver
- 
React on connection state change (e.g.
- onStop(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTimerObservationHandler
- onSubscribe(Subscription) - Method in class reactor.netty.channel.ChannelOperations
- onTerminate() - Method in class reactor.netty.channel.ChannelOperations
- 
Return a Mono succeeding when aChannelOperationshas been terminated.
- onTerminate() - Method in interface reactor.netty.Connection
- 
Return a Mono succeeding when aConnectionis not used anymore by any current operations.
- onUncaughtException(Connection, Throwable) - Method in interface reactor.netty.ConnectionObserver
- 
React on connection fatal error, will request a disconnecting state change by default.
- onUnprocessedOutboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
- 
React on an unprocessed outbound error.
- onWritabilityChanged() - Method in class reactor.netty.channel.ChannelOperations
- 
React on Channel writability change.
- onWriteIdle(long, Runnable) - Method in interface reactor.netty.Connection
- 
Assign aRunnableto be invoked when writes have become idle for the given timeout.
- option(ChannelOption<O>, O) - Method in class reactor.netty.tcp.TcpClient
- option(ChannelOption<O>, O) - Method in class reactor.netty.transport.Transport
- 
Update the given option key or remove it if the value is null.
- option(ChannelOption<O>, O) - Method in class reactor.netty.udp.UdpClient
- option(ChannelOption<O>, O) - Method in class reactor.netty.udp.UdpServer
- options() - Method in class reactor.netty.http.client.HttpClient
- 
HTTP OPTIONS to connect theHttpClient.
- options() - Method in class reactor.netty.transport.TransportConfig
- 
Return the read-onlyChannelOptionmap.
- options(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
- 
Listens for HTTP OPTIONS on the passed path to be used as a routing condition.
- outbound() - Method in class reactor.netty.channel.ChannelOperations
- outbound() - Method in interface reactor.netty.Connection
- 
Return theNettyOutboundwrite API from this connection.
- outboundHttpMessage() - Method in class reactor.netty.http.HttpOperations
- 
Outbound Netty HttpMessage.
P
- 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.quic.QuicClientConfig
- parentChannelInitializer() - Method in class reactor.netty.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
- 
HTTP PATCH to connect theHttpClient.
- 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 theHttpInfos.uri()without the leading and trailing '/' if present.
- path(SocketAddress) - Static method in class reactor.netty.transport.DomainSocketAddressUtils
- 
Returns the path to the domain socket.
- 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 configuringConnectionProviderthe 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 configuringConnectionProvideracquire timeout (resolution: ms).
- pendingAcquireTimer(BiFunction<Runnable, Duration, Disposable>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
- 
Set the option to use for configuringConnectionProviderpending acquire timer.
- 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 andInteger.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, orInteger.MAX_VALUEfor 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), or0for 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
- 
DefaultgetPermitsSamplingRate(between 0d and 1d (percentage)) to be used with aSamplingAllocationStrategy.
- 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
- 
DefaultreturnPermitsSamplingRate(between 0d and 1d (percentage)) to be used with aSamplingAllocationStrategy.
- PooledConnectionProvider<T extends Connection> - Class in reactor.netty.resources
- 
BaseConnectionProviderimplementation.
- 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.quic.QuicClient
- 
The port to which this client should connect.
- port(int) - Method in class reactor.netty.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
- 
HTTP POST to connect theHttpClient.
- 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
- 
An error for signalling that the connection was closed prematurelyChannelInboundHandler.channelInactive(io.netty.channel.ChannelHandlerContext),ChannelOperations.onInboundClose(),ChannelOperations#onInboundError().
- prepareHttpMessage(ByteBuf) - Method in class reactor.netty.http.HttpOperations
- protocol() - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- protocol() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
- 
Returns the protocol version, (e.g.
- 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.
- protocol(HttpProtocol...) - Method in class reactor.netty.http.client.HttpClient
- 
The HTTP protocol to support.
- protocol(HttpProtocol...) - Method in class reactor.netty.http.server.HttpServer
- 
The HTTP protocol to support.
- 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() - Method in interface reactor.netty.http.websocket.WebsocketSpec
- 
Returns the configured sub protocols.
- protocols() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
- protocols(String) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
- 
Sets sub-protocol to use in websocket handshake signature.
- 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 - Enum constant in enum reactor.netty.channel.ChannelMeters.ChannelMetersTags
- 
Proxy address, when there is a proxy configured.
- 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() - Method in class reactor.netty.transport.ClientTransportConfig
- 
Return theProxyProviderif any or null.
- proxyProvider(ProxyProvider) - Method in class reactor.netty.http.client.HttpClientConfig
- 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
- proxyProviderSupplier() - Method in class reactor.netty.transport.ClientTransportConfig
- 
Return theProxyProvidersupplier if any or null.
- proxyProviderSupplier(Supplier<ProxyProvider>) - Method in class reactor.netty.http.client.HttpClientConfig
- proxyProviderSupplier(Supplier<ProxyProvider>) - Method in class reactor.netty.transport.ClientTransportConfig
- proxyWhen(BiFunction<HttpClientConfig, ? super ProxyProvider.TypeSpec, Mono<? extends ProxyProvider.Builder>>) - Method in class reactor.netty.http.client.HttpClient
- 
Supports proxy configuration with a deferred approach.
- 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 configuredSETTINGS_ENABLE_PUSHvalue or null.
- put() - Method in class reactor.netty.http.client.HttpClient
- 
HTTP PUT to connect theHttpClient.
- 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.
Q
- queryTimeout() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the configured timeout of each DNS query performed by this resolver.
- queryTimeout(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Sets the timeout of each DNS query performed by this resolver (resolution: milliseconds).
- QUIC_CLIENT_PREFIX - Static variable in class reactor.netty.quic.QuicClientConfig
- 
Name prefix that will be used for the QUIC client's metrics registered in Micrometer's global registry.
- QUIC_SERVER_PREFIX - Static variable in class reactor.netty.quic.QuicServerConfig
- 
Name prefix that will be used for the QUIC server's metrics registered in Micrometer's global registry.
- QuicClient - Class in reactor.netty.quic
- 
A QuicClient allows building in a safe immutable way a QUIC client that is materialized and connecting whenQuicClient.connect()is ultimately called.
- QuicClient() - Constructor for class reactor.netty.quic.QuicClient
- QuicClientConfig - Class in reactor.netty.quic
- 
Encapsulate all necessary configuration for QUIC client transport.
- QuicConnection - Interface in reactor.netty.quic
- 
API for creating and handling streams.
- QuicInbound - Interface in reactor.netty.quic
- 
An inbound-traffic API delegating to an underlyingChannel.
- QuicInitialSettingsSpec - Class in reactor.netty.quic
- 
A configuration builder to fine tune the QUIC initial settings.
- QuicInitialSettingsSpec.Builder - Interface in reactor.netty.quic
- QuicOutbound - Interface in reactor.netty.quic
- 
An outbound-traffic API delegating to an underlyingChannel.
- QuicResources - Class in reactor.netty.quic
- 
Hold the default QUIC resources.
- QuicResources(LoopResources) - Constructor for class reactor.netty.quic.QuicResources
- QuicServer - Class in reactor.netty.quic
- 
A QuicServer allows building in a safe immutable way a QUIC server that is materialized and bound whenQuicServer.bind()is ultimately called.
- QuicServer() - Constructor for class reactor.netty.quic.QuicServer
- QuicServerConfig - Class in reactor.netty.quic
- 
Encapsulate all necessary configuration for QUIC server transport.
- QuicStreamInfo - Interface in reactor.netty.quic
- 
Exposes information for theQuicStreamChannelas stream id etc.
R
- ReactiveBridge - Static variable in interface reactor.netty.NettyPipeline
- REACTOR_NETTY_SEND_MAX_PREFETCH_SIZE - Static variable in class reactor.netty.ReactorNetty
- 
Default prefetch size (Subscription.request(long)) for data stream Publisher, fallback to 128.
- 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.internal - package reactor.netty.http.internal
- reactor.netty.http.logging - package reactor.netty.http.logging
- 
Http message log factory.
- reactor.netty.http.observability - package reactor.netty.http.observability
- 
This package contains tracing observation handlers forHttpClientandHttpServer.
- reactor.netty.http.server - package reactor.netty.http.server
- 
Http Server abstractions and factory.
- reactor.netty.http.server.compression - package reactor.netty.http.server.compression
- 
Server compression.
- reactor.netty.http.server.logging - package reactor.netty.http.server.logging
- 
Http access log.
- reactor.netty.http.server.logging.error - package reactor.netty.http.server.logging.error
- 
Http error log.
- reactor.netty.http.websocket - package reactor.netty.http.websocket
- 
Common components for Websocket 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.quic - package reactor.netty.quic
- 
Components for writing QUIC-based clients and servers using Reactor abstractions.
- reactor.netty.resources - package reactor.netty.resources
- 
Contracts for managing connections viaConnectionProviderand event-loop resources viaLoopResources.
- 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 NettyLoggingHandlerimplementation.
- 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
- 
Reactor Netty factory for generating a log message based on a givenHttpMessageArgProvider.
- ReactorNettyHttpMessageLogFactory() - Constructor for class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
- ReactorNettyPropagatingReceiverTracingObservationHandler - Class in reactor.netty.http.observability
- 
Reactor Netty specificPropagatingReceiverTracingObservationHandler.
- ReactorNettyPropagatingReceiverTracingObservationHandler(Tracer, Propagator) - Constructor for class reactor.netty.http.observability.ReactorNettyPropagatingReceiverTracingObservationHandler
- 
Creates a new instance ofReactorNettyPropagatingReceiverTracingObservationHandler.
- ReactorNettyPropagatingSenderTracingObservationHandler - Class in reactor.netty.http.observability
- 
Reactor Netty specificPropagatingSenderTracingObservationHandler.
- ReactorNettyPropagatingSenderTracingObservationHandler(Tracer, Propagator) - Constructor for class reactor.netty.http.observability.ReactorNettyPropagatingSenderTracingObservationHandler
- 
Creates a new instance ofReactorNettyPropagatingSenderTracingObservationHandler.
- 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() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Return the configured read timeout for the request or null.
- 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).
- 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 newConnectionreference 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 underlyingWebsocketInbound.
- receive() - Method in interface reactor.netty.NettyInbound
- 
AFluxextension 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
- 
Returns aFluxofHttpContentcontaining received chunks.
- receiveForm() - Method in interface reactor.netty.http.server.HttpServerRequest
- 
When the request isPOSTand haveContent-Typewith valueapplication/x-www-form-urlencodedormultipart/form-data, returns aFluxofHttpDatacontaining receivedAttribute/FileUpload.
- receiveForm(Consumer<HttpServerFormDecoderProvider.Builder>) - Method in interface reactor.netty.http.server.HttpServerRequest
- 
When the request isPOSTand haveContent-Typewith valueapplication/x-www-form-urlencodedormultipart/form-data, returns aFluxofHttpDatacontaining receivedAttribute/FileUpload.
- receiveFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound
- 
Receive aFluxofWebSocketFrameformed frame content.
- receiveObject() - Method in class reactor.netty.channel.ChannelOperations
- receiveObject() - Method in interface reactor.netty.NettyInbound
- 
a Object inboundFlux.
- 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(SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- recordConnectTime(SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- 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, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- recordConnectTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- 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(ContextView, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- 
Records the time that is spent for connecting to the remote address.
- recordDataReceived(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
- 
Records the amount of the data that is received, in bytes.
- recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- 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
- recordDataReceived(SocketAddress, 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 class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- recordDataReceived(SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- 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, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- 
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(ContextView, SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- 
Records the amount of the data that is received, in bytes.
- 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.
- 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.
- recordDataReceivedTime(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 class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
- 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(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.
- recordDataSent(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
- 
Records the amount of the data that is sent, in bytes.
- recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- 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
- recordDataSent(SocketAddress, 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 class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- recordDataSent(SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- 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, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- 
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(ContextView, SocketAddress, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- 
Records the amount of the data that is sent, in bytes.
- 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.
- 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.
- recordDataSentTime(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 class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
- 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(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.
- 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(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.
- recordResponseTime(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 class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
- 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(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.
- 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, 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 class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- recordTlsHandshakeTime(SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
- 
Records the time that is spent for TLS handshake.
- recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
- recordTlsHandshakeTime(ContextView, SocketAddress, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
- 
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.
- recordWrite(ChannelHandlerContext, SocketAddress, long) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
- recvQueueLen() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured RECV queue length.
- 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 thatHttpServerwill 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 requestBiConsumeror 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, HttpConnectionPoolMetrics) - Method in class reactor.netty.http.client.HttpMeterRegistrarAdapter
- 
Registers HTTP/2 or HTTP/3 specific metrics for a connection pool.
- registerMetrics(String, String, SocketAddress, ConnectionPoolMetrics) - Method in class reactor.netty.http.client.HttpMeterRegistrarAdapter
- 
Registers metrics for a connection pool.
- 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 - Enum constant in enum reactor.netty.channel.ChannelMeters.ChannelMetersTags
- 
Remote address.
- REMOTE_ADDRESS - Static variable in class reactor.netty.Metrics
- remoteAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
- 
Returns the address of the client that initiated the request, possiblynullin case of Unix Domain Sockets.
- remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
- remoteAddress() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Deprecated.as of 1.0.26. UseConnectionInformation.connectionRemoteAddress()
- remoteAddress() - Method in interface reactor.netty.http.server.logging.error.ErrorLogArgProvider
- 
Returns the address of the remote peer or possiblynullin case of Unix Domain Sockets.
- remoteAddress() - Method in class reactor.netty.quic.QuicClientConfig
- 
Return the remote configuredSocketAddress.
- remoteAddress() - Method in class reactor.netty.transport.ClientTransportConfig
- 
Return the remote configuredSocketAddress.
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient
- remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.quic.QuicClient
- 
The address to which this client should connect on each subscribe.
- 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(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
- 
A generic route predicate that if matched already register I/O handler useHttpServerRoutes.route(Predicate, BiFunction)will be removed.
- 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 theHttpClient.
- REQUEST - Enum constant in enum reactor.netty.http.logging.HttpMessageType
- 
RepresentsHttpRequest.
- REQUEST_DECODING_FAILED - Enum constant in enum reactor.netty.http.server.HttpServerState
- 
The request was received but with decoding failures.
- REQUEST_PREPARED - Enum constant in enum reactor.netty.http.client.HttpClientState
- 
The request has been prepared and ready for I/O handler to be invoked.
- REQUEST_RECEIVED - Enum constant in enum reactor.netty.http.server.HttpServerState
- 
The request was received.
- REQUEST_SENT - Enum constant in enum reactor.netty.http.client.HttpClientState
- 
The request has been sent.
- requestHeader(CharSequence) - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns the value of a request header with the specified name ornullis case such request header does not exist.
- requestHeaderIterator() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns an iterator over all request headers.
- requestHeaders() - Method in interface reactor.netty.http.client.HttpClientInfos
- 
Return outbound headers to be sent.
- requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest
- 
Returns inboundHttpHeaders.
- requestId() - Method in interface reactor.netty.http.HttpInfos
- 
Return a unique id for the request.
- requestId() - Method in class reactor.netty.http.HttpOperations
- requestTimeout() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Return the configured request timeout for the request or null.
- requestTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer
- 
Specifies the maximum duration for reading a given request content (resolution: ms).
- 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.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() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the configured DNS resolver cache or null.
- resolveCache(DnsCache) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Sets the resolve cache to use for DNS resolution.
- resolvedAddressesSelector(ClientTransport.ResolvedAddressSelector<? super CONF>) - Method in class reactor.netty.transport.ClientTransport
- 
Determines the resolved addresses to which this client should connect for each subscription.
- resolvedAddressTypes() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the configured list of the protocol families of the address resolved or null.
- resolvedAddressTypes(ResolvedAddressTypes) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Sets the list of the protocol families of the address resolved.
- resolvePath(String) - Static method in class reactor.netty.http.HttpOperations
- 
Returns the decoded path portion from the provideduri.
- resolver() - Method in class reactor.netty.transport.ClientTransportConfig
- 
Return the configuredAddressResolverGroupor null.
- resolver(AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpClient
- resolver(AddressResolverGroup<?>) - Method in class reactor.netty.transport.ClientTransport
- 
Assign anAddressResolverGroup.
- resolver(Consumer<NameResolverProvider.NameResolverSpec>) - Method in class reactor.netty.transport.ClientTransport
- 
Apply a name resolver configuration.
- 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
- 
Return the response status and headers asHttpClientResponse
- response(BiFunction<? super HttpClientResponse, ? super ByteBufFlux, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
- 
Extract a response flux from the givenHttpClientResponseand bodyByteBufFlux.
- RESPONSE - Enum constant in enum reactor.netty.http.logging.HttpMessageType
- 
RepresentsHttpResponse.
- RESPONSE_COMPLETED - Enum constant in enum reactor.netty.http.client.HttpClientState
- 
The response fully received.
- RESPONSE_INCOMPLETE - Enum constant in enum reactor.netty.http.client.HttpClientState
- 
The request has been sent but the response has not been fully received and the connection has been prematurely closed.
- RESPONSE_RECEIVED - Enum constant in enum reactor.netty.http.client.HttpClientState
- 
The response status and headers have been received.
- 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
- 
Extract a response flux from the givenHttpClientResponseand underlyingConnection.
- responseContent() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
- 
Return the response body chunks asByteBufFlux.
- responseHeader(CharSequence) - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns the value of a response header with the specified name ornullis case such response header does not exist.
- responseHeaderIterator() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns an iterator over all response headers.
- 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
- 
Extract a response mono from the givenHttpClientResponseand aggregated bodyByteBufMono.
- responseTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
- responseTimeout() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return the configured response timeout or null.
- 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(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
- 
Enables anAddressResolverGroupofDnsNameResolvers that supports random selection of destination addresses if multiple are provided by the nameserver.
- route(Consumer<? super HttpServerRoutes>) - Method in class reactor.netty.http.server.HttpServer
- 
Define routes for the server through the providedHttpServerRoutesbuilder.
- 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.
- runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpClient
- runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpServer
- runOn(EventLoopGroup) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Performs the communication with the DNS servers on the givenEventLoopGroup.
- runOn(EventLoopGroup) - Method in class reactor.netty.transport.Transport
- 
Run IO loops on the givenEventLoopGroup.
- runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpClient
- runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpServer
- runOn(LoopResources) - Method in class reactor.netty.tcp.TcpClient
- runOn(LoopResources) - Method in class reactor.netty.tcp.TcpServer
- runOn(LoopResources) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Performs the communication with the DNS servers on a suppliedEventLoopGroupfrom theLoopResourcescontainer.
- runOn(LoopResources) - Method in class reactor.netty.transport.Transport
- 
Run IO loops on a suppliedEventLoopGroupfrom theLoopResourcescontainer.
- runOn(LoopResources) - Method in class reactor.netty.udp.UdpClient
- runOn(LoopResources) - Method in class reactor.netty.udp.UdpServer
- runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpClient
- runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpServer
- runOn(LoopResources, boolean) - Method in class reactor.netty.transport.ClientTransport
- runOn(LoopResources, boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Performs the communication with the DNS servers on a suppliedEventLoopGroupfrom theLoopResourcescontainer.
- runOn(LoopResources, boolean) - Method in class reactor.netty.transport.Transport
- 
Run IO loops on a suppliedEventLoopGroupfrom theLoopResourcescontainer.
- runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpClient
- 
Run IO loops on a suppliedEventLoopGroupfrom theLoopResourcescontainer.
- runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpServer
- 
Run IO loops on a suppliedEventLoopGroupfrom theLoopResourcescontainer.
- runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpClient
- 
Deprecated.as of 1.3.0. PreferUdpClient.runOn(LoopResources, SocketProtocolFamily). This method will be removed in version 1.4.0.
- runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpServer
- 
Deprecated.as of 1.3.0. PreferUdpServer.runOn(LoopResources, SocketProtocolFamily). This method will be removed in version 1.4.0.
- runOn(LoopResources, SocketProtocolFamily) - Method in class reactor.netty.udp.UdpClient
- 
Run IO loops on a suppliedEventLoopGroupfrom theLoopResourcescontainer.
- runOn(LoopResources, SocketProtocolFamily) - Method in class reactor.netty.udp.UdpServer
- 
Run IO loops on a suppliedEventLoopGroupfrom theLoopResourcescontainer.
S
- safeRelease(Object) - Static method in class reactor.netty.ReactorNetty
- 
Try to callReferenceCounted.release()if the specified message implementsReferenceCounted.
- scheduler() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
- 
Returns the configured scheduler to be used for offloading disk operations in the decoding phase.
- 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.
- scheme() - Method in interface reactor.netty.http.server.ConnectionInformation
- 
Returns the current protocol scheme.
- searchDomains() - Method in class reactor.netty.transport.NameResolverProvider
- 
Returns the configured list of search domains of the resolver or null.
- searchDomains(List<String>) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
- 
Sets the list of search domains of the resolver.
- secure() - Method in class reactor.netty.http.client.HttpClient
- 
Enable default sslContext support.
- secure() - Method in class reactor.netty.tcp.TcpClient
- 
Enable default sslContext support.
- secure(QuicSslContext) - Method in class reactor.netty.quic.QuicServer
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.client.HttpClient
- 
Apply an SSL configuration customization via the passed builder.
- 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>) - Method in class reactor.netty.tcp.TcpClient
- 
Apply an SSL configuration customization via the passed builder.
- secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpServer
- 
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(Function<QuicChannel, ? extends QuicSslEngine>) - Method in class reactor.netty.quic.QuicServer
- secure(SslProvider) - Method in class reactor.netty.http.client.HttpClient
- 
Apply an SSL configuration via the passedSslProvider.
- secure(SslProvider) - Method in class reactor.netty.http.server.HttpServer
- 
Applies an SSL configuration via the passedSslProvider.
- secure(SslProvider) - Method in class reactor.netty.tcp.TcpClient
- 
Apply an SSL configuration via the passedSslProvider.
- secure(SslProvider) - Method in class reactor.netty.tcp.TcpServer
- 
Applies an SSL configuration via the passedSslProvider.
- secure(SslProvider, boolean) - Method in class reactor.netty.http.server.HttpServer
- 
Applies an SSL configuration via the passedSslProvider.
- 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() - Method in interface reactor.netty.http.server.HttpServerResponse
- 
Sends the HTTP headers and empty content thus delimiting a full empty body http response.
- 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 theNettyOutboundsending builder and returning aPublisherto 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 returnedPublisherto signal end of the request.
- send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
- 
Configure a body to send on request.
- send(Publisher<? extends ByteBuf>) - Method in class reactor.netty.http.HttpOperations
- 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 class reactor.netty.channel.ChannelOperations
- send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
- 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, 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, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
- 
Prepare to send a close frame on subscribe then close the underlying channel.
- sendFile(Path) - Method in interface reactor.netty.NettyOutbound
- 
Sends content from givenPathusingFileChannel.transferTo(long, long, WritableByteChannel)support.
- sendFile(Path, long, long) - Method in class reactor.netty.http.HttpOperations
- sendFile(Path, long, long) - Method in interface reactor.netty.NettyOutbound
- 
Sends content from the givenPathusingFileChannel.transferTo(long, long, WritableByteChannel)support, if the system supports it, the path resolves to a local file systemFile, compression and SSL/TLS is not enabled, then transfer will use zero-byte copy to the peer., otherwise chunked read/write will be used.
- sendFileChunked(Path, long, long) - Method in interface reactor.netty.NettyOutbound
- 
Sends content from givenPathusing 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
- 
Returns aNettyOutboundsuccessful on committed response.
- sendNotFound() - Method in interface reactor.netty.http.server.HttpServerResponse
- 
Sends 404 statusHttpResponseStatus.NOT_FOUND.
- sendObject(Object) - Method in class reactor.netty.channel.ChannelOperations
- sendObject(Object) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
- sendObject(Object) - Method in class reactor.netty.http.HttpOperations
- 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).
- sendObject(Publisher<?>) - Method in interface reactor.netty.NettyOutbound
- 
Sends an object through Netty pipeline.
- sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.channel.ChannelOperations
- sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
- sendObject(Publisher<?>, Predicate<Object>) - Method in interface reactor.netty.NettyOutbound
- 
Sends an object through Netty pipeline.
- sendQueueLen() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configured SEND queue length.
- sendRedirect(String) - Method in interface reactor.netty.http.server.HttpServerResponse
- 
Sends redirect statusHttpResponseStatus.FOUNDalong with a location header to the remote client.
- 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.http.websocket.WebsocketOutbound
- 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
- 
Cookiesholder from server request headers.
- serverNames(SNIServerName...) - Method in interface reactor.netty.tcp.SslProvider.Builder
- 
Sets the desiredSNIServerNames.
- ServerTransport<T extends ServerTransport<T,CONF>, CONF extends ServerTransportConfig<CONF>> - Class in reactor.netty.transport 
- 
A generic serverTransportthat willServerTransport.bind()to a local address and provide aDisposableServer.
- 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(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.http.HttpResources
- 
Update event loops resources and return the global HTTP/1.x resources.
- set(LoopResources) - Static method in class reactor.netty.quic.QuicResources
- 
Update event loops resources and return the global QUIC 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
- 
AddsContextViewto the channel attributes.
- setSniAsyncMappings(AsyncMapping<String, SslProvider>) - Method in interface reactor.netty.tcp.SslProvider.Builder
- 
Sets the provided mappings of domain names toSslProvider.
- setSniMappings(Map<String, Consumer<? super SslProvider.SslContextSpec>>) - Method in interface reactor.netty.tcp.SslProvider.Builder
- 
Sets the provided mappings of domain names toSslProviderbuilders.
- shouldProxy(SocketAddress) - Method in class reactor.netty.transport.ProxyProvider
- 
Returns true when the givenSocketAddressshould be reached via the configured proxy.
- shutdown() - Static method in class reactor.netty.udp.UdpResources
- 
Shutdown the globalUdpResourceswithout 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 globalUdpResourceswithout 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 globalUdpResourceswithout resetting them, effectively cleaning up associated resources without creating new ones.
- SIMPLE - Enum constant in enum reactor.netty.transport.logging.AdvancedByteBufFormat
- 
When wire logging is enabled with this format, only the events will be logged.
- SMALL_CACHE_SIZE - Static variable in class reactor.netty.Metrics
- 
The size of the small cache.
- socketAddress(SocketAddress) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
- 
The address to connect to.
- socketAddress(Supplier<? extends SocketAddress>) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
- 
The supplier for the address to connect to.
- socketFamily() - Method in class reactor.netty.udp.UdpClientConfig
- 
Return the configuredSocketProtocolFamilyto run with or null.
- socketFamily() - Method in class reactor.netty.udp.UdpServerConfig
- 
Return the configuredSocketProtocolFamilyto run with or null.
- SOCKS4 - Enum constant in enum reactor.netty.transport.ProxyProvider.Proxy
- SOCKS5 - Enum constant in enum reactor.netty.transport.ProxyProvider.Proxy
- 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.http.Http3SslContextSpec
- sslContext() - Method in class reactor.netty.tcp.AbstractProtocolSslContextSpec
- sslContext() - Method in interface reactor.netty.tcp.SslProvider.GenericSslContextSpec
- 
Create a newSslContextinstance with the configured settings.
- sslContext(SslContext) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
- 
The SslContext to set when configuring SSL.
- sslContext(Map<String, SslProvider>) - Method in class reactor.netty.http.Http3SslContextSpec
- sslContext(Map<String, SslProvider>) - Method in interface reactor.netty.tcp.SslProvider.GenericSslContextSpecWithSniSupport
- 
Create a newSslContextinstance with the configured settings.
- sslContext(SslProvider.GenericSslContextSpec<?>) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
- 
SslContext builder that provides, specific for the protocol, default configuration e.g.
- sslContext(SslProvider.ProtocolSslContextSpec) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
- 
Deprecated.as of 1.2.0. Prefer usingSslProvider.SslContextSpec.sslContext(SslProvider.GenericSslContextSpec). This method will be removed in version 1.3.0.
- 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
- 
Returns the currentSslProviderif thatHttpClientsecured via SSL transport or null.
- sslProvider() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Returns the currentSslProviderif thatHttpServersecured via SSL transport or null.
- sslProvider() - Method in class reactor.netty.tcp.TcpClientConfig
- 
Return the currentSslProviderif thatTcpClientsecured via SSL transport or null.
- sslProvider() - Method in class reactor.netty.tcp.TcpServerConfig
- 
Returns the currentSslProviderif thatTcpServersecured via SSL transport or null.
- SslProvider - Class in reactor.netty.tcp
- 
SSL Provider.
- SslProvider.Builder - Interface in reactor.netty.tcp
- SslProvider.GenericSslContextSpec<B> - Interface in reactor.netty.tcp
- 
Generic SslContext builder that provides, specific for the protocol, default configuration.
- SslProvider.GenericSslContextSpecWithSniSupport<B> - Interface 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() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns the response status, (e.g.
- status(int) - Method in interface reactor.netty.http.server.HttpServerResponse
- 
Sets an HTTP status to be sent along with the headers.
- status(HttpResponseStatus) - Method in interface reactor.netty.http.server.HttpServerResponse
- 
Sets an HTTP status to be sent along with the headers.
- STATUS - Static variable in class reactor.netty.Metrics
- STREAM_CONFIGURED - Enum constant in enum reactor.netty.http.client.HttpClientState
- 
Propagated when a stream is bound to a channelOperation and ready for user interaction.
- streamAttr(AttributeKey<A>, A) - Method in class reactor.netty.quic.QuicServer
- 
Injects default attribute to the futureQuicStreamChannel.
- streamAttributes() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the read-only default stream attributes.
- streamId() - Method in interface reactor.netty.quic.QuicStreamInfo
- 
The id of the stream.
- streaming() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
- 
Returns whether the streaming mode is enabled.
- streaming(boolean) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
- 
When set totrue, the data is streamed directly from the parsed input buffer stream, which means it is not stored either in memory or file.
- streamObserve(ConnectionObserver) - Method in class reactor.netty.quic.QuicServer
- 
Set or add the givenConnectionObserverfor each stream.
- streamObserver() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configuredConnectionObserverif any orConnectionObserver.emptyListener()for each stream.
- streamOption(ChannelOption<A>, A) - Method in class reactor.netty.quic.QuicServer
- 
Injects default options to the futureQuicStreamChannel.
- streamOptions() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the read-onlyChannelOptionmap for each stream.
- STREAMS_ACTIVE - Static variable in class reactor.netty.Metrics
- 
The number of active HTTP/2 streams.
- streamType() - Method in interface reactor.netty.quic.QuicStreamInfo
- 
Returns theQuicStreamTypeof the stream.
- stringToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound
- subscribe(Subscriber<? super Void>) - Method in interface reactor.netty.NettyOutbound
- 
Subscribes aVoidsubscriber to this outbound and trigger all eventual parent outbound send.
- subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufFlux
- subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufMono
- 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
T
- tagSpan(Observation.Context, Span) - 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
- 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 whenTcpClient.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
- 
Deprecated.Use the other methods exposed byHttpClientto achieve the same configurations. This method will be removed in version 1.1.0.
- tcpConfiguration(Function<? super TcpServer, ? extends TcpServer>) - Method in class reactor.netty.http.server.HttpServer
- 
Deprecated.Use the other methods exposed byHttpServerto achieve the same configurations. This method will be removed in version 1.1.0.
- 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 whenServerTransport.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:SslProviderwill be set depending onOpenSsl.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, File, String) - 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, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm
- 
Add an HTTP File Upload attribute for a text file.
- TEXTUAL - Enum constant in enum reactor.netty.transport.logging.AdvancedByteBufFormat
- 
When wire logging is enabled with this format, both events and content will be logged.
- 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 aMonoof pending outbound(s) write completion.
- then(Publisher<Void>) - Method in interface reactor.netty.NettyOutbound
- then(Publisher<Void>, Runnable) - Method in interface reactor.netty.NettyOutbound
- 
Append aPublishertask such as a Mono and return a newNettyOutboundto sequence further send.
- then(ChannelPipelineConfigurer) - Method in interface reactor.netty.ChannelPipelineConfigurer
- 
Chain together anotherChannelPipelineConfigurer.
- then(ConnectionObserver) - Method in interface reactor.netty.ConnectionObserver
- 
Chain together anotherConnectionObserver.
- 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() - Method in class reactor.netty.http.Http3SettingsSpec
- 
Return the configuredQuicTokenHandleror null.
- tokenHandler() - Method in class reactor.netty.quic.QuicServerConfig
- 
Return the configuredQuicTokenHandleror null.
- tokenHandler(QuicTokenHandler) - Method in interface reactor.netty.http.Http3SettingsSpec.Builder
- 
Set theQuicTokenHandlerthat is used to generate and validate tokens ornullif no tokens should be used at all.
- tokenHandler(QuicTokenHandler) - Method in class reactor.netty.quic.QuicServer
- 
Configure theQuicTokenHandlerthat is used to generate and validate tokens.
- 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
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as the functionality is not used anymore.
- 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(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.
- trace(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
- trace(HttpMessageArgProvider) - Method in interface reactor.netty.http.logging.HttpMessageLogFactory
- 
Generates a log message based on a givenHttpMessageArgProviderfor a log with a levelTRACE.
- 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
- 
TransportConnectoris a helper class that creates, initializes and registers the channel.
- type(ProxyProvider.Proxy) - Method in interface reactor.netty.transport.ProxyProvider.TypeSpec
- 
The proxy type.
- TYPE - Static variable in class reactor.netty.Metrics
U
- UDP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
- 
Name prefix that will be used for the UDP client's metrics registered in Micrometer's global registry.
- UDP_IO_THREAD_COUNT - Static variable in class reactor.netty.ReactorNetty
- 
Default worker thread count for UDP, fallback to available processor (but with a minimum value of 4).
- UDP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
- 
Name prefix that will be used for the UDP server's metrics registered in Micrometer's global registry.
- UdpClient - Class in reactor.netty.udp
- 
A UdpClient allows building in a safe immutable way a UDP client that is materialized and connecting whenUdpClient.connect()is ultimately called.
- UdpClient() - Constructor for class reactor.netty.udp.UdpClient
- UdpClientConfig - Class in reactor.netty.udp
- 
Encapsulate all necessary configuration for UDP client transport.
- UdpInbound - Interface in reactor.netty.udp
- 
An inbound-traffic API delegating to an underlyingChannel.
- UdpOutbound - Interface in reactor.netty.udp
- 
An outbound-traffic API delegating to an underlyingChannel.
- UdpResources - Class in reactor.netty.udp
- 
Hold the default UDP resources.
- UdpResources(LoopResources) - Constructor for class reactor.netty.udp.UdpResources
- UdpServer - Class in reactor.netty.udp
- 
A UdpServer allows building in a safe immutable way a UDP server that is materialized and connecting whenUdpServer.bind()is ultimately called.
- UdpServer() - Constructor for class reactor.netty.udp.UdpServer
- UdpServerConfig - Class in reactor.netty.udp
- 
Encapsulate all necessary configuration for UDP server transport.
- UNKNOWN - Static variable in class reactor.netty.Metrics
- UnvoidHandler - Static variable in interface reactor.netty.NettyPipeline
- 
Deprecated.as of 1.1.0. This will be removed in 2.0.0 as Netty 5 does not supportVoidChannelPromise.
- updateChannelContext(Channel, Observation) - Static method in class reactor.netty.Metrics
- 
Updates theContextViewin the channel attributes with thisObservation.
- updateContext(Context, Object) - Static method in class reactor.netty.Metrics
- updateHost(Supplier<? extends SocketAddress>, String) - Static method in class reactor.netty.transport.AddressUtils
- 
Update the provided address with the new host string.
- updateMap(Map<K, V>, Object, Object) - Static method in class reactor.netty.quic.QuicServerConfig
- updateMap(Map<K, V>, Object, Object) - Static method in class reactor.netty.transport.TransportConfig
- 
Add or remove values to a map in an immutable way by returning a new map instance.
- updatePort(Supplier<? extends SocketAddress>, int) - Static method in class reactor.netty.transport.AddressUtils
- 
Update the provided address with the new port.
- UPGRADE_REJECTED - Enum constant in enum reactor.netty.http.client.HttpClientState
- 
The H2C upgrade was unsuccessful due to the server not issuing with a 101 Switching Protocols response.
- UPGRADE_SUCCESSFUL - Enum constant in enum reactor.netty.http.client.HttpClientState
- 
The H2C upgrade was successful.
- uri() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return the configured request uri.
- uri() - Method in interface reactor.netty.http.HttpInfos
- 
Returns the resolved target address.
- uri() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
- 
Returns the requested URI, (e.g.
- uri() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns the requested URI, (e.g.
- uri(String) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration
- 
Configure URI to use for this request/response.
- uri(URI) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration
- 
Configure URI to use for this request/response.
- uri(Mono<String>) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration
- 
Configure URI to use for this request/response on subscribe.
- URI - Enum constant in enum reactor.netty.channel.ChannelMeters.ChannelMetersTags
- 
URI.
- URI - Enum constant in enum reactor.netty.channel.ChannelMeters.ConnectionsTotalMeterTags
- 
URI.
- URI - Static variable in class reactor.netty.Metrics
- uriTagValue() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Returns the configured function that receives the actual uri and returns the uri tag value that will be used for the metrics withMetrics.URItag.
- uriTagValue() - Method in class reactor.netty.http.server.HttpServerConfig
- 
Returns the configured function that receives the actual uri and returns the uri tag value that will be used for the metrics withMetrics.URItag.
- uriValueFunction() - Method in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
- 
Returns the function that is used for sanitizing the uri.
- USED_DIRECT_MEMORY - Static variable in class reactor.netty.Metrics
- 
The number of bytes reserved by direct buffer allocator.
- USED_HEAP_MEMORY - Static variable in class reactor.netty.Metrics
- 
The number of bytes reserved by heap buffer allocator.
- user() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Returns the user identifier.
- USER_AGENT - Static variable in class reactor.netty.http.client.HttpClient
- userEventTriggered(ChannelHandlerContext, Object) - Method in class reactor.netty.http.server.logging.error.DefaultErrorLogHandler
- username(String) - Method in interface reactor.netty.transport.ProxyProvider.Builder
- 
The proxy username.
V
- validateHeaders - Variable in class reactor.netty.http.HttpDecoderSpec
- validateHeaders() - Method in class reactor.netty.http.HttpDecoderSpec
- 
Return the configuration whether to validate headers when decoding requests.
- validateHeaders(boolean) - Method in class reactor.netty.http.HttpDecoderSpec
- 
Configure 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.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.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() - 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).
- version(WebSocketVersion) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
- 
Sets websocket version to use.
W
- warmup() - Method in class reactor.netty.http.client.HttpClient
- 
Based on the actual configuration, returns aMonothat triggers: an initialization of the event loop group an initialization of the host name resolver loads the necessary native libraries for the transport loads the necessary native libraries for the security if there is such By default, when method is not used, thefirst requestabsorbs the extra time needed to load resources.
- warmup() - Method in class reactor.netty.http.server.HttpServer
- 
Based on the actual configuration, returns aMonothat triggers: an initialization of the event loop groups loads the necessary native libraries for the transport loads the necessary native libraries for the security if there is such By default, when method is not used, thebind operationabsorbs the extra time needed to load resources.
- warmup() - Method in class reactor.netty.quic.QuicServer
- 
Based on the actual configuration, returns aMonothat triggers: an initialization of the event loop group loads the necessary native libraries for the transport By default, when method is not used, thebind operationabsorbs the extra time needed to load resources.
- warmup() - Method in class reactor.netty.tcp.TcpClient
- 
Based on the actual configuration, returns aMonothat triggers: an initialization of the event loop group an initialization of the host name resolver loads the necessary native libraries for the transport loads the necessary native libraries for the security if there is such By default, when method is not used, theconnect operationabsorbs the extra time needed to load resources.
- warmup() - Method in class reactor.netty.tcp.TcpServer
- 
Based on the actual configuration, returns aMonothat triggers: an initialization of the event loop groups loads the necessary native libraries for the transport loads the necessary native libraries for the security if there is such By default, when method is not used, thebind operationabsorbs the extra time needed to load resources.
- warmup() - Method in class reactor.netty.transport.ClientTransport
- 
Based on the actual configuration, returns aMonothat triggers: an initialization of the event loop group an initialization of the host name resolver loads the necessary native libraries for the transport By default, when method is not used, theconnect operationabsorbs the extra time needed to initialize and load the resources.
- warmup() - Method in class reactor.netty.transport.ServerTransport
- 
Based on the actual configuration, returns aMonothat triggers: an initialization of the event loop groups loads the necessary native libraries for the transport By default, when method is not used, thebind operationabsorbs the extra time needed to load resources.
- warmup() - Method in class reactor.netty.udp.UdpServer
- 
Based on the actual configuration, returns aMonothat triggers: an initialization of the event loop group loads the necessary native libraries for the transport By default, when method is not used, thebind operationabsorbs the extra time needed to load resources.
- warn(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
- warn(HttpMessageArgProvider) - Method in interface reactor.netty.http.logging.HttpMessageLogFactory
- 
Generates a log message based on a givenHttpMessageArgProviderfor a log with a levelWARN.
- websocket() - Method in class reactor.netty.http.client.HttpClient
- 
HTTP Websocket to connect theHttpClient.
- websocket(WebsocketClientSpec) - Method in class reactor.netty.http.client.HttpClient
- 
HTTP Websocket to connect theHttpClient.
- websocketClientSpec() - Method in class reactor.netty.http.client.HttpClientConfig
- 
Return the configured websocket client configuration.
- WebsocketClientSpec - Interface in reactor.netty.http.client
- 
Websocket client configuration.
- WebsocketClientSpec.Builder - Class in reactor.netty.http.client
- WebsocketInbound - Interface in reactor.netty.http.websocket
- 
A websocket framed inbound.
- WebsocketOutbound - Interface in reactor.netty.http.websocket
- 
A websocket framed outbound.
- WebsocketServerSpec - Interface in reactor.netty.http.server
- 
Websocket server configuration.
- WebsocketServerSpec.Builder - Class in reactor.netty.http.server
- WebsocketSpec - Interface in reactor.netty.http.websocket
- 
Wrapper for websocket configuration.
- WebsocketSpec.Builder<SPEC extends WebsocketSpec.Builder<SPEC>> - Class in reactor.netty.http.websocket
- WebsocketSpecImpl - Class in reactor.netty.http.websocket
- 
Configurer implementation forWebsocketSpec.
- WebsocketSpecImpl(WebsocketSpec.Builder<?>) - Constructor for class reactor.netty.http.websocket.WebsocketSpecImpl
- windowBits(int) - Method in interface reactor.netty.http.server.compression.DeflateOption.Builder
- 
Sets the deflate window bits.
- windowBits(int) - Method in interface reactor.netty.http.server.compression.GzipOption.Builder
- 
Sets the gzip window bits.
- wiretap(boolean) - Method in class reactor.netty.http.client.HttpClient
- wiretap(boolean) - Method in class reactor.netty.http.server.HttpServer
- wiretap(boolean) - Method in class reactor.netty.tcp.TcpClient
- wiretap(boolean) - Method in class reactor.netty.tcp.TcpServer
- wiretap(boolean) - Method in class reactor.netty.transport.Transport
- 
Apply or remove a wire logger configuration usingTransportcategory (logger),DEBUGlogger level andAdvancedByteBufFormat.HEX_DUMPforByteBufformat, which means both events and content will be logged and the content will be in hex format.
- wiretap(boolean) - Method in class reactor.netty.udp.UdpClient
- wiretap(boolean) - Method in class reactor.netty.udp.UdpServer
- wiretap(String) - Method in class reactor.netty.tcp.TcpClient
- wiretap(String) - Method in class reactor.netty.tcp.TcpServer
- wiretap(String) - Method in class reactor.netty.transport.Transport
- 
Apply a wire logger configuration using the specified category (logger),DEBUGlogger level andAdvancedByteBufFormat.HEX_DUMPforByteBufformat, which means both events and content will be logged and the content will be in hex format.
- wiretap(String) - Method in class reactor.netty.udp.UdpClient
- wiretap(String) - Method in class reactor.netty.udp.UdpServer
- wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpClient
- wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpServer
- wiretap(String, LogLevel) - Method in class reactor.netty.transport.Transport
- 
Apply a wire logger configuration using the specified category (logger), logger level andAdvancedByteBufFormat.HEX_DUMPforByteBufformat, which means both events and content will be logged and the content will be in hex format.
- wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpClient
- wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpServer
- wiretap(String, LogLevel, AdvancedByteBufFormat) - Method in class reactor.netty.transport.Transport
- 
Apply a wire logger configuration using the specified category (logger), logger level andByteBufformat.
- wiretap(String, LogLevel, AdvancedByteBufFormat, Charset) - Method in class reactor.netty.transport.Transport
- 
Apply a wire logger configuration using the specific category (logger), logger level,ByteBufformat and charset.
- withConnection(Consumer<? super Connection>) - Method in class reactor.netty.channel.ChannelOperations
- withConnection(Consumer<? super Connection>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
- withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerRequest
- withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.http.server.HttpServerResponse
- withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyInbound
- 
Calls the passed callback with aConnectionto operate on the underlyingChannelstate.
- withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyOutbound
- 
Call the passed callback with aConnectionto operate on the underlyingChannelstate.
- withForwardedPrefix(String) - Method in class reactor.netty.http.server.ConnectionInfo
- 
Return a newConnectionInfowith the forwardedPrefix set.
- withHostAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo
- 
Return a newConnectionInfowith the updated host address.
- withHostAddress(InetSocketAddress, String, int) - Method in class reactor.netty.http.server.ConnectionInfo
- 
Return a newConnectionInfowith updated host address, host name, and host port information.
- withRemoteAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo
- 
Return a newConnectionInfowith the updated remote address.
- withScheme(String) - Method in class reactor.netty.http.server.ConnectionInfo
- 
Return a newConnectionInfowith the updated scheme.
- wrapException(Throwable) - Static method in class reactor.netty.ReactorNetty
- 
Wrap possibly fatal or singleton exception into a new exception instance in order to propagate in reactor flows without side effect.
- wrapInboundError(Throwable) - Method in class reactor.netty.channel.ChannelOperations
- 
Wrap an inbound error.
- write(ChannelHandlerContext, Object, ChannelPromise) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
- writeableType() - Method in class reactor.netty.contextpropagation.ChannelContextAccessor
- writeValues(Map<Object, Object>, Channel) - Method in class reactor.netty.contextpropagation.ChannelContextAccessor
- ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
- 
Listens for websocket on the passed path to be used as a routing condition.
- ws(String, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerRoutes
- 
Listens for websocket on the passed path to be used as a routing condition.
- ws(Predicate<? super HttpServerRequest>, BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerRoutes
- 
Listens for websocket with the given route predicate to invoke the matching handler.
- WsCompressionHandler - Static variable in interface reactor.netty.NettyPipeline
- WsFrameAggregator - Static variable in interface reactor.netty.NettyPipeline
Z
- ZONE_ID_SYSTEM - Static variable in class reactor.netty.ReactorNetty
- 
Specifies the zone id used by the access log.
- zonedDateTime() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
- 
Deprecated.as of 1.0.6. Prefer usingAccessLogArgProvider.accessDateTime()This method will be removed in version 1.2.0.
- ZstdOption - Class in reactor.netty.http.server.compression
- 
ZSTD compression option configuration.
- ZstdOption.Builder - Interface in reactor.netty.http.server.compression
_
- _dispose() - Method in class reactor.netty.quic.QuicResources
- 
Dispose underlying resources.
- _dispose() - Method in class reactor.netty.tcp.TcpResources
- 
Dispose underlying resources.
- _dispose() - Method in class reactor.netty.udp.UdpResources
- 
Dispose underlying resources.
- _disposeLater(Duration, Duration) - Method in class reactor.netty.quic.QuicResources
- 
Dispose underlying resources in a listenable fashion.
- _disposeLater(Duration, Duration) - Method in class reactor.netty.tcp.TcpResources
- 
Dispose underlying resources in a listenable fashion.
- _disposeLater(Duration, Duration) - Method in class reactor.netty.udp.UdpResources
- 
Dispose underlying resources in a listenable fashion.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
variantwith theAccessLogFactoryinterface instead. This method will be removed in version 1.2.0.