Skip navigation links
reactor-netty
A B C D E F G H I K L M N O P Q R S T U V W Z _ 

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
Base ChannelHandler for 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
 
accept(Throwable) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
ACCESS_LOG_ENABLED - Static variable in class reactor.netty.ReactorNetty
Specifies whether the Http Server access log will be enabled.
accessDateTime() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the date-time of the moment when the request was received.
accessLog(boolean) - Method in class reactor.netty.http.server.HttpServer
Enable or disable the access log.
accessLog(boolean, AccessLogFactory) - Method in class reactor.netty.http.server.HttpServer
Enable or disable the access log and customize it through an AccessLogFactory.
accessLog(Function<AccessLogArgProvider, AccessLog>) - Method in class reactor.netty.http.server.HttpServer
Deprecated.
as of 1.0.3. Prefer the variant with the AccessLogFactory interface instead. This method will be removed in version 1.2.0.
AccessLog - Class in reactor.netty.http.server.logging
Log the http access information into a Logger named reactor.netty.http.server.AccessLog at INFO level.
AccessLogArgProvider - Interface in reactor.netty.http.server.logging
A provider of the args required for access log.
AccessLogFactory - Interface in reactor.netty.http.server.logging
An interface to declare more concisely a Function that apply an AccessLog by an AccessLogArgProvider.
AccessLogHandler - Static variable in interface reactor.netty.NettyPipeline
 
AccessLogHandlerFactory - Enum in reactor.netty.http.server.logging
Use to create an access-log handler.
acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in interface reactor.netty.resources.ConnectionProvider
Return an existing or new Connection on subscribe.
acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
 
acquire(TransportConfig, ConnectionObserver, Supplier<? extends SocketAddress>, AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpResources
 
acquireCount() - Method in interface reactor.netty.resources.ConnectionProvider.ConnectionMetadata
Returns the number of times the connection has been acquired from the pool.
ACQUIRED - Static variable in interface reactor.netty.ConnectionObserver.State
Propagated when a connection has been reused / acquired (keep-alive or pooling)
acquiredSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Measure the current number of resources that have been successfully acquired and are in active use.
ACTIVE_CONNECTIONS - Static variable in class reactor.netty.Metrics
The number of the connections that have been successfully acquired and are in active use.
ACTIVE_DIRECT_MEMORY - Static variable in class reactor.netty.Metrics
The actual bytes consumed by in-use buffers allocated from direct buffer pools.
ACTIVE_HEAP_MEMORY - Static variable in class reactor.netty.Metrics
The actual bytes consumed by in-use buffers allocated from heap buffer pools.
ACTIVE_STREAMS - Static variable in class reactor.netty.Metrics
The number of the active HTTP/2 streams.
addCookie(Cookie) - Method in interface reactor.netty.http.client.HttpClientRequest
Add an outbound cookie.
addCookie(Cookie) - Method in interface reactor.netty.http.server.HttpServerResponse
Adds an outbound cookie.
addHandler(ChannelHandler) - Method in interface reactor.netty.Connection
Deprecated.
as of 1.0.17. Use Connection.addHandlerFirst(ChannelHandler) or Connection.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. Use Connection.addHandlerFirst(String, ChannelHandler) or Connection.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 new SslProvider with a prepending handler configurator callback to inject default settings to an existing provider configuration.
addHandlerFirst(ChannelHandler) - Method in interface reactor.netty.Connection
Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.
addHandlerFirst(String, ChannelHandler) - Method in interface reactor.netty.Connection
Add a ChannelHandler to the beginning of the "user" ChannelPipeline, that is just after the reactor-added codecs.
addHandlerLast(ChannelHandler) - Method in interface reactor.netty.Connection
Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers like NettyPipeline.ReactiveBridge.
addHandlerLast(String, ChannelHandler) - Method in interface reactor.netty.Connection
Add a ChannelHandler to the end of the "user" ChannelPipeline, that is just before the reactor-added handlers like NettyPipeline.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
Add NettyPipeline.ChannelMetricsHandler to 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
Add NettyPipeline.ReactiveBridge handler at the end of Channel pipeline.
address() - Method in interface reactor.netty.DisposableChannel
When on the server, returns the bind address, when on the client, returns the remote address.
address() - Method in interface reactor.netty.DisposableServer
 
address(InetSocketAddress) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
The address to connect to.
address(Supplier<? extends InetSocketAddress>) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
The supplier for the address to connect to.
ADDRESS_RESOLVER - Static variable in class reactor.netty.Metrics
Time spent for resolving the address.
addressSupplier(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
Deprecated.
Use TcpClient.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's NetUtil.createByteArrayFromIpAddressString(java.lang.String) utility method and the InetSocketAddress instances will be created in a way that these instances are resolved initially.
addSniMapping(String, Consumer<? super SslProvider.SslContextSpec>) - Method in interface reactor.netty.tcp.SslProvider.Builder
Adds a mapping for the given domain name to an SslProvider builder.
addSniMappings(Map<String, Consumer<? super SslProvider.SslContextSpec>>) - Method in interface reactor.netty.tcp.SslProvider.Builder
Adds the provided mappings of domain names to SslProvider builders to the existing mappings.
addSslHandler(Channel, SocketAddress, boolean) - Method in class reactor.netty.tcp.SslProvider
 
AdvancedByteBufFormat - Enum in reactor.netty.transport.logging
Used to control the format and verbosity of logging for ByteBufs and ByteBufHolders.
afterInboundComplete() - Method in class reactor.netty.channel.ChannelOperations
React after inbound completion (last packet).
afterMarkSentHeaders() - Method in class reactor.netty.http.HttpOperations
 
aggregate() - Method in class reactor.netty.ByteBufFlux
Aggregate subsequent byte buffers into a single buffer.
aggregateFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound
Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.
aggregateFrames(int) - Method in interface reactor.netty.http.websocket.WebsocketInbound
Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.
allCookieHeaders() - Method in class reactor.netty.http.Cookies
 
allCookies() - Method in interface reactor.netty.http.server.HttpServerInfos
Returns resolved HTTP cookies.
alloc() - Method in class reactor.netty.channel.ChannelOperations
 
alloc() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
alloc() - Method in interface reactor.netty.NettyOutbound
Returns the assigned ByteBufAllocator.
allocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Measure the current number of allocated resources in the pool, acquired or idle.
allocationStrategy(ConnectionProvider.AllocationStrategy<?>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Limits in how many connections can be allocated and managed by the pool are driven by the provided ConnectionProvider.AllocationStrategy.
allocationStrategy() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
 
allocationTimestamp() - Method in interface reactor.netty.resources.ConnectionProvider.ConnectionMetadata
Returns a timestamp that denotes the order in which the connection was created/allocated, to millisecond precision.
allowDuplicateContentLengths - Variable in class reactor.netty.http.HttpDecoderSpec
 
allowDuplicateContentLengths(boolean) - Method in class reactor.netty.http.HttpDecoderSpec
Configure whether to allow duplicate Content-Length headers.
allowDuplicateContentLengths() - Method in class reactor.netty.http.HttpDecoderSpec
Return the configuration whether to allow duplicate Content-Length headers.
as(Class<T>) - Method in class reactor.netty.channel.ChannelOperations
 
as(Class<T>) - Method in interface reactor.netty.Connection
Return an existing Connection that must match the given type wrapper or null.
asByteArray() - Method in class reactor.netty.ByteBufFlux
Convert to a byte[] inbound Flux.
asByteArray() - Method in class reactor.netty.ByteBufMono
a byte[] inbound Mono.
asByteBuffer() - Method in class reactor.netty.ByteBufFlux
Convert to a ByteBuffer inbound Flux.
asByteBuffer() - Method in class reactor.netty.ByteBufMono
a ByteBuffer inbound Mono.
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 an InputStream inbound Flux
asInputStream() - Method in class reactor.netty.ByteBufMono
Convert to an InputStream inbound Mono
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
Convert to a String inbound Flux using the default Charset.
asString(Charset) - Method in class reactor.netty.ByteBufFlux
Convert to a String inbound Flux using the provided Charset.
asString() - Method in class reactor.netty.ByteBufMono
a String inbound Mono.
asString(Charset) - Method in class reactor.netty.ByteBufMono
a String inbound Mono.
attr(String, String) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP Form attribute.
attr(AttributeKey<A>, A) - Method in class reactor.netty.tcp.TcpClient
 
attr(AttributeKey<A>, A) - Method in class reactor.netty.transport.Transport
Update the given attribute key or remove it if the value is null.
attr(AttributeKey<A>, A) - Method in class reactor.netty.udp.UdpClient
 
attr(AttributeKey<A>, A) - Method in class reactor.netty.udp.UdpServer
 
attributes() - Method in class reactor.netty.transport.TransportConfig
Return the read-only default channel attributes.

B

baseDirectory() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
Returns the configured directory where to store disk Attribute/FileUpload.
baseDirectory(Path) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
Sets the directory where to store disk Attribute/FileUpload.
baseUrl(String) - Method in class reactor.netty.http.client.HttpClient
Configure URI to use for this request/response.
baseUrl() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured base URL to use for this request/response or null.
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 the Connection to the channel scope via an attribute.
bind() - Method in class reactor.netty.incubator.quic.QuicServer
Binds the QuicServer and returns a Mono of Connection.
bind() - Method in class reactor.netty.transport.ServerTransport
Binds the ServerTransport and returns a Mono of DisposableServer.
bind(TransportConfig, ChannelInitializer<Channel>, SocketAddress, boolean) - Static method in class reactor.netty.transport.TransportConnector
Binds a Channel.
bind() - Method in class reactor.netty.udp.UdpServer
Binds the UdpServer and returns a Mono of Connection.
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() - Method in class reactor.netty.transport.TransportConfig
Return the local SocketAddress supplier that will be bound or null.
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.incubator.quic.QuicServer
Starts the server in a blocking fashion, and waits for it to finish initializing or the startup timeout expires (the startup timeout is 45 seconds).
bindNow(Duration) - Method in class reactor.netty.incubator.quic.QuicServer
Start the server in a blocking fashion, and wait for it to finish initializing or the provided startup timeout expires.
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 is 45 seconds).
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() - 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 is 45 seconds).
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.
bootstrap(Function<? super Bootstrap, ? extends Bootstrap>) - Method in class reactor.netty.tcp.TcpClient
Deprecated.
as of 0.9.10. Use the other methods exposed by TcpClient to 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() - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
build() - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Build a new Http2SettingsSpec.
build() - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
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() - Method in interface reactor.netty.transport.ProxyProvider.Builder
Builds new ProxyProvider.
builder() - Static method in class reactor.netty.http.client.Http2AllocationStrategy
Creates a builder for Http2AllocationStrategy.
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 for Http2SettingsSpec.
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() - Constructor for class reactor.netty.http.websocket.WebsocketSpec.Builder
 
builder(String) - Static method in interface reactor.netty.resources.ConnectionProvider
Creates a builder for ConnectionProvider.
builder() - Static method in class reactor.netty.tcp.SslProvider
Creates a builder for SslProvider.
builder() - Static method in class reactor.netty.transport.NameResolverProvider
Creates a builder for NameResolverProvider.
builder() - Static method in class reactor.netty.transport.ProxyProvider
Creates a builder for ProxyProvider.
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
A decorating Flux NettyInbound with various ByteBuf related operations.
ByteBufMono - Class in reactor.netty
A decorating Mono NettyInbound with various ByteBuf related operations.
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.
channel() - Method in class reactor.netty.channel.ChannelOperations
 
channel() - Method in interface reactor.netty.DisposableChannel
Returns the underlying Channel.
channelActive(ChannelHandlerContext) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
ChannelBindException - Exception in reactor.netty
Represents a failing attempt to bind a local socket address.
ChannelBindException(String, int, Throwable) - Constructor for exception reactor.netty.ChannelBindException
 
ChannelBindException(String, Throwable) - Constructor for exception reactor.netty.ChannelBindException
 
ChannelContextAccessor - Class in reactor.netty.contextpropagation
A ContextAccessor to enable reading values from a Netty Channel and writing values to a Netty Channel.
ChannelContextAccessor() - Constructor for class reactor.netty.contextpropagation.ChannelContextAccessor
 
channelGroup(ChannelGroup) - Method in class reactor.netty.http.server.HttpServer
 
channelGroup(ChannelGroup) - Method in class reactor.netty.tcp.TcpServer
 
channelGroup(ChannelGroup) - Method in class reactor.netty.transport.Transport
Provide a ChannelGroup to hold all active connected channels.
channelGroup() - Method in class reactor.netty.transport.TransportConfig
Return the configured ChannelGroup or null.
channelHash() - Method in class reactor.netty.http.client.HttpClientConfig
 
channelHash() - Method in class reactor.netty.tcp.TcpClientConfig
 
channelHash() - Method in class reactor.netty.transport.ClientTransportConfig
 
channelHash() - Method in class reactor.netty.transport.TransportConfig
 
channelInactive(ChannelHandlerContext) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
channelInitializer(ConnectionObserver, SocketAddress, boolean) - Method in class reactor.netty.transport.TransportConfig
Return the ChannelInitializer that 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
ChannelHandler for 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 new ChannelOperations attached to the Channel.
ChannelOperations.OnSetup - Interface in reactor.netty.channel
ChannelOperationsId - Interface in reactor.netty
Provides short/long string representation of the channel.
channelOperationsProvider() - Method in class reactor.netty.http.client.HttpClientConfig
 
channelOperationsProvider() - Method in class reactor.netty.tcp.TcpClientConfig
 
channelOperationsProvider() - Method in class reactor.netty.tcp.TcpServerConfig
 
channelOperationsProvider() - Method in class reactor.netty.transport.TransportConfig
Return the associated ChannelOperations.OnSetup, config implementations might override this.
channelOperationsProvider() - Method in class reactor.netty.udp.UdpClientConfig
 
channelOperationsProvider() - Method in class reactor.netty.udp.UdpServerConfig
 
ChannelPipelineConfigurer - Interface in reactor.netty
Configure the channel pipeline while initializing the channel.
channelRead(ChannelHandlerContext, Object) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
channelRegistered(ChannelHandlerContext) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
channelType(boolean) - Method in class reactor.netty.transport.ClientTransportConfig
 
channelType(boolean) - Method in class reactor.netty.transport.ServerTransportConfig
 
channelType(boolean) - Method in class reactor.netty.transport.TransportConfig
Return the channel type this configuration is associated with, it can be one of the following.
channelType(boolean) - Method in class reactor.netty.udp.UdpClientConfig
 
channelType(boolean) - Method in class reactor.netty.udp.UdpServerConfig
 
charset(Charset) - Method in interface reactor.netty.http.client.HttpClientForm
Set the Form Charset.
charset(Charset) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
charset() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
Returns the configured charset for Attribute/FileUpload.
childAttr(AttributeKey<A>, A) - Method in class reactor.netty.transport.ServerTransport
Injects default attribute to the future child Channel connections.
childAttributes() - Method in class reactor.netty.transport.ServerTransportConfig
Return the read-only default channel attributes for each remote connection.
childObserve(ConnectionObserver) - Method in class reactor.netty.transport.ServerTransport
Set or add the given ConnectionObserver for each remote connection.
childObserver() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured ConnectionObserver if any or ConnectionObserver.emptyListener() for each remote connection.
childOption(ChannelOption<A>, A) - Method in class reactor.netty.transport.ServerTransport
Injects default options to the future child Channel connections.
childOptions() - Method in class reactor.netty.transport.ServerTransportConfig
Return the read-only ChannelOption map for each remote connection.
CHUNK_SIZE - Static variable in class reactor.netty.Metrics
The chunk size for an arena.
chunkedTransfer(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse
Sets Transfer-Encoding header.
ChunkedWriter - Static variable in interface reactor.netty.NettyPipeline
 
cleanOnTerminate(boolean) - Method in interface reactor.netty.http.client.HttpClientForm
Should file attributes be cleaned and eventually removed from disk.
ClientTransport<T extends ClientTransport<T,CONF>,CONF extends ClientTransportConfig<CONF>> - Class in reactor.netty.transport
A generic client Transport that will ClientTransport.connect() to a remote address and provide a Connection.
ClientTransport() - Constructor for class reactor.netty.transport.ClientTransport
 
ClientTransportConfig<CONF extends TransportConfig> - Class in reactor.netty.transport
Encapsulate all necessary configuration for client transport.
ClientTransportConfig(ConnectionProvider, Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.ClientTransportConfig
 
ClientTransportConfig(ClientTransportConfig<CONF>) - Constructor for class reactor.netty.transport.ClientTransportConfig
 
closeNotifyFlushTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
Set the options to use for configuring SSL close_notify flush timeout.
closeNotifyFlushTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
Set the options to use for configuring SSL close_notify flush timeout.
closeNotifyReadTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
Set the options to use for configuring SSL close_notify read timeout.
closeNotifyReadTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
Set the options to use for configuring SSL close_notify read timeout.
colocate(EventLoopGroup) - Static method in interface reactor.netty.resources.LoopResources
Create a delegating EventLoopGroup which reuse local event loop if already working inside one.
common(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
 
common(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
 
comparator(Comparator<HttpRouteHandlerMetadata>) - Method in interface reactor.netty.http.server.HttpServerRoutes
Use the provided Comparator to sort routes, rather than using configured order.Routes that were already configured are also impacted by this change and will be sorted according to the comparator.You can revert to using the declaration order by calling the HttpServerRoutes.noComparator() method (which is the default).
completeOncePreferredResolved(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
If true, the resolver notifies the returned Future as soon as all queries for the preferred address type are complete.
compress(boolean) - Method in class reactor.netty.http.client.HttpClient
Specifies whether GZip compression is enabled.
compress(BiPredicate<HttpServerRequest, HttpServerResponse>) - Method in class reactor.netty.http.server.HttpServer
Enable GZip response compression if the client request presents accept encoding headers and the provided Predicate matches.
compress(boolean) - Method in class reactor.netty.http.server.HttpServer
Specifies whether GZip response compression is enabled if the client request presents accept encoding.
compress(int) - Method in class reactor.netty.http.server.HttpServer
Enable GZip response compression if the client request presents accept encoding headers AND the response reaches a minimum threshold.
compress(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
Sets flag whether the websocket compression extension is enabled if the client request presents websocket extensions headers.
compress() - Method in interface reactor.netty.http.websocket.WebsocketSpec
Returns whether the websocket compression extension is enabled.
compress() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
 
compression(boolean) - Method in interface reactor.netty.http.server.HttpServerResponse
Enables/Disables compression handling (gzip/deflate) for the underlying response.
compressionAllowClientNoContext(boolean) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
Allows the server to activate client_no_context_takeover Default to false.
compressionAllowClientNoContext() - Method in interface reactor.netty.http.client.WebsocketClientSpec
Returns whether the server is allowed to activate client_no_context_takeover.
compressionAllowServerNoContext(boolean) - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
Allows the client to activate server_no_context_takeover.
compressionAllowServerNoContext() - Method in interface reactor.netty.http.server.WebsocketServerSpec
Returns whether the client is allowed to activate server_no_context_takeover.
CompressionHandler - Static variable in interface reactor.netty.NettyPipeline
 
compressionPreferredClientNoContext(boolean) - Method in class reactor.netty.http.server.WebsocketServerSpec.Builder
Indicates if the server prefers to activate client_no_context_takeover if client is compatible with.
compressionPreferredClientNoContext() - Method in interface reactor.netty.http.server.WebsocketServerSpec
Returns whether the server prefers to activate client_no_context_takeover.
compressionRequestedServerNoContext(boolean) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
Indicates if the client needs to activate server_no_context_takeover if the server is compatible with.
compressionRequestedServerNoContext() - Method in interface reactor.netty.http.client.WebsocketClientSpec
Returns whether the client needs to activate server_no_context_takeover.
compressPredicate() - Method in class reactor.netty.http.server.HttpServerConfig
Return the configured compression predicate or null.
computeIfAbsent(Map<K, V>, K, Function<K, V>) - Static method in class reactor.netty.internal.util.MapUtils
This is a temporary workaround for Java 8 specific performance issue https://bugs.openjdk.org/browse/JDK-8161372.
configuration() - Method in class reactor.netty.transport.Transport
Return a TransportConfig.
configure(Consumer<SslContextBuilder>) - Method in class reactor.netty.tcp.AbstractProtocolSslContextSpec
 
configure(SslHandler) - Method in class reactor.netty.tcp.SslProvider
 
configure(Consumer<SslContextBuilder>) - Method in interface reactor.netty.tcp.SslProvider.ProtocolSslContextSpec
Configures the underlying SslContextBuilder.
CONFIGURED - Static variable in interface reactor.netty.ConnectionObserver.State
Propagated when a connection is bound to a channelOperation and ready for user interaction
connect() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
Negotiate a websocket upgrade and return a Mono of Connection.
connect() - Method in class reactor.netty.incubator.quic.QuicClient
Connect the QuicClient and return a Mono of QuicConnection.
connect() - Method in class reactor.netty.tcp.TcpClient
 
connect() - Method in class reactor.netty.transport.ClientTransport
Connect the ClientTransport and return a Mono of Connection.
connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>) - Static method in class reactor.netty.transport.TransportConnector
Connect a Channel to the remote peer.
connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, ContextView) - Static method in class reactor.netty.transport.TransportConnector
Connect a Channel to the remote peer.
connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, EventLoop) - Static method in class reactor.netty.transport.TransportConnector
Connect a Channel to the remote peer.
connect(TransportConfig, SocketAddress, AddressResolverGroup<?>, ChannelInitializer<Channel>, EventLoop, ContextView) - Static method in class reactor.netty.transport.TransportConnector
Connect a Channel to the remote peer.
connect() - Method in class reactor.netty.udp.UdpClient
 
CONNECT_TIME - Static variable in class reactor.netty.Metrics
Time spent for connecting to the remote address.
CONNECTED - Static variable in interface reactor.netty.ConnectionObserver.State
Propagated when a connection has been established and is available
connection() - Method in class reactor.netty.channel.ChannelOperations
Return the delegate IO Connection for low-level IO access.
Connection - Interface in reactor.netty
Hold contextual information for the underlying Channel.
CONNECTION_PROVIDER_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the PooledConnectionProvider's metrics registered in Micrometer's global registry.
connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.transport.TransportConfig
Return the ChannelFactory which is used to create Channel instances.
connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.udp.UdpClientConfig
 
connectionFactory(EventLoopGroup, boolean) - Method in class reactor.netty.udp.UdpServerConfig
 
connectionHostAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
Returns the address of the host which received the request, possibly null in case of Unix Domain Sockets.
connectionIdAddressGenerator(QuicConnectionIdGenerator) - Method in class reactor.netty.incubator.quic.QuicServer
Set the QuicConnectionIdGenerator to use.
connectionIdAddressGenerator() - Method in class reactor.netty.incubator.quic.QuicServerConfig
Return the configured QuicConnectionIdGenerator or the default.
ConnectionInfo - Class in reactor.netty.http.server
Resolve information about the current connection, including the host (server) address, the remote (client) address and the scheme.
ConnectionInformation - Interface in reactor.netty.http.server
Resolve information about the connection from which an http request is received.
connectionInformation() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the information about the current connection.
ConnectionObserver - Interface in reactor.netty
Event listeners for connection lifecycle.
connectionObserver() - Method in class reactor.netty.transport.TransportConfig
ConnectionObserver.State - Interface in reactor.netty
A marker interface for various state signals used in ConnectionObserver.onStateChange(Connection, State)
ConnectionPoolMetrics - Interface in reactor.netty.resources
 
connectionProvider() - Method in class reactor.netty.http.client.HttpClientConfig
 
ConnectionProvider - Interface in reactor.netty.resources
connectionProvider() - Method in class reactor.netty.transport.ClientTransportConfig
Return the ConnectionProvider.
ConnectionProvider.AllocationStrategy<A extends ConnectionProvider.AllocationStrategy<A>> - Interface in reactor.netty.resources
 
ConnectionProvider.Builder - Class in reactor.netty.resources
Build a ConnectionProvider to cache and reuse a fixed maximum number of Connection.
ConnectionProvider.ConnectionMetadata - Interface in reactor.netty.resources
 
ConnectionProvider.ConnectionPoolSpec<SPEC extends ConnectionProvider.ConnectionPoolSpec<SPEC>> - Class in reactor.netty.resources
Configuration for a connection pool.
ConnectionProvider.HostSpecificSpec - Class in reactor.netty.resources
Configuration for a connection pool per remote host.
ConnectionProvider.MeterRegistrar - Interface in reactor.netty.resources
A strategy to register which metrics are collected in a particular connection pool.
connectionRemoteAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
Returns the address of the client that initiated the request, possibly null in case of Unix Domain Sockets.
CONNECTIONS_ACTIVE - Static variable in class reactor.netty.Metrics
The number of connections that are currently in use.
CONNECTIONS_TOTAL - Static variable in class reactor.netty.Metrics
The number of all connections, whether they are active or idle.
connectionScheme() - Method in interface reactor.netty.http.server.ConnectionInformation
Returns the current protocol scheme.
connectMetricsHandler() - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
connectMetricsHandler() - Method in class reactor.netty.channel.ChannelMetricsHandler
 
connectMetricsHandler() - Method in class reactor.netty.channel.MicrometerChannelMetricsHandler
 
ConnectMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
 
connectNow() - Method in class reactor.netty.incubator.quic.QuicClient
Block the QuicClient and return a QuicConnection.
connectNow(Duration) - Method in class reactor.netty.incubator.quic.QuicClient
Block the QuicClient and return a QuicConnection.
connectNow() - Method in class reactor.netty.tcp.TcpClient
 
connectNow(Duration) - Method in class reactor.netty.tcp.TcpClient
 
connectNow() - Method in class reactor.netty.transport.ClientTransport
Block the ClientTransport and return a Connection.
connectNow(Duration) - Method in class reactor.netty.transport.ClientTransport
Block the ClientTransport and return a Connection.
connectNow() - Method in class reactor.netty.udp.UdpClient
 
connectNow(Duration) - Method in class reactor.netty.udp.UdpClient
 
connectTimeoutMillis(long) - Method in interface reactor.netty.transport.ProxyProvider.Builder
The proxy connect timeout in millis.
content() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
Return the data which is held by the HttpMessage.
contentLength() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the response content length.
CONTEXT_CALLER_EVENTLOOP - Static variable in class reactor.netty.resources.PooledConnectionProvider
Context key used to propagate the caller event loop in the connection pool subscription.
ContextAwareChannelMetricsRecorder - Class in reactor.netty.channel
ContextView aware class for recording metrics on protocol level.
ContextAwareChannelMetricsRecorder() - Constructor for class reactor.netty.channel.ContextAwareChannelMetricsRecorder
 
ContextAwareHttpClientMetricsRecorder - Class in reactor.netty.http.client
ContextView aware class for collecting metrics on HTTP client level.
ContextAwareHttpClientMetricsRecorder() - Constructor for class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
 
ContextAwareHttpMetricsRecorder - Class in reactor.netty.http
ContextView aware class for recording metrics for HTTP protocol.
ContextAwareHttpMetricsRecorder() - Constructor for class reactor.netty.http.ContextAwareHttpMetricsRecorder
 
ContextAwareHttpServerMetricsRecorder - Class in reactor.netty.http.server
ContextView aware class for collecting metrics on HTTP server level.
ContextAwareHttpServerMetricsRecorder() - Constructor for class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
 
cookie(Cookie) - Method in class reactor.netty.http.client.HttpClient
Apply cookies configuration.
cookie(String, Consumer<? super Cookie>) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
as of 1.1.0. Use HttpClient.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 - Class in reactor.netty.http
Store cookies for the http channel.
Cookies(HttpHeaders, CharSequence, boolean, CookieDecoder) - Constructor for class reactor.netty.http.Cookies
 
cookies() - Method in interface reactor.netty.http.HttpInfos
Returns resolved HTTP cookies.
cookies() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns resolved HTTP cookies.
cookiesWhen(String, Function<? super Cookie, Mono<? extends Cookie>>) - Method in class reactor.netty.http.client.HttpClient
Apply cookies configuration emitted by the returned Mono before requesting.
copy() - Method in class reactor.netty.http.client.Http2AllocationStrategy
 
copy() - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
Returns a deep copy of this instance.
create(Connection, ConnectionObserver, Object) - Method in interface reactor.netty.channel.ChannelOperations.OnSetup
Create a new ChannelOperations given a netty channel, a parent ConnectionObserver and an optional message (nullable).
create() - Static method in class reactor.netty.http.client.HttpClient
Prepare a pooled HttpClient.
create(ConnectionProvider) - Static method in class reactor.netty.http.client.HttpClient
Prepare an HttpClient.
create(Object) - Static method in class reactor.netty.http.logging.HttpMessageArgProviderFactory
Creates HttpContentArgProvider based on the provided HTTP object.
create() - Static method in class reactor.netty.http.server.HttpServer
Prepare an HttpServer.
create(String, Object...) - Static method in class reactor.netty.http.server.logging.AccessLog
 
create(Function<AccessLogArgProvider, AccessLog>) - Method in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
Create an access log handler, AccessLogHandlerH1 or AccessLogHandlerH2.
create() - Static method in class reactor.netty.incubator.quic.QuicClient
Prepare a QuicClient.
create() - Static method in class reactor.netty.incubator.quic.QuicServer
Prepare a QuicServer.
create(String) - Static method in interface reactor.netty.resources.ConnectionProvider
Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
create(String, int) - Static method in interface reactor.netty.resources.ConnectionProvider
Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
create(String, int, boolean) - Static method in interface reactor.netty.resources.ConnectionProvider
Create a new ConnectionProvider to cache and reuse a fixed maximum number of Connection.
create(String) - Static method in interface reactor.netty.resources.LoopResources
Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories.
create(String, int, boolean) - Static method in interface reactor.netty.resources.LoopResources
Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories.
create(String, int, int, boolean) - Static method in interface reactor.netty.resources.LoopResources
Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories.
create(String, int, int, boolean, boolean) - Static method in interface reactor.netty.resources.LoopResources
Create a simple LoopResources to provide automatically for EventLoopGroup and Channel factories.
create() - Static method in class reactor.netty.tcp.TcpClient
Prepare a pooled TcpClient.
create(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpClient
Prepare a TcpClient.
create() - Static method in class reactor.netty.tcp.TcpServer
Prepare a TcpServer.
create() - Static method in class reactor.netty.udp.UdpClient
Prepare a UdpClient.
create() - Static method in class reactor.netty.udp.UdpServer
Prepare a UdpServer.
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.
createInetSocketAddress(String, int, boolean) - Static method in class reactor.netty.transport.AddressUtils
Creates InetSocketAddress instance.
createPool(TransportConfig, PooledConnectionProvider.PoolFactory<T>, SocketAddress, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
 
createPool(String, TransportConfig, PooledConnectionProvider.PoolFactory<T>, SocketAddress, AddressResolverGroup<?>) - Method in class reactor.netty.resources.PooledConnectionProvider
 
createResolved(String, int) - Static method in class reactor.netty.transport.AddressUtils
Creates InetSocketAddress that is always resolved.
createStream(BiFunction<? super QuicInbound, ? super QuicOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.incubator.quic.QuicConnection
Creates a bidirectional stream.
createStream(QuicStreamType, BiFunction<? super QuicInbound, ? super QuicOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.incubator.quic.QuicConnection
Creates a stream.
createUnresolved(String, int) - Static method in class reactor.netty.transport.AddressUtils
Creates unresolved InetSocketAddress.
currentContext() - Method in class reactor.netty.channel.ChannelOperations
 
currentContext() - Method in interface reactor.netty.ConnectionObserver
Connection listener Context.
currentContext() - Method in interface reactor.netty.http.client.HttpClientInfos
Deprecated.
Use HttpClientInfos.currentContextView(). This method will be removed in version 1.1.0.
currentContextView() - Method in interface reactor.netty.http.client.HttpClientInfos
Return the current ContextView associated with the Mono/Flux exposed via HttpClient.ResponseReceiver.response() or related terminating API.
currentObservation(ContextView) - Static method in class reactor.netty.Metrics
 

D

daemon() - Method in class reactor.netty.incubator.quic.QuicResources
 
daemon() - Method in interface reactor.netty.resources.LoopResources
return true if EventLoopGroup should not be shutdown.
daemon() - Method in class reactor.netty.tcp.TcpResources
 
daemon() - Method in class reactor.netty.udp.UdpResources
 
DATA_RECEIVED - Static variable in class reactor.netty.Metrics
Amount of the data received, in bytes.
DATA_RECEIVED_TIME - Static variable in class reactor.netty.Metrics
Time spent in consuming incoming data.
DATA_SENT - Static variable in class reactor.netty.Metrics
Amount of the data sent, in bytes.
DATA_SENT_TIME - Static variable in class reactor.netty.Metrics
Time spent in sending outgoing data.
dataReceivedTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
dataSentTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
debug(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
 
debug(HttpMessageArgProvider) - Method in interface reactor.netty.http.logging.HttpMessageLogFactory
Generates a log message based on a given HttpMessageArgProvider for a log with a level DEBUG.
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 the HttpMessage.
decoderResultFunction() - Method in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
Returns the function that is used for sanitizing the decoding result.
DEFAULT_ALLOW_DUPLICATE_CONTENT_LENGTHS - Static variable in class reactor.netty.http.HttpDecoderSpec
 
DEFAULT_FAIL_ON_MISSING_RESPONSE - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
 
DEFAULT_H2C_MAX_CONTENT_LENGTH - Static variable in class reactor.netty.http.client.HttpResponseDecoderSpec
The maximum length of the content of the HTTP/2.0 clear-text upgrade request.
DEFAULT_H2C_MAX_CONTENT_LENGTH - Static variable in class reactor.netty.http.server.HttpRequestDecoderSpec
The maximum length of the content of the HTTP/2.0 clear-text upgrade request.
DEFAULT_INITIAL_BUFFER_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
 
DEFAULT_IO_SELECT_COUNT - Static variable in interface reactor.netty.resources.LoopResources
Default selector thread count, fallback to -1 (no selector thread).
DEFAULT_IO_WORKER_COUNT - Static variable in interface reactor.netty.resources.LoopResources
Default worker thread count, fallback to available processor (but with a minimum value of 4).
DEFAULT_MAX_CHUNK_SIZE - Static variable in class reactor.netty.http.HttpDecoderSpec
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, 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 global AddressResolverGroup from HttpResources that is shared amongst all HTTP clients.
defaultAddressResolverGroup() - Method in class reactor.netty.tcp.TcpClientConfig
Provides a global AddressResolverGroup from TcpResources that is shared amongst all TCP clients.
defaultAddressResolverGroup() - Method in class reactor.netty.transport.ClientTransportConfig
Provides a global AddressResolverGroup that is shared amongst all clients.
defaultAddressResolverGroup() - Method in class reactor.netty.udp.UdpClientConfig
Provides a global AddressResolverGroup from UdpResources that is shared amongst all UDP clients.
defaultChildObserver() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured child lifecycle ConnectionObserver if any or ConnectionObserver.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(SslProvider.DefaultConfigurationType) - Method in interface reactor.netty.tcp.SslProvider.DefaultConfigurationSpec
Deprecated.
Default configuration type that will be applied to the provided SslContextBuilder.
defaultConfiguration() - Method in class reactor.netty.tcp.TcpSslContextSpec
 
defaultConnectionObserver() - Method in class reactor.netty.http.client.HttpClientConfig
 
defaultConnectionObserver() - Method in class reactor.netty.incubator.quic.QuicClientConfig
 
defaultConnectionObserver() - Method in class reactor.netty.incubator.quic.QuicServerConfig
 
defaultConnectionObserver() - Method in class reactor.netty.transport.ClientTransportConfig
 
defaultConnectionObserver() - Method in class reactor.netty.transport.ServerTransportConfig
 
defaultConnectionObserver() - Method in class reactor.netty.transport.TransportConfig
Return the configured default ConnectionObserver.
defaultConnectionObserver() - Method in class reactor.netty.udp.UdpServerConfig
 
defaultLoggingHandler() - Method in class reactor.netty.http.client.HttpClientConfig
 
defaultLoggingHandler() - Method in class reactor.netty.http.server.HttpServerConfig
 
defaultLoggingHandler() - Method in class reactor.netty.incubator.quic.QuicClientConfig
 
defaultLoggingHandler() - Method in class reactor.netty.incubator.quic.QuicServerConfig
 
defaultLoggingHandler() - Method in class reactor.netty.tcp.TcpClientConfig
 
defaultLoggingHandler() - Method in class reactor.netty.tcp.TcpServerConfig
 
defaultLoggingHandler() - Method in class reactor.netty.transport.TransportConfig
Return the default LoggingHandler to 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.tcp.TcpClientConfig
 
defaultLoopResources() - Method in class reactor.netty.tcp.TcpServerConfig
 
defaultLoopResources() - Method in class reactor.netty.transport.TransportConfig
Return the default LoopResources for 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.incubator.quic.QuicClientConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.incubator.quic.QuicServerConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.tcp.TcpClientConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.tcp.TcpServerConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.transport.TransportConfig
Return the configured metrics recorder.
defaultMetricsRecorder() - Method in class reactor.netty.udp.UdpClientConfig
 
defaultMetricsRecorder() - Method in class reactor.netty.udp.UdpServerConfig
 
defaultOnChannelInit() - Method in class reactor.netty.http.client.HttpClientConfig
 
defaultOnChannelInit() - Method in class reactor.netty.http.server.HttpServerConfig
 
defaultOnChannelInit() - Method in class reactor.netty.tcp.TcpClientConfig
 
defaultOnChannelInit() - Method in class reactor.netty.tcp.TcpServerConfig
 
defaultOnChannelInit() - Method in class reactor.netty.transport.ClientTransportConfig
 
defaultOnChannelInit() - Method in class reactor.netty.transport.ServerTransportConfig
 
defaultOnChannelInit() - Method in class reactor.netty.transport.TransportConfig
Return the default callback if any or ChannelPipelineConfigurer.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
Convert a supplied Future for each subscriber into Mono.
delete() - Method in class reactor.netty.http.client.HttpClient
HTTP DELETE to connect the HttpClient.
delete(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
Listens for HTTP DELETE on the passed path to be used as a routing condition.
deRegisterDefaultMetrics(String, SocketAddress) - Method in class reactor.netty.resources.PooledConnectionProvider
 
deRegisterMetrics(String, String, SocketAddress) - Method in interface reactor.netty.resources.ConnectionProvider.MeterRegistrar
Invoked when a connection pool is disposed.
DIRECT_ARENAS - Static variable in class reactor.netty.Metrics
The number of direct arenas.
directory(String, Path) - Method in interface reactor.netty.http.server.HttpServerRoutes
Listens for HTTP GET on the passed path to be used as a routing condition.
directory(String, Path, Function<HttpServerResponse, HttpServerResponse>) - Method in interface reactor.netty.http.server.HttpServerRoutes
Listens for HTTP GET on the passed path to be used as a routing condition.The content of the provided directory will be served.
disableOptionalRecord(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Disables the automatic inclusion of an optional record that tries to hint the remote DNS server about how much data the resolver can read per response.
disableRecursionDesired(boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Specifies whether this resolver has to send a DNS query with the recursion desired (RD) flag set.
disableRetry(boolean) - Method in class reactor.netty.http.client.HttpClient
Option to disable retry once support for the outgoing requests that fail with AbortedException.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 underlying Channel.
dispose() - Method in class reactor.netty.incubator.quic.QuicResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global QUIC resources which has a longer lifecycle than regular LoopResources.
dispose() - Method in interface reactor.netty.resources.ConnectionProvider
Dispose this ConnectionProvider.
dispose() - Method in interface reactor.netty.resources.LoopResources
Dispose the underlying LoopResources.
dispose() - Method in class reactor.netty.tcp.TcpResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global TCP resources which has a longer lifecycle than regular LoopResources and ConnectionProvider.
dispose() - Method in class reactor.netty.udp.UdpResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global UDP resources which has a longer lifecycle than regular LoopResources.
disposeInactivePoolsInBackground(Duration, Duration) - Method in class reactor.netty.resources.ConnectionProvider.Builder
Set the options to use for configuring ConnectionProvider background disposal for inactive connection pools.
disposeLater() - Method in class reactor.netty.incubator.quic.QuicResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global QUIC resources which has a longer lifecycle than regular LoopResources.
disposeLater(Duration, Duration) - Method in class reactor.netty.incubator.quic.QuicResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global QUIC resources which has a longer lifecycle than regular LoopResources.
disposeLater() - Method in interface reactor.netty.resources.ConnectionProvider
Returns a Mono that triggers the disposal of the ConnectionProvider when subscribed to.
disposeLater() - Method in interface reactor.netty.resources.LoopResources
Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
disposeLater(Duration, Duration) - Method in interface reactor.netty.resources.LoopResources
Returns a Mono that triggers the disposal of the underlying LoopResources when subscribed to.
disposeLater() - Method in class reactor.netty.resources.PooledConnectionProvider
 
disposeLater() - Method in class reactor.netty.tcp.TcpResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global TCP resources which has a longer lifecycle than regular LoopResources and ConnectionProvider.
disposeLater(Duration, Duration) - Method in class reactor.netty.tcp.TcpResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global TCP resources which has a longer lifecycle than regular LoopResources and ConnectionProvider.
disposeLater() - Method in class reactor.netty.udp.UdpResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global UDP resources which has a longer lifecycle than regular LoopResources.
disposeLater(Duration, Duration) - Method in class reactor.netty.udp.UdpResources
This has a NOOP implementation by default in order to prevent unintended disposal of the global UDP resources which has a longer lifecycle than regular LoopResources.
disposeLoops() - Static method in class reactor.netty.incubator.quic.QuicResources
Shutdown the global QuicResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnections() - Static method in class reactor.netty.http.HttpResources
Shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnections() - Static method in class reactor.netty.tcp.TcpResources
Shutdown the global TcpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.http.HttpResources
Prepare to shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnectionsLater(Duration, Duration) - Static method in class reactor.netty.http.HttpResources
Prepare to shutdown the global HttpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnectionsLater() - Static method in class reactor.netty.tcp.TcpResources
Prepare to shutdown the global TcpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsAndConnectionsLater(Duration, Duration) - Static method in class reactor.netty.tcp.TcpResources
Prepare to shutdown the global TcpResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsLater() - Static method in class reactor.netty.incubator.quic.QuicResources
Prepare to shut down the global QuicResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeLoopsLater(Duration, Duration) - Static method in class reactor.netty.incubator.quic.QuicResources
Prepare to shut down the global QuicResources without resetting them, effectively cleaning up associated resources without creating new ones.
disposeNow() - Method in interface reactor.netty.DisposableChannel
Releases or closes the underlying Channel in a blocking fashion with 3 seconds default timeout.
disposeNow(Duration) - Method in interface reactor.netty.DisposableChannel
Releases or closes the underlying Channel in a blocking fashion with the provided timeout.
disposeSubscriber() - Method in class reactor.netty.channel.ChannelOperations
 
disposeSubscriber() - Method in interface reactor.netty.DisposableChannel
Returns a CoreSubscriber that will dispose on complete or error.
disposeTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.Builder
When ConnectionProvider.dispose() or ConnectionProvider.disposeLater() is called, trigger a graceful shutdown for 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 of DnsAddressResolverGroup or null.
dnsAddressResolverGroupProvider(Function<DnsNameResolverBuilder, DnsAddressResolverGroup>) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Sets the custom function to build the DnsAddressResolverGroup given a DnsNameResolverBuilder.
doAfterRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called when HttpClientRequest has been sent and HttpClientState.REQUEST_SENT has been emitted.
doAfterResolve(BiConsumer<? super Connection, ? super SocketAddress>) - Method in class reactor.netty.transport.ClientTransport
Set or add a callback called after SocketAddress is resolved successfully.
doAfterResponseSuccess(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called after HttpClientResponse has been fully received and HttpClientState.RESPONSE_COMPLETED has been emitted.
doOnBind(Consumer<? super TcpServerConfig>) - Method in class reactor.netty.tcp.TcpServer
 
doOnBind(Consumer<? super CONF>) - Method in class reactor.netty.transport.ServerTransport
Set or add a callback called when ServerTransport is about to start listening for incoming traffic.
doOnBind() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured callback or null.
doOnBind(Consumer<? super UdpServerConfig>) - Method in class reactor.netty.udp.UdpServer
Set or add a callback called when UdpServer is about to start listening for incoming traffic.
doOnBind() - Method in class reactor.netty.udp.UdpServerConfig
Return the configured callback or null.
doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.tcp.TcpServer
 
doOnBound(Consumer<? super DisposableServer>) - Method in class reactor.netty.transport.ServerTransport
Set or add a callback called after DisposableServer has been started.
doOnBound() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured callback or null.
doOnBound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
Set or add a callback called after UdpServer has been started.
doOnBound() - Method in class reactor.netty.udp.UdpServerConfig
Return the configured callback or null.
doOnChannelInit(ChannelPipelineConfigurer) - Method in class reactor.netty.transport.Transport
Configure the channel pipeline while initializing the channel.
doOnChannelInit() - Method in class reactor.netty.transport.TransportConfig
Return the configured callback if any or ChannelPipelineConfigurer.emptyConfigurer().
doOnConnect(Consumer<? super QuicClientConfig>) - Method in class reactor.netty.incubator.quic.QuicClient
Set or add a callback called when QuicClient is about to connect to the remote endpoint.
doOnConnect() - Method in class reactor.netty.incubator.quic.QuicClientConfig
Return the configured callback or null.
doOnConnect(Consumer<? super TcpClientConfig>) - Method in class reactor.netty.tcp.TcpClient
 
doOnConnect(Consumer<? super CONF>) - Method in class reactor.netty.transport.ClientTransport
Set or add a callback called when ClientTransport is about to connect to the remote endpoint.
doOnConnect() - Method in class reactor.netty.transport.ClientTransportConfig
Return the configured callback or null.
doOnConnect(Consumer<? super UdpClientConfig>) - Method in class reactor.netty.udp.UdpClient
 
doOnConnected(Consumer<? super QuicConnection>) - Method in class reactor.netty.incubator.quic.QuicClient
Set or add a callback called after QuicConnection has been connected.
doOnConnected() - Method in class reactor.netty.incubator.quic.QuicClientConfig
Return the configured callback or null.
doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
 
doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
Set or add a callback called after Connection has been connected.
doOnConnected() - Method in class reactor.netty.transport.ClientTransportConfig
Return the configured callback or null.
doOnConnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
 
doOnConnection(Consumer<? super QuicConnection>) - Method in class reactor.netty.incubator.quic.QuicServer
Set or add a callback called on new remote QuicConnection.
doOnConnection() - Method in class reactor.netty.incubator.quic.QuicServerConfig
Return the configured callback or null.
doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpServer
 
doOnConnection(Consumer<? super Connection>) - Method in class reactor.netty.transport.ServerTransport
Set or add a callback called on new remote Connection.
doOnConnection() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured callback or null.
doOnDisconnected(Consumer<? super QuicConnection>) - Method in class reactor.netty.incubator.quic.QuicClient
Set or add a callback called after QuicConnection has been disconnected.
doOnDisconnected() - Method in class reactor.netty.incubator.quic.QuicClientConfig
Return the configured callback or null.
doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.tcp.TcpClient
 
doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
Set or add a callback called after Connection has been disconnected.
doOnDisconnected() - Method in class reactor.netty.transport.ClientTransportConfig
Return the configured callback or null.
doOnDisconnected(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpClient
 
doOnError(BiConsumer<? super HttpClientRequest, ? super Throwable>, BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called when HttpClientRequest has not been sent and when HttpClientResponse has not been fully received.
doOnRedirect(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called after HttpClientResponse headers have been received and the request is about to be redirected.
doOnRequest(BiConsumer<? super HttpClientRequest, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called when HttpClientRequest is about to be sent and HttpClientState.REQUEST_PREPARED has been emitted.
doOnRequestError(BiConsumer<? super HttpClientRequest, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called when HttpClientRequest has not been sent.
doOnResolve(Consumer<? super Connection>) - Method in class reactor.netty.transport.ClientTransport
Set or add a callback called before SocketAddress is 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 a SocketAddress.
doOnResponse(BiConsumer<? super HttpClientResponse, ? super Connection>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called after HttpClientResponse headers have been received and HttpClientState.RESPONSE_RECEIVED has been emitted.
doOnResponseError(BiConsumer<? super HttpClientResponse, ? super Throwable>) - Method in class reactor.netty.http.client.HttpClient
Setup a callback called when HttpClientResponse has not been fully received, HttpClientState.RESPONSE_INCOMPLETE has been emitted.
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 after DisposableServer has been shutdown.
doOnUnbound() - Method in class reactor.netty.transport.ServerTransportConfig
Return the configured callback or null.
doOnUnbound(Consumer<? super Connection>) - Method in class reactor.netty.udp.UdpServer
Set or add a callback called after UdpServer has been shutdown.
doOnUnbound() - Method in class reactor.netty.udp.UdpServerConfig
Return the configured callback or null.
duplicate() - Method in class reactor.netty.transport.Transport
Return a new Transport inheriting the current configuration.
duration() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the request/response duration.

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.channel.MeterKey
 
equals(Object) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
 
equals(Object) - Method in class reactor.netty.http.Http2SettingsSpec
 
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.incubator.quic.QuicInitialSettingsSpec
 
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.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 given HttpMessageArgProvider for a log with a level ERROR.
ERROR - Static variable in class reactor.netty.Metrics
 
ERRORS - Static variable in class reactor.netty.Metrics
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.transport.ClientTransportConfig
 
eventLoopGroup() - Method in class reactor.netty.transport.ServerTransportConfig
 
eventLoopGroup() - Method in class reactor.netty.transport.TransportConfig
Return the configured EventLoopGroup.
eventLoopGroup() - Method in class reactor.netty.udp.UdpServerConfig
 
evictInBackground(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider background eviction.
evictionPredicate(BiPredicate<Connection, ConnectionProvider.ConnectionMetadata>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider custom eviction predicate.
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 

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
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
Return the configured InternetProtocolFamily to run with or null.
family() - Method in class reactor.netty.udp.UdpServerConfig
Return the configured InternetProtocolFamily to run with or null.
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, InputStream) - 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, String, File, String) - 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, 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(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(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(BiPredicate<HttpClientRequest, HttpClientResponse>) - Method in class reactor.netty.http.client.HttpClient
Enables auto-redirect support if the passed Predicate matches.
followRedirect(BiPredicate<HttpClientRequest, HttpClientResponse>, BiConsumer<HttpHeaders, HttpClientRequest>) - Method in class reactor.netty.http.client.HttpClient
Variant of HttpClient.followRedirect(BiPredicate) that also accepts BiConsumer that 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 of HttpClient.followRedirect(BiPredicate) that also accepts a redirect request processor.
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 of HttpClient.followRedirect(boolean) that also accepts BiConsumer that 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 of HttpClient.followRedirect(boolean) 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-side SslContext.
forClient() - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new client-side SslContext.
forClient() - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new client-side SslContext.
forClient() - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new client-side SslContext.
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, File) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(File, File, String) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(InputStream, InputStream) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(InputStream, InputStream, String) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(KeyManager) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(KeyManagerFactory) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, String, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, X509Certificate...) - Static method in class reactor.netty.http.Http11SslContextSpec
Creates a builder for new server-side SslContext.
forServer(File, File) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(File, File, String) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(InputStream, InputStream) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(InputStream, InputStream, String) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(KeyManager) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(KeyManagerFactory) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, String, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, X509Certificate...) - Static method in class reactor.netty.http.Http2SslContextSpec
Creates a builder for new server-side SslContext.
forServer(File, File) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(File, File, String) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(InputStream, InputStream) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(InputStream, InputStream, String) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(KeyManager) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(KeyManagerFactory) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, String, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, X509Certificate...) - Static method in class reactor.netty.tcp.DefaultSslContextSpec
Creates a builder for new server-side SslContext.
forServer(File, File) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(File, File, String) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(InputStream, InputStream) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(InputStream, InputStream, String) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(KeyManager) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(KeyManagerFactory) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, String, Iterable<? extends X509Certificate>) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, String, X509Certificate...) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forServer(PrivateKey, X509Certificate...) - Static method in class reactor.netty.tcp.TcpSslContextSpec
Creates a builder for new server-side SslContext.
forwarded(BiFunction<ConnectionInfo, HttpRequest, ConnectionInfo>) - Method in class reactor.netty.http.server.HttpServer
Specifies a custom request handler for deriving information about the connection.
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.
from(Channel) - Static method in interface reactor.netty.Connection
Return an existing Connection wrapper or create a simple new one.
from(F) - Static method in class reactor.netty.FutureMono
Convert a Future into Mono.
from(TcpClient) - Static method in class reactor.netty.http.client.HttpClient
Deprecated.
Use the other methods exposed by HttpClient to 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 by HttpServer to achieve the same configurations. This method will be removed in version 1.1.0.
fromInbound(Publisher<?>) - Static method in class reactor.netty.ByteBufFlux
Decorate as ByteBufFlux.
fromInbound(Publisher<?>, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
Decorate as ByteBufFlux.
fromPath(Path) - Static method in class reactor.netty.ByteBufFlux
Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux.
fromPath(Path, int) - Static method in class reactor.netty.ByteBufFlux
Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux.
fromPath(Path, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
Open a FileChannel from a path and stream ByteBuf chunks with a default maximum size of 500K into the returned ByteBufFlux, using the provided ByteBufAllocator.
fromPath(Path, int, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
Open a FileChannel from a path and stream ByteBuf chunks with a given maximum size into the returned ByteBufFlux, using the provided ByteBufAllocator.
fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufFlux
Decorate as ByteBufFlux.
fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufFlux
Decorate as ByteBufFlux.
fromString(Publisher<? extends String>) - Static method in class reactor.netty.ByteBufMono
Decorate as ByteBufMono.
fromString(Publisher<? extends String>, Charset, ByteBufAllocator) - Static method in class reactor.netty.ByteBufMono
Decorate as ByteBufMono.
fullPath() - Method in interface reactor.netty.http.HttpInfos
Returns the decoded path portion from the HttpInfos.uri().
FutureMono - Class in reactor.netty
Convert Netty Future into void Mono.
FutureMono() - Constructor for class reactor.netty.FutureMono
 

G

get(Channel) - Static method in class reactor.netty.channel.ChannelOperations
Return the current Channel bound ChannelOperations or null if none.
get() - Method in class reactor.netty.http.client.HttpClient
HTTP GET to connect the HttpClient.
get() - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
 
get() - Method in class reactor.netty.http.Http11SslContextSpec
 
get() - Method in class reactor.netty.http.Http2SslContextSpec
 
get() - Static method in class reactor.netty.http.HttpResources
Return the global HTTP resources for event loops and pooling.
get() - Method in class reactor.netty.http.server.HttpRequestDecoderSpec
 
get(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
Listens for HTTP GET on the passed path to be used as a routing condition.
get() - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
 
get() - Static method in class reactor.netty.incubator.quic.QuicResources
Return the global QUIC resources for loops.
get() - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
 
get() - Method in class reactor.netty.tcp.DefaultSslContextSpec
 
get() - Static method in class reactor.netty.tcp.TcpResources
Return the global TCP resources for event loops and pooling.
get() - Method in class reactor.netty.tcp.TcpSslContextSpec
 
get() - Static method in class reactor.netty.udp.UdpResources
Return the global UDP resources for pooling.
getAddress() - Method in class reactor.netty.transport.ProxyProvider
The supplier for the address to connect to.
getAllCachedCookies() - Method in class reactor.netty.http.server.ServerCookies
Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.
getCachedCookies() - Method in class reactor.netty.http.Cookies
Wait for the cookies to become available, cache them and subsequently return the cached map of cookies.
getCachedCookies() - Method in class reactor.netty.http.server.ServerCookies
 
getChannelContext(Channel) - Static method in class reactor.netty.ReactorNetty
Returns ContextView from the channel attributes when exists otherwise returns null.
getDefaultConfigurationType() - Method in class reactor.netty.tcp.SslProvider
Returns the configured default configuration type.
getDefaultHostPort(String) - Static method in class reactor.netty.http.server.ConnectionInfo
Returns the default host port number based on scheme.
getHostAddress() - Method in class reactor.netty.http.server.ConnectionInfo
Return the host address of the connection.
getHostName() - Method in class reactor.netty.http.server.ConnectionInfo
Returns the connection host name.
getHostPort() - Method in class reactor.netty.http.server.ConnectionInfo
Returns the connection host port.
getMethod() - Method in interface reactor.netty.http.server.HttpRouteHandlerMetadata
Get the http method this handler can handle.
getNameResolverProvider() - Method in class reactor.netty.transport.ClientTransportConfig
Return the configured NameResolverProvider or null.
getNonProxyHostsPredicate() - Method in class reactor.netty.transport.ProxyProvider
A predicate Predicate on SocketAddress that returns true when the provided address should be reached directly, bypassing the proxy.
getOrCreate(LoopResources, Function<LoopResources, QuicResources>, String) - Static method in class reactor.netty.incubator.quic.QuicResources
Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getOrCreate(AtomicReference<T>, LoopResources, ConnectionProvider, BiFunction<LoopResources, ConnectionProvider, T>, String) - Static method in class reactor.netty.tcp.TcpResources
Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getOrCreate(LoopResources, Function<LoopResources, UdpResources>, String) - Static method in class reactor.netty.udp.UdpResources
Safely check if existing resource exist and proceed to update/cleanup if new resources references are passed.
getOrCreateDefaultResolver() - Method in class reactor.netty.http.HttpResources
 
getOrCreateDefaultResolver() - Method in class reactor.netty.tcp.TcpResources
Safely checks whether a name resolver exists and proceed with a creation if it does not exist.
getOrCreateHttp2ConnectionProvider(Function<ConnectionProvider, ConnectionProvider>) - Method in class reactor.netty.http.HttpResources
Safely checks whether a ConnectionProvider for HTTP/2 traffic exists and proceed with a creation if it does not exist.
getPath() - Method in interface reactor.netty.http.server.HttpRouteHandlerMetadata
Get the http path this handler can handle.
getPermits(int) - Method in class reactor.netty.http.client.Http2AllocationStrategy
 
getPermits(int) - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
Try to get the permission to allocate a desired positive number of new connections.
getRemoteAddress() - Method in class reactor.netty.http.server.ConnectionInfo
Return the remote address of the connection.
getResolveAddressTimer(String, String, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
getScheme() - Method in class reactor.netty.http.server.ConnectionInfo
Return the connection scheme.
getSpanName(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTracingObservationHandler
 
getSslContext() - Method in class reactor.netty.tcp.SslProvider
Returns SslContext instance with configured settings.
getTimer() - Method in interface reactor.netty.observability.ReactorNettyHandlerContext
Obtain the timer associated to this reactor netty context.
getTlsHandshakeTimer(String, String, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
getType() - Method in class reactor.netty.transport.ProxyProvider
The proxy type.

H

h2cMaxContentLength - Variable in class reactor.netty.http.HttpDecoderSpec
 
h2cMaxContentLength(int) - Method in class reactor.netty.http.HttpDecoderSpec
Configure the maximum length of the content of the HTTP/2.0 clear-text upgrade request.
h2cMaxContentLength() - Method in class reactor.netty.http.HttpDecoderSpec
Return the configured maximum length of the content of the HTTP/2.0 clear-text upgrade request.
H2CUpgradeHandler - Static variable in interface reactor.netty.NettyPipeline
 
H2Flush - Static variable in interface reactor.netty.NettyPipeline
 
H2MultiplexHandler - Static variable in interface reactor.netty.NettyPipeline
 
H2OrHttp11Codec - Static variable in interface reactor.netty.NettyPipeline
 
H2ToHttp11Codec - Static variable in interface reactor.netty.NettyPipeline
 
handle(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
Negotiate a websocket upgrade and extract a flux from the given WebsocketInbound and WebsocketOutbound.
handle(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in class reactor.netty.http.server.HttpServer
Attach an I/O handler to react on a connected client.
handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpClient
Attach an IO handler to react on connected client.
handle(BiFunction<? super NettyInbound, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.tcp.TcpServer
Attaches an I/O handler to react on a connected client.
handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpClient
Attach an IO handler to react on connected client.
handle(BiFunction<? super UdpInbound, ? super UdpOutbound, ? extends Publisher<Void>>) - Method in class reactor.netty.udp.UdpServer
Attach an IO handler to react on connected client.
handlePing(boolean) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
Sets flag whether to proxy websocket ping frames or respond to them.
handlePing() - Method in interface reactor.netty.http.websocket.WebsocketSpec
Returns whether to proxy websocket PING frames or respond to them.
handlePing() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
 
handlerConfigurator(Consumer<? super SslHandler>) - Method in interface reactor.netty.tcp.SslProvider.Builder
Set a configurator callback to mutate any property from the provided SslHandler.
handshakeTimeout(Duration) - Method in interface reactor.netty.tcp.SslProvider.Builder
Set the options to use for configuring SSL handshake timeout.
handshakeTimeoutMillis(long) - Method in interface reactor.netty.tcp.SslProvider.Builder
Set the options to use for configuring SSL handshake timeout.
hashCode() - Method in class reactor.netty.channel.MeterKey
 
hashCode() - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
 
hashCode() - Method in class reactor.netty.http.Http2SettingsSpec
 
hashCode() - Method in class reactor.netty.http.HttpDecoderSpec
 
hashCode() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
 
hashCode() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
 
hashCode() - Method in class reactor.netty.tcp.SslProvider
 
hashCode() - Method in class reactor.netty.transport.NameResolverProvider
 
hashCode() - Method in class reactor.netty.transport.ProxyProvider
 
hasNativeSupport() - Static method in interface reactor.netty.resources.LoopResources
Return true if environment supports native connections.
hasProxy() - Method in class reactor.netty.transport.ClientTransportConfig
Return true if that ClientTransportConfig is 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 the HttpClient.
head(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
Listens for HTTP HEAD on the passed path to be used as a routing condition.
header(CharSequence, CharSequence) - Method in interface reactor.netty.http.client.HttpClientRequest
Set an outbound header, replacing any pre-existing value.
header(CharSequence, CharSequence) - Method in interface reactor.netty.http.server.HttpServerResponse
Sets an outbound HTTP header, replacing any pre-existing value.
headers(Consumer<? super HttpHeaders>) - Method in class reactor.netty.http.client.HttpClient
Apply headers configuration.
headers() - Method in class reactor.netty.http.client.HttpClientConfig
Return a copy of the request headers.
headers(HttpHeaders) - Method in interface reactor.netty.http.client.HttpClientRequest
Set outbound headers from the passed headers.
headers() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
Returns the request/response headers.
headers(HttpHeaders) - Method in interface reactor.netty.http.server.HttpServerResponse
Sets outbound HTTP headers, replacing any pre-existing value for these headers.
headers() - Method in interface reactor.netty.http.websocket.WebsocketInbound
Returns the websocket remote headers sent during handshake.
headersWhen(Function<? super HttpHeaders, Mono<? extends HttpHeaders>>) - Method in class reactor.netty.http.client.HttpClient
Apply headers configuration emitted by the returned Mono before requesting.
headerTableSize(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_HEADER_TABLE_SIZE value.
headerTableSize() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_HEADER_TABLE_SIZE value or null.
headerValueFunction() - Method in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
Returns the function that is used for sanitizing the headers values.
HEAP_ARENAS - Static variable in class reactor.netty.Metrics
The number of heap arenas.
host() - Method in interface reactor.netty.DisposableServer
Returns the server's host string.
host(String) - Method in class reactor.netty.http.server.HttpServer
 
host(String) - Method in class reactor.netty.incubator.quic.QuicClient
The host to which this client should connect.
host(String) - Method in class reactor.netty.incubator.quic.QuicServer
The host to which this server should bind.
host(String) - Method in class reactor.netty.tcp.TcpClient
 
host(String) - Method in class reactor.netty.tcp.TcpServer
 
host(String) - Method in class reactor.netty.transport.ClientTransport
The host to which this client should connect.
host(String) - Method in interface reactor.netty.transport.ProxyProvider.AddressSpec
The proxy host to connect to.
host(String) - Method in class reactor.netty.transport.ServerTransport
The host to which this server should bind.
host(String) - Method in class reactor.netty.udp.UdpClient
 
host(String) - Method in class reactor.netty.udp.UdpServer
The host to which this server should bind.
hostAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
Returns the address of the host which received the request, possibly null in case of Unix Domain Sockets.
hostAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
 
hostName() - Method in interface reactor.netty.http.server.ConnectionInformation
Returns the host name derived from the Host/X-Forwarded-Host/Forwarded header associated with this request.
HOSTNAME_VERIFICATION_CONFIGURER - Static variable in class reactor.netty.http.client.HttpClientSecurityUtils
Enables the hostname verification.
hostPort() - Method in interface reactor.netty.http.server.ConnectionInformation
Returns the host port derived from the Host/X-Forwarded-*/Forwarded header associated with this request.
hostsFileEntriesResolver() - Method in class reactor.netty.transport.NameResolverProvider
Returns the configured custom HostsFileEntriesResolver to be used for hosts file entries or null.
hostsFileEntriesResolver(HostsFileEntriesResolver) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Specifies a custom HostsFileEntriesResolver to be used for hosts file entries.
HostSpecificSpec() - Constructor for class reactor.netty.resources.ConnectionProvider.HostSpecificSpec
 
Http11SslContextSpec - Class in reactor.netty.http
SslContext builder that provides default configuration specific to HTTP/1.x as follows: SslProvider will be set depending on OpenSsl.isAvailable() The default cipher suites will be used Application protocol negotiation configuration is disabled
Http2AllocationStrategy - Class in reactor.netty.http.client
HTTP/2 ConnectionProvider.AllocationStrategy.
Http2AllocationStrategy.Builder - Interface in reactor.netty.http.client
 
http2Settings(Consumer<Http2SettingsSpec.Builder>) - Method in class reactor.netty.http.client.HttpClient
Apply HTTP/2 configuration.
http2Settings(Consumer<Http2SettingsSpec.Builder>) - Method in class reactor.netty.http.server.HttpServer
Apply HTTP/2 configuration.
http2SettingsSpec() - Method in class reactor.netty.http.client.HttpClientConfig
Return the HTTP/2 configuration.
Http2SettingsSpec - Class in reactor.netty.http
A configuration builder to fine tune the Http2Settings.
http2SettingsSpec() - Method in class reactor.netty.http.server.HttpServerConfig
Return the HTTP/2 configuration.
Http2SettingsSpec.Builder - Interface in reactor.netty.http
 
Http2SslContextSpec - Class in reactor.netty.http
SslContext builder that provides default configuration specific to HTTP/2 as follows: SslProvider will be set depending on OpenSsl.isAlpnSupported() Http2SecurityUtil.CIPHERS Application protocol negotiation configuration is enabled HTTP/1.1 and HTTP/2 support in order to support upgrade to HTTP/2
HTTP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the HTTP client's metrics registered in Micrometer's global registry.
HTTP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the HTTP server's metrics registered in Micrometer's global registry.
HttpAggregator - Static variable in interface reactor.netty.NettyPipeline
 
HttpClient - Class in reactor.netty.http.client
An HttpClient allows building in a safe immutable way an http client that is materialized and connecting when ClientTransport.connect() is ultimately called.
HttpClient() - Constructor for class reactor.netty.http.client.HttpClient
 
HttpClient.RedirectSendHandler - Interface in reactor.netty.http.client
Marker interface for use with HttpClient.RequestSender.send(BiFunction).
HttpClient.RequestSender - Interface in reactor.netty.http.client
Allow a request body configuration before calling one of the terminal, Publisher based, HttpClient.ResponseReceiver API.
HttpClient.ResponseReceiver<S extends HttpClient.ResponseReceiver<?>> - Interface in reactor.netty.http.client
A response extractor for this configured HttpClient.
HttpClient.UriConfiguration<S extends HttpClient.UriConfiguration<?>> - Interface in reactor.netty.http.client
A URI configuration.
HttpClient.WebsocketReceiver<S extends HttpClient.WebsocketReceiver<?>> - Interface in reactor.netty.http.client
Allow a websocket handling.
HttpClient.WebsocketSender - Interface in reactor.netty.http.client
Allow a request body configuration before calling one of the terminal, Publisher based, HttpClient.WebsocketReceiver API.
HttpClientConfig - Class in reactor.netty.http.client
Encapsulate all necessary configuration for HTTP client transport.
HttpClientForm - Interface in reactor.netty.http.client
An HTTP Form builder.
HttpClientInfos - Interface in reactor.netty.http.client
An Http Reactive Channel with several accessors related to HTTP flow: resource URL, information for redirections etc...
HttpClientMetricsRecorder - Interface in reactor.netty.http.client
Interface for collecting metrics on HTTP client level.
HttpClientRequest - Interface in reactor.netty.http.client
An Http Reactive client metadata contract for outgoing requests.
HttpClientResponse - Interface in reactor.netty.http.client
An HttpClient Reactive metadata contract for incoming response.
HttpClientSecurityUtils - Class in reactor.netty.http.client
Provides utilities for HttpClient SSL/TLS configuration.
HttpClientState - Enum in reactor.netty.http.client
Specific Http Client state observable by HttpClient.observe(ConnectionObserver).
HttpCodec - Static variable in interface reactor.netty.NettyPipeline
 
HttpDecoderSpec<T extends HttpDecoderSpec<T>> - Class in reactor.netty.http
A configuration builder to fine tune the HttpCodec (or more precisely the settings for the decoder).
HttpDecoderSpec() - Constructor for class reactor.netty.http.HttpDecoderSpec
 
HttpDecompressor - Static variable in interface reactor.netty.NettyPipeline
 
httpFormDecoder(Consumer<HttpServerFormDecoderProvider.Builder>) - Method in class reactor.netty.http.server.HttpServer
Apply HTTP form decoder configuration.
httpHeaders(Consumer<HttpHeaders>) - Method in interface reactor.netty.transport.ProxyProvider.Builder
A consumer to add request headers for the http proxy.
HttpInfos - Interface in reactor.netty.http
An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...
HttpMessageArgProvider - Interface in reactor.netty.http.logging
A provider of the args required for logging HttpMessage details.
HttpMessageArgProviderFactory - Class in reactor.netty.http.logging
Factory for creating HttpContentArgProvider based on the provided HTTP object.
httpMessageLogFactory(HttpMessageLogFactory) - Method in class reactor.netty.http.client.HttpClient
When HttpMessage is about to be logged the configured factory will be used for generating a sanitized log message.
httpMessageLogFactory() - Method in class reactor.netty.http.HttpOperations
 
HttpMessageLogFactory - Interface in reactor.netty.http.logging
Factory for generating a log message based on a given HttpMessageArgProvider.
httpMessageLogFactory(HttpMessageLogFactory) - Method in class reactor.netty.http.server.HttpServer
When HttpMessage is about to be logged the configured factory will be used for generating a sanitized log message.
HttpMessageLogUtils - Class in reactor.netty.http.logging
Utilities for creating log message based on a given HttpMessageArgProvider.
httpMessageType() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
Returns the HttpMessage type.
HttpMessageType - Enum in reactor.netty.http.logging
Representation of various HttpMessage types.
HttpMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
 
HttpMetricsRecorder - Interface in reactor.netty.http
Interface for recording metrics for HTTP protocol.
HttpOperations<INBOUND extends NettyInbound,OUTBOUND extends NettyOutbound> - Class in reactor.netty.http
An HTTP ready ChannelOperations with state management for status and headers (first HTTP response packet).
HttpOperations(HttpOperations<INBOUND, OUTBOUND>) - Constructor for class reactor.netty.http.HttpOperations
 
HttpOperations(Connection, ConnectionObserver, HttpMessageLogFactory) - Constructor for class reactor.netty.http.HttpOperations
 
HttpOperations.PostHeadersNettyOutbound - Class in reactor.netty.http
 
HttpProtocol - Enum in reactor.netty.http
An enum defining various HTTP negotiations between H2, H2C-upgrade, H2C-prior-knowledge and HTTP/1.1.
httpRequestDecoder(Function<HttpRequestDecoderSpec, HttpRequestDecoderSpec>) - Method in class reactor.netty.http.server.HttpServer
Configure the HttpServerCodec's request decoding options.
HttpRequestDecoderSpec - Class in reactor.netty.http.server
A configuration builder to fine tune the HttpServerCodec (or more precisely the HttpServerCodec.HttpServerRequestDecoder) for HTTP/1.1 or HttpServerUpgradeHandler for 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 the HttpClientCodec's response decoding options.
HttpResponseDecoderSpec - Class in reactor.netty.http.client
A configuration builder to fine tune the HttpClientCodec (or more precisely the HttpClientCodec.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 when ServerTransport.bind() is ultimately called.
HttpServer() - Constructor for class reactor.netty.http.server.HttpServer
 
HttpServerConfig - Class in reactor.netty.http.server
Encapsulate all necessary configuration for HTTP server transport.
HttpServerFormDecoderProvider - Class in reactor.netty.http.server
A configuration builder to fine tune the HTTP form decoder.
HttpServerFormDecoderProvider.Builder - Interface in reactor.netty.http.server
 
HttpServerInfos - Interface in reactor.netty.http.server
An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...
HttpServerMetricsRecorder - Interface in reactor.netty.http.server
Interface for collecting metrics on HTTP server level.
HttpServerRequest - Interface in reactor.netty.http.server
An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...
HttpServerResponse - Interface in reactor.netty.http.server
An Http Reactive Channel with several accessors related to HTTP flow: headers, params, URI, method, websocket...
HttpServerRoutes - Interface in reactor.netty.http.server
Server routes are unique and only the first matching in order of declaration will be invoked.
HttpServerState - Enum in reactor.netty.http.server
Specific Http Server state observable by Transport.observe(ConnectionObserver).
HttpTrafficHandler - Static variable in interface reactor.netty.NettyPipeline
 

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(Duration) - Method in class reactor.netty.http.server.HttpServer
Specifies an idle timeout on the connection when it is waiting for an HTTP request (resolution: ms).
idleTimeout() - Method in class reactor.netty.http.server.HttpServerConfig
Return the configured idle timeout for the connection when it is waiting for an HTTP request or null.
IdleTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
 
inbound() - Method in class reactor.netty.channel.ChannelOperations
 
inbound() - Method in interface reactor.netty.Connection
Return the NettyInbound read API from this connection.
inboundHandler(BiConsumer<? super ChannelHandlerContext, Object>) - Static method in interface reactor.netty.NettyPipeline
incrementErrorsCount(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Increments the number of the errors that are occurred.
incrementErrorsCount(ContextView, SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
Increments the number of the errors that are occurred.
incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
 
incrementErrorsCount(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
incrementErrorsCount(ContextView, SocketAddress, String) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
Increments the number of the errors that are occurred.
incrementErrorsCount(SocketAddress, String) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
 
incrementErrorsCount(SocketAddress, String) - Method in interface reactor.netty.http.HttpMetricsRecorder
Increments the number of the errors that are occurred.
incrementErrorsCount(SocketAddress, String) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
index(BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
This route will be invoked when GET "/path" or "/path/" like uri are requested.
INDEX_PREDICATE - Static variable in interface reactor.netty.http.server.HttpServerRoutes
 
info(HttpMessageArgProvider) - Method in class reactor.netty.http.logging.AbstractHttpMessageLogFactory
 
info(HttpMessageArgProvider) - Method in interface reactor.netty.http.logging.HttpMessageLogFactory
Generates a log message based on a given HttpMessageArgProvider for a log with a level INFO.
initialBufferSize - Variable in class reactor.netty.http.HttpDecoderSpec
 
initialBufferSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
Configure the initial buffer size for HTTP request decoding.
initialBufferSize() - Method in class reactor.netty.http.HttpDecoderSpec
Return the configured initial buffer size for HTTP request decoding.
initialWindowSize(int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_INITIAL_WINDOW_SIZE value.
initialWindowSize() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_INITIAL_WINDOW_SIZE value or null.
initShortId() - Method in class reactor.netty.channel.ChannelOperations
 
initShortId() - Method in class reactor.netty.http.HttpOperations
 
INSTANCE - Static variable in class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
 
IO_SELECT_COUNT - Static variable in class reactor.netty.ReactorNetty
Default selector thread count, fallback to -1 (no selector thread)
IO_WORKER_COUNT - Static variable in class reactor.netty.ReactorNetty
Default worker thread count, fallback to available processor (but with a minimum value of 4).
isAcceptGzip() - Method in class reactor.netty.http.client.HttpClientConfig
Return whether GZip compression is enabled.
isCompleteOncePreferredResolved() - Method in class reactor.netty.transport.NameResolverProvider
Returns true if the resolver notifies the returned Future as soon as all queries for the preferred address type are complete.
isConnectionReset(Throwable) - Static method in exception reactor.netty.channel.AbortedException
Return true if connection has been simply aborted on a tcp level by verifying if the given inbound error.
isContentAlwaysEmpty() - Method in class reactor.netty.http.HttpOperations
 
isDisableOptionalRecord() - Method in class reactor.netty.transport.NameResolverProvider
Returns true if an optional record inclusion is disabled.
isDisableRecursionDesired() - Method in class reactor.netty.transport.NameResolverProvider
Returns true if recursion desired is disabled.
isDisposed() - Method in class reactor.netty.channel.ChannelOperations
 
isDisposed() - Method in interface reactor.netty.DisposableChannel
 
isDisposed() - Method in class reactor.netty.incubator.quic.QuicResources
 
isDisposed() - Method in class reactor.netty.resources.PooledConnectionProvider
 
isDisposed() - Method in class reactor.netty.tcp.TcpResources
 
isDisposed() - Method in class reactor.netty.udp.UdpResources
 
isFollowRedirect() - Method in interface reactor.netty.http.client.HttpClientRequest
Return true if redirected will be followed.
isFormUrlencoded() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns true if the request has Content-Type with value application/x-www-form-urlencoded.
isForwarded() - Method in class reactor.netty.http.server.HttpServerConfig
Returns whether that HttpServer supports the "Forwarded" and "X-Forwarded-*" HTTP request headers for deriving information about the connection.
isInboundCancelled() - Method in class reactor.netty.channel.ChannelOperations
Return true if inbound traffic is not expected anymore.
isInboundComplete() - Method in class reactor.netty.channel.ChannelOperations
Return true if inbound traffic is not incoming or expected anymore.
isInboundDisposed() - Method in class reactor.netty.channel.ChannelOperations
Return true if inbound traffic is not incoming or expected anymore.
isKeepAlive() - Method in interface reactor.netty.http.HttpInfos
Is the request keep alive.
isLocalStream() - Method in interface reactor.netty.incubator.quic.QuicStreamInfo
Returns true if the stream was created by this peer.
isMicrometerAvailable() - Static method in class reactor.netty.internal.util.Metrics
Check if the current runtime supports metrics, by verifying if Micrometer Core is on the classpath.
isMultipart() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns true if the request has Content-Type with value multipart/form-data.
isPersistent() - Method in class reactor.netty.channel.ChannelOperations
 
isPersistent() - Method in interface reactor.netty.Connection
Return false if it will force a close on terminal protocol events thus defeating any pooling strategy Return true (default) if it will release on terminal protocol events thus keeping alive the channel if possible.
isPreferNative() - Method in class reactor.netty.transport.NameResolverProvider
Returns true if prefer native event loop and channel factory (e.g.
isPreferNative() - Method in class reactor.netty.transport.TransportConfig
Return true if prefer native event loop and channel factory (e.g.
isRetryDisabled() - Method in class reactor.netty.http.client.HttpClientConfig
Return true if retry once is disabled, false otherwise.
isRoundRobinSelection() - Method in class reactor.netty.transport.NameResolverProvider
Returns true if RoundRobinDnsAddressResolverGroup is in use.
isSecure() - Method in class reactor.netty.http.client.HttpClientConfig
Returns true if that HttpClient secured via SSL transport.
isSecure() - Method in class reactor.netty.http.server.HttpServerConfig
Returns true if that HttpServer secured via SSL transport.
isSecure() - Method in class reactor.netty.tcp.TcpClientConfig
Return true if that TcpClient secured via SSL transport.
isSecure() - Method in class reactor.netty.tcp.TcpServerConfig
Returns true if that TcpServer secured via SSL transport.
isSubscriptionDisposed() - Method in class reactor.netty.channel.ChannelOperations
Return true if dispose subscription has been terminated.
isTracingAvailable() - Static method in class reactor.netty.internal.util.Metrics
Check if the current runtime supports tracing, by verifying if Micrometer Tracing is on the classpath.
isWebsocket() - Method in interface reactor.netty.http.HttpInfos
Returns true if websocket connection (upgraded).
isWebsocket() - Method in class reactor.netty.http.HttpOperations
 

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 request keepAlive if true otherwise remove the existing connection keep alive header.

L

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.
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 parent ConnectionObserver for user-facing lifecycle handling.
LOCAL_ADDRESS - Static variable in class reactor.netty.Metrics
 
localHost() - Method in exception reactor.netty.ChannelBindException
Return the configured binding host.
localPort() - Method in exception reactor.netty.ChannelBindException
Return the configured binding port.
loggingHandler(LoggingHandler) - Method in class reactor.netty.http.client.HttpClientConfig
 
loggingHandler(LoggingHandler) - Method in class reactor.netty.http.server.HttpServerConfig
 
LoggingHandler - Static variable in interface reactor.netty.NettyPipeline
 
loggingHandler() - Method in class reactor.netty.transport.TransportConfig
Return the configured LoggingHandler or null.
loggingHandler(LoggingHandler) - Method in class reactor.netty.transport.TransportConfig
 
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 provided HttpMessageArgProvider.
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 - Interface in reactor.netty.resources
An EventLoopGroup selector with associated Channel factories.
loopResources() - Method in class reactor.netty.transport.NameResolverProvider
Returns the configured LoopResources or null.
loopResources() - Method in class reactor.netty.transport.TransportConfig
Return the configured LoopResources or the default.

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 8 Map issues.
markPersistent(boolean) - Method in interface reactor.netty.Connection
Mark the underlying channel as persistent or not.
markReadCookies() - Method in class reactor.netty.http.Cookies
 
markReadingCookies() - Method in class reactor.netty.http.Cookies
 
markSentBody() - Method in class reactor.netty.http.HttpOperations
Mark the body sent.
markSentHeaderAndBody(Object...) - Method in class reactor.netty.http.HttpOperations
Mark the headers and body sent.
markSentHeaders(Object...) - Method in class reactor.netty.http.HttpOperations
Mark the headers sent.
MAX_CONNECTIONS - Static variable in class reactor.netty.Metrics
The maximum number of active connections that are allowed.
MAX_PENDING_CONNECTIONS - Static variable in class reactor.netty.Metrics
The maximum number of requests that will be queued while waiting for a ready connection.
maxAllocatedSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Get the maximum number of live resources this Pool will allow.
maxChunkSize - Variable in class reactor.netty.http.HttpDecoderSpec
 
maxChunkSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
Deprecated.
as of 1.1.0. This will be removed in 2.0.0 as Netty 5 does not support this configuration.
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.
maxConcurrentStreams(long) - Method in interface reactor.netty.http.client.Http2AllocationStrategy.Builder
Configures the maximum number of the concurrent streams that can be opened to the remote peer.
maxConcurrentStreams() - Method in class reactor.netty.http.client.Http2AllocationStrategy
Returns the configured maximum number of the concurrent streams that can be opened to the remote peer.
maxConcurrentStreams(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_MAX_CONCURRENT_STREAMS value.
maxConcurrentStreams() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_MAX_CONCURRENT_STREAMS value or null.
maxConnections(int) - Method in interface reactor.netty.http.client.Http2AllocationStrategy.Builder
Configures the maximum number of live connections to keep in the pool.
maxConnections(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider maximum connections per connection pool.
maxConnections() - Method in interface reactor.netty.resources.ConnectionProvider
Returns the maximum number of connections before starting pending.
maxConnections() - Method in class reactor.netty.resources.PooledConnectionProvider
 
maxConnections() - Method in class reactor.netty.tcp.TcpResources
 
maxConnectionsPerHost() - Method in interface reactor.netty.resources.ConnectionProvider
Returns the maximum number of connections per host before starting pending.
maxConnectionsPerHost() - Method in class reactor.netty.resources.PooledConnectionProvider
 
maxConnectionsPerHost() - Method in class reactor.netty.tcp.TcpResources
 
maxData(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
Set the initial maximum data limit.
maxData() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
Return the configured initial maximum data limit.
maxFramePayloadLength(int) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
Sets specifies a custom maximum allowable frame payload length.
maxFramePayloadLength() - Method in interface reactor.netty.http.websocket.WebsocketSpec
Returns the configured maximum allowable frame payload length.
maxFramePayloadLength() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
 
maxFrameSize(int) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_MAX_FRAME_SIZE value.
maxFrameSize() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_MAX_FRAME_SIZE value or null.
maxHeaderListSize(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
Sets the SETTINGS_MAX_HEADER_LIST_SIZE value.
maxHeaderListSize() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_MAX_HEADER_LIST_SIZE value or the default Http2CodecUtil.DEFAULT_HEADER_LIST_SIZE.
maxHeaderSize - Variable in class reactor.netty.http.HttpDecoderSpec
 
maxHeaderSize(int) - Method in class reactor.netty.http.HttpDecoderSpec
Configure the maximum header size that can be decoded for the HTTP request.
maxHeaderSize() - Method in class reactor.netty.http.HttpDecoderSpec
Return the configured maximum header size that can be decoded for the HTTP request.
maxIdleTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider max idle time (resolution: ms).
maxIdleTime() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
 
maxInitialLineLength - Variable in class reactor.netty.http.HttpDecoderSpec
 
maxInitialLineLength(int) - Method in class reactor.netty.http.HttpDecoderSpec
Configure the maximum length that can be decoded for the HTTP request's initial line.
maxInitialLineLength() - Method in class reactor.netty.http.HttpDecoderSpec
Return the configured maximum length that can be decoded for the HTTP request's initial line.
maxInMemorySize(long) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
Sets the maximum in-memory size per Attribute/FileUpload i.e.
maxInMemorySize() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
Returns the configured maximum size after which an Attribute/FileUpload starts being stored on disk rather than in memory.
maxKeepAliveRequests(int) - Method in class reactor.netty.http.server.HttpServer
The maximum number of HTTP/1.1 requests which can be served until the connection is closed by the server.
maxKeepAliveRequests() - Method in class reactor.netty.http.server.HttpServerConfig
The configured maximum number of HTTP/1.1 requests which can be served until the connection is closed by the server.
maxLifeTime(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider max life time (resolution: ms).
maxLifeTime() - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
 
maxPayloadSize() - Method in class reactor.netty.transport.NameResolverProvider
Returns the configured capacity of the datagram packet buffer.
maxPayloadSize(int) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Sets the capacity of the datagram packet buffer (in bytes).
maxPendingAcquireSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Get the maximum number of Pool.acquire() this Pool can queue in a pending state when no available resource is immediately handy (and the Pool cannot allocate more resources).
maxQueriesPerResolve() - Method in class reactor.netty.transport.NameResolverProvider
Returns the configured maximum allowed number of DNS queries to send when resolving a host name.
maxQueriesPerResolve(int) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Sets the maximum allowed number of DNS queries to send when resolving a host name.
maxSize(long) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
Set the maximum size per Attribute/FileUpload.
maxSize() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
Returns the configured maximum allowed size of individual Attribute/FileUpload.
maxStreamDataBidirectionalLocal(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
Set the initial maximum data limit for local bidirectional streams.
maxStreamDataBidirectionalLocal() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
Return the configured initial maximum data limit for local bidirectional streams.
maxStreamDataBidirectionalRemote(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
Set the initial maximum data limit for remote bidirectional streams.
maxStreamDataBidirectionalRemote() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
Return the configured initial maximum data limit for remote bidirectional streams.
maxStreamDataUnidirectional(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
Set the initial maximum data limit for unidirectional streams.
maxStreamDataUnidirectional() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
Return the configured initial maximum data limit for unidirectional streams.
maxStreams(long) - Method in interface reactor.netty.http.Http2SettingsSpec.Builder
The connection is marked for closing once the number of all-time streams reaches maxStreams.
maxStreams() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured maxStreams value or null.
maxStreamsBidirectional(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
Set the initial maximum stream limit for bidirectional streams.
maxStreamsBidirectional() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
Return the configured initial maximum stream limit for bidirectional streams.
maxStreamsUnidirectional(long) - Method in interface reactor.netty.incubator.quic.QuicInitialSettingsSpec.Builder
Set the initial maximum stream limit for unidirectional streams.
maxStreamsUnidirectional() - Method in class reactor.netty.incubator.quic.QuicInitialSettingsSpec
Return the configured initial maximum stream limit for unidirectional streams.
MeterKey - Class in reactor.netty.channel
Contains meters' tags values.
MeterKey(String, String, String, String) - Constructor for class reactor.netty.channel.MeterKey
 
method() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured request method.
method() - Method in interface reactor.netty.http.HttpInfos
Returns the resolved request method (HTTP 1.1 etc.).
method() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
Returns the name of this method, (e.g.
method() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the name of this method, (e.g.
METHOD - Static variable in class reactor.netty.Metrics
 
metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.HTTP_CLIENT_PREFIX.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClient
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.client.HttpClient
Specifies whether the metrics are enabled on the HttpClient.
metrics(boolean, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.HTTP_SERVER_PREFIX.
metrics(boolean, Function<String, String>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.HTTP_SERVER_PREFIX.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.server.HttpServer
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
Specifies whether the metrics are enabled on the HttpServer.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>, Function<String, String>, Function<String, String>) - Method in class reactor.netty.http.server.HttpServer
Specifies whether the metrics are enabled on the HttpServer.
Metrics - Class in reactor.netty.internal.util
Utility class around instrumentation and metrics with Micrometer.
Metrics() - Constructor for class reactor.netty.internal.util.Metrics
 
Metrics - Class in reactor.netty
Constants and utilities around metrics.
Metrics() - Constructor for class reactor.netty.Metrics
 
metrics(boolean) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry under the name Metrics.CONNECTION_PROVIDER_PREFIX.
metrics(boolean, Supplier<? extends ConnectionProvider.MeterRegistrar>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Specifies whether the metrics are enabled on the ConnectionProvider.
metrics(boolean) - Method in class reactor.netty.tcp.TcpClient
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpClient
 
metrics(boolean) - Method in class reactor.netty.tcp.TcpServer
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.tcp.TcpServer
 
metrics(boolean) - Method in class reactor.netty.transport.Transport
Whether to enable metrics to be collected and registered in Micrometer's globalRegistry.
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.transport.Transport
Specifies whether the metrics are enabled on the Transport.
metrics(boolean) - Method in class reactor.netty.udp.UdpClient
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpClient
 
metrics(boolean) - Method in class reactor.netty.udp.UdpServer
 
metrics(boolean, Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.udp.UdpServer
 
metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.client.HttpClientConfig
 
metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.http.server.HttpServerConfig
 
metricsRecorder() - Method in class reactor.netty.transport.TransportConfig
Return the configured metrics recorder ChannelMetricsRecorder or null.
metricsRecorder(Supplier<? extends ChannelMetricsRecorder>) - Method in class reactor.netty.transport.TransportConfig
Obtains immediately the ChannelMetricsRecorder from the provided Supplier.
metricsRecorderInternal() - Method in class reactor.netty.transport.TransportConfig
 
MicrometerChannelMetricsHandler - Class in reactor.netty.channel
ChannelHandler for collecting metrics on protocol level.
MicrometerChannelMetricsRecorder - Class in reactor.netty.channel
A ChannelMetricsRecorder implementation for integration with Micrometer.
MicrometerChannelMetricsRecorder(String, String) - Constructor for class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
MicrometerHttpMetricsRecorder - Class in reactor.netty.http
An HttpMetricsRecorder implementation for integration with Micrometer.
MicrometerHttpMetricsRecorder(String, String) - 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 this ConnectionProvider.
mutate() - Method in class reactor.netty.resources.PooledConnectionProvider
 
mutate() - Method in class reactor.netty.tcp.TcpResources
 

N

name() - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
NAME - Static variable in class reactor.netty.Metrics
 
name(String) - Method in class reactor.netty.resources.ConnectionProvider.Builder
ConnectionProvider name is used for metrics.
name() - Method in interface reactor.netty.resources.ConnectionProvider
Returns ConnectionProvider name used for metrics.
name() - Method in class reactor.netty.resources.PooledConnectionProvider
 
name() - Method in class reactor.netty.tcp.TcpResources
 
NameResolverProvider - Class in reactor.netty.transport
NameResolverProvider.NameResolverSpec - Interface in reactor.netty.transport
 
NATIVE - Static variable in class reactor.netty.ReactorNetty
Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available.
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.
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.
NettyInbound - Interface in reactor.netty
An inbound-traffic API delegating to an underlying Channel.
NettyOutbound - Interface in reactor.netty
An outbound-traffic API delegating to an underlying Channel.
NettyPipeline - Interface in reactor.netty
Constant for names used when adding/removing ChannelHandler.
neverComplete() - Method in interface reactor.netty.NettyOutbound
Returns a never completing Mono after this NettyOutbound.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 unpooled HttpClient.
newConnection() - Static method in interface reactor.netty.resources.ConnectionProvider
Return a ConnectionProvider that will always create a new Connection.
newConnection() - Static method in class reactor.netty.tcp.TcpClient
Prepare a non pooled TcpClient.
newFullBodyMessage(ByteBuf) - Method in class reactor.netty.http.HttpOperations
 
newNameResolverGroup(LoopResources, boolean) - Method in class reactor.netty.transport.NameResolverProvider
Provides a new DnsAddressResolverGroup.
newPool(Publisher<T>, AllocationStrategy, Function<T, Publisher<Void>>, BiPredicate<T, PooledRefMetadata>) - 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>, 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, Function<PoolConfig<T>, InstrumentedPool<T>>) - Method in class reactor.netty.resources.PooledConnectionProvider.PoolFactory
 
newProxyHandler() - Method in class reactor.netty.transport.ProxyProvider
Return a new eventual ProxyHandler.
newRoutes() - Static method in interface reactor.netty.http.server.HttpServerRoutes
Returns a new default routing registry HttpServerRoutes.
newServerRequestHolder(HttpHeaders, ServerCookieDecoder) - Static method in class reactor.netty.http.Cookies
Deprecated.
as of 1.0.8. Prefer ServerCookies.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 applied Comparator customization using HttpServerRoutes.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 the ObservationRegistry to 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 given ConnectionObserver to observe the connection state changes.
observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpClient
 
observe(ConnectionObserver) - Method in class reactor.netty.udp.UdpServer
 
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in class reactor.netty.incubator.quic.QuicResources
 
onChannel(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources
Callback for a Channel selection.
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.incubator.quic.QuicResources
 
onChannelClass(Class<CHANNEL>, EventLoopGroup) - Method in interface reactor.netty.resources.LoopResources
Callback for a Channel class 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.incubator.quic.QuicResources
 
onClient(boolean) - Method in interface reactor.netty.resources.LoopResources
Callback for client EventLoopGroup creation.
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(Disposable) - Method in class reactor.netty.channel.ChannelOperations
 
onDispose(Disposable) - Method in interface reactor.netty.Connection
 
onDispose() - Method in interface reactor.netty.DisposableChannel
Returns an observing Mono terminating with success when shutdown successfully or error.
onDispose(Disposable) - Method in interface reactor.netty.DisposableChannel
Assigns a Disposable to 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 inbound Channel.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 a Runnable to be invoked when reads have become idle for the given timeout.
onServer(boolean) - Method in class reactor.netty.incubator.quic.QuicResources
 
onServer(boolean) - Method in interface reactor.netty.resources.LoopResources
Callback for server EventLoopGroup creation, this is the EventLoopGroup for 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.incubator.quic.QuicResources
 
onServerSelect(boolean) - Method in interface reactor.netty.resources.LoopResources
Callback for server select EventLoopGroup creation, this is the EventLoopGroup for 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 a ChannelOperations has been terminated.
onTerminate() - Method in interface reactor.netty.Connection
Return a Mono succeeding when a Connection is 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 a Runnable to 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 the HttpClient.
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.
options() - Method in class reactor.netty.transport.TransportConfig
Return the read-only ChannelOption map.
outbound() - Method in class reactor.netty.channel.ChannelOperations
 
outbound() - Method in interface reactor.netty.Connection
Return the NettyOutbound write 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.incubator.quic.QuicClientConfig
 
parentChannelInitializer() - Method in class reactor.netty.incubator.quic.QuicServerConfig
 
parseAddress(String, int) - Static method in class reactor.netty.transport.AddressUtils
Parse unresolved InetSocketAddress.
parseAddress(String, int, boolean) - Static method in class reactor.netty.transport.AddressUtils
Parse unresolved InetSocketAddress.
parseHttpAfterConnectRequest(boolean) - Method in class reactor.netty.http.client.HttpResponseDecoderSpec
Configure whether the HTTP decoding will continue even after HTTP CONNECT.
password(Function<? super String, ? extends String>) - Method in interface reactor.netty.transport.ProxyProvider.Builder
A function to supply the proxy's password from the username.
patch() - Method in class reactor.netty.http.client.HttpClient
HTTP PATCH to connect the HttpClient.
path() - Method in interface reactor.netty.DisposableServer
Returns the server's path to the domain socket.
path() - Method in interface reactor.netty.http.HttpInfos
Returns the decoded path portion from the HttpInfos.uri() without the leading and trailing '/' if present.
PENDING_CONNECTIONS - Static variable in class reactor.netty.Metrics
The number of requests that are waiting for a connection.
PENDING_STREAMS - Static variable in class reactor.netty.Metrics
The number of requests that are waiting for opening HTTP/2 stream.
PENDING_TASKS - Static variable in class reactor.netty.Metrics
The number of tasks that are pending for processing on an event loop.
pendingAcquireMaxCount(int) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider the maximum number of registered requests for acquire to keep in a pending queue When invoked with -1 the pending queue will not have upper limit.
pendingAcquireSize() - Method in interface reactor.netty.resources.ConnectionPoolMetrics
Measure the current number of "pending" acquire Monos in the Pool.
pendingAcquireTimeout(Duration) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the options to use for configuring ConnectionProvider acquire timeout (resolution: ms).
pendingAcquireTimer(BiFunction<Runnable, Duration, Disposable>) - Method in class reactor.netty.resources.ConnectionProvider.ConnectionPoolSpec
Set the option to use for configuring ConnectionProvider pending 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 and Integer.MAX_VALUE.
permitMaximum() - Method in class reactor.netty.http.client.Http2AllocationStrategy
 
permitMaximum() - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
Returns the maximum number of permits this strategy can grant in total, or Integer.MAX_VALUE for unbounded.
permitMinimum() - Method in class reactor.netty.http.client.Http2AllocationStrategy
 
permitMinimum() - Method in interface reactor.netty.resources.ConnectionProvider.AllocationStrategy
Return the minimum number of permits this strategy tries to maintain granted (reflecting a minimal size for the pool), or 0 for scale-to-zero.
POOL_ACQUIRE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
Default acquisition timeout (milliseconds) before error.
POOL_GET_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty
Default getPermitsSamplingRate (between 0d and 1d (percentage)) to be used with a SamplingAllocationStrategy.
POOL_LEASING_STRATEGY - Static variable in class reactor.netty.ReactorNetty
Default leasing strategy (fifo, lifo), fallback to fifo.
POOL_MAX_CONNECTIONS - Static variable in class reactor.netty.ReactorNetty
Default max connections.
POOL_MAX_IDLE_TIME - Static variable in class reactor.netty.ReactorNetty
Default max idle time, fallback - max idle time is not specified.
POOL_MAX_LIFE_TIME - Static variable in class reactor.netty.ReactorNetty
Default max life time, fallback - max life time is not specified.
POOL_RETURN_PERMITS_SAMPLING_RATE - Static variable in class reactor.netty.ReactorNetty
Default returnPermitsSamplingRate (between 0d and 1d (percentage)) to be used with a SamplingAllocationStrategy.
PooledConnectionProvider<T extends Connection> - Class in reactor.netty.resources
Base ConnectionProvider implementation.
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
 
port(int) - Method in class reactor.netty.http.server.HttpServer
 
port(int) - Method in class reactor.netty.incubator.quic.QuicClient
The port to which this client should connect.
port(int) - Method in class reactor.netty.incubator.quic.QuicServer
The port to which this server should bind.
port(int) - Method in class reactor.netty.tcp.TcpClient
 
port(int) - Method in class reactor.netty.tcp.TcpServer
 
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
 
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 the HttpClient.
post(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
Listens for HTTP POST on the passed path to be used as a routing condition.
PostHeadersNettyOutbound(Mono<Void>, HttpOperations<?, ?>, ByteBuf) - Constructor for class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
PREDICATE_GROUP_FLUSH - Static variable in class reactor.netty.ReactorNetty
 
PrematureCloseException - Exception in reactor.netty.http.client
An error for signalling that the connection was closed prematurely ChannelInboundHandler.channelInactive(io.netty.channel.ChannelHandlerContext), ChannelOperations.onInboundClose(), ChannelOperations#onInboundError().
protocol() - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
protocol(HttpProtocol...) - Method in class reactor.netty.http.client.HttpClient
The HTTP protocol to support.
protocol() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
Returns the protocol version, (e.g.
protocol(HttpProtocol...) - Method in class reactor.netty.http.server.HttpServer
The HTTP protocol to support.
protocol() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns the inbound protocol and version.
protocol() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the protocol version, (e.g.
protocols() - Method in class reactor.netty.http.client.HttpClientConfig
Return the HTTP protocol to support.
protocols() - Method in class reactor.netty.http.server.HttpServerConfig
Return the HTTP protocol to support.
protocols(String) - Method in class reactor.netty.http.websocket.WebsocketSpec.Builder
Sets sub-protocol to use in websocket handshake signature.
protocols() - Method in interface reactor.netty.http.websocket.WebsocketSpec
Returns the configured sub protocols.
protocols() - Method in class reactor.netty.http.websocket.WebsocketSpecImpl
 
proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.tcp.TcpClient
 
proxy(Consumer<? super ProxyProvider.TypeSpec>) - Method in class reactor.netty.transport.ClientTransport
Apply a proxy configuration.
ProxyHandler - Static variable in interface reactor.netty.NettyPipeline
 
ProxyLoggingHandler - Static variable in interface reactor.netty.NettyPipeline
 
proxyProtocol(ProxyProtocolSupportType) - Method in class reactor.netty.http.server.HttpServer
Specifies whether support for the "HAProxy proxy protocol" for deriving information about the address of the remote peer is enabled.
ProxyProtocolDecoder - Static variable in interface reactor.netty.NettyPipeline
 
ProxyProtocolReader - Static variable in interface reactor.netty.NettyPipeline
 
proxyProtocolSupportType() - Method in class reactor.netty.http.server.HttpServerConfig
Return the supported type for the "HAProxy proxy protocol".
ProxyProtocolSupportType - Enum in reactor.netty.http.server
Proxy protocol support type, this enum class defines how the HttpServer handles proxy protocol.
proxyProvider(ProxyProvider) - Method in class reactor.netty.http.client.HttpClientConfig
 
proxyProvider() - Method in class reactor.netty.transport.ClientTransportConfig
Return the ProxyProvider if any or null.
proxyProvider(ProxyProvider) - Method in class reactor.netty.transport.ClientTransportConfig
 
ProxyProvider - Class in reactor.netty.transport
Proxy configuration.
ProxyProvider.AddressSpec - Interface in reactor.netty.transport
 
ProxyProvider.Builder - Interface in reactor.netty.transport
 
ProxyProvider.Proxy - Enum in reactor.netty.transport
Proxy Type.
ProxyProvider.TypeSpec - Interface in reactor.netty.transport
 
proxyWithSystemProperties() - Method in class reactor.netty.transport.ClientTransport
Set up a proxy from the java system properties.
pushEnabled() - Method in class reactor.netty.http.Http2SettingsSpec
Returns the configured SETTINGS_ENABLE_PUSH value or null.
put() - Method in class reactor.netty.http.client.HttpClient
HTTP PUT to connect the HttpClient.
put(String, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
Listens for HTTP PUT on the passed path to be used as a routing condition.

Q

queryTimeout(Duration) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Sets the timeout of each DNS query performed by this resolver (resolution: milliseconds).
queryTimeout() - Method in class reactor.netty.transport.NameResolverProvider
Returns the configured timeout of each DNS query performed by this resolver.
QUIC_CLIENT_PREFIX - Static variable in class reactor.netty.incubator.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.incubator.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.incubator.quic
A QuicClient allows building in a safe immutable way a QUIC client that is materialized and connecting when QuicClient.connect() is ultimately called.
QuicClient() - Constructor for class reactor.netty.incubator.quic.QuicClient
 
QuicClientConfig - Class in reactor.netty.incubator.quic
Encapsulate all necessary configuration for QUIC client transport.
QuicConnection - Interface in reactor.netty.incubator.quic
API for creating and handling streams.
QuicInbound - Interface in reactor.netty.incubator.quic
An inbound-traffic API delegating to an underlying Channel.
QuicInitialSettingsSpec - Class in reactor.netty.incubator.quic
A configuration builder to fine tune the QUIC initial settings.
QuicInitialSettingsSpec.Builder - Interface in reactor.netty.incubator.quic
 
QuicOutbound - Interface in reactor.netty.incubator.quic
An outbound-traffic API delegating to an underlying Channel.
QuicResources - Class in reactor.netty.incubator.quic
Hold the default QUIC resources.
QuicResources(LoopResources) - Constructor for class reactor.netty.incubator.quic.QuicResources
 
QuicServer - Class in reactor.netty.incubator.quic
A QuicServer allows building in a safe immutable way a QUIC server that is materialized and bound when QuicServer.bind() is ultimately called.
QuicServer() - Constructor for class reactor.netty.incubator.quic.QuicServer
 
QuicServerConfig - Class in reactor.netty.incubator.quic
Encapsulate all necessary configuration for QUIC server transport.
QuicStreamInfo - Interface in reactor.netty.incubator.quic
Exposes information for the QuicStreamChannel as stream id etc.

R

ReactiveBridge - Static variable in interface reactor.netty.NettyPipeline
 
reactor.netty - package reactor.netty
Main Reactor Netty Contracts used by all client and server implementations.
reactor.netty.channel - package reactor.netty.channel
Netty <-> Reactive Streams bridge via channel handler.
reactor.netty.contextpropagation - package reactor.netty.contextpropagation
This package contains context propagation utilities.
reactor.netty.http - package reactor.netty.http
Common components for writing HTTP-based clients and servers using Reactor abstractions.
reactor.netty.http.client - package reactor.netty.http.client
Http Client abstractions and factory.
reactor.netty.http.logging - package reactor.netty.http.logging
Http message log factory.
reactor.netty.http.observability - package reactor.netty.http.observability
This package contains tracing observation handlers for HttpClient and HttpServer.
reactor.netty.http.server - package reactor.netty.http.server
Http Server abstractions and factory.
reactor.netty.http.server.logging - package reactor.netty.http.server.logging
Http access log.
reactor.netty.http.websocket - package reactor.netty.http.websocket
Common components for Websocket using Reactor abstractions.
reactor.netty.incubator.quic - package reactor.netty.incubator.quic
Components for writing QUIC-based clients and servers using Reactor abstractions.
reactor.netty.internal.util - package reactor.netty.internal.util
Reactor Netty internal utilities.
reactor.netty.observability - package reactor.netty.observability
This package contains core tracing observation handlers.
reactor.netty.resources - package reactor.netty.resources
Contracts for managing connections via ConnectionProvider and event-loop resources via LoopResources.
reactor.netty.tcp - package reactor.netty.tcp
Components for writing TCP-based clients and servers using Reactor abstractions.
reactor.netty.transport - package reactor.netty.transport
Transport builders for clients and servers.
reactor.netty.transport.logging - package reactor.netty.transport.logging
Reactor Netty LoggingHandler implementation.
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 given HttpMessageArgProvider.
ReactorNettyHttpMessageLogFactory() - Constructor for class reactor.netty.http.logging.ReactorNettyHttpMessageLogFactory
 
ReactorNettyPropagatingReceiverTracingObservationHandler - Class in reactor.netty.http.observability
Reactor Netty specific PropagatingReceiverTracingObservationHandler.
ReactorNettyPropagatingReceiverTracingObservationHandler(Tracer, Propagator) - Constructor for class reactor.netty.http.observability.ReactorNettyPropagatingReceiverTracingObservationHandler
ReactorNettyPropagatingSenderTracingObservationHandler - Class in reactor.netty.http.observability
Reactor Netty specific PropagatingSenderTracingObservationHandler.
ReactorNettyPropagatingSenderTracingObservationHandler(Tracer, Propagator) - Constructor for class reactor.netty.http.observability.ReactorNettyPropagatingSenderTracingObservationHandler
ReactorNettyTimerObservationHandler - Class in reactor.netty.observability
Reactor Netty timer observation handler.
ReactorNettyTimerObservationHandler(MeterRegistry) - Constructor for class reactor.netty.observability.ReactorNettyTimerObservationHandler
 
ReactorNettyTracingObservationHandler - Class in reactor.netty.observability
Abstraction over all Reactor Netty handlers.
ReactorNettyTracingObservationHandler(Tracer) - Constructor for class reactor.netty.observability.ReactorNettyTracingObservationHandler
 
readableType() - Method in class reactor.netty.contextpropagation.ChannelContextAccessor
 
readTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer
Specifies the maximum duration allowed between each network-level read operation while reading a given request content (resolution: ms).
readTimeout() - Method in class reactor.netty.http.server.HttpServerConfig
Return the configured read timeout for the request or null.
ReadTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
 
readValue(Channel, Object) - Method in class reactor.netty.contextpropagation.ChannelContextAccessor
 
readValues(Channel, Predicate<Object>, Map<Object, Object>) - Method in class reactor.netty.contextpropagation.ChannelContextAccessor
 
rebind(Connection) - Method in interface reactor.netty.Connection
Bind a new Connection reference or null to the channel attributes only if this instance is currently bound.
receive() - Method in class reactor.netty.channel.ChannelOperations
 
receive() - Method in interface reactor.netty.http.client.HttpClient.WebsocketReceiver
Negotiate a websocket upgrade and extract a flux from the underlying WebsocketInbound.
receive() - Method in interface reactor.netty.NettyInbound
A Flux extension that allows for extra decoding operators.
receiveCloseStatus() - Method in interface reactor.netty.http.websocket.WebsocketInbound
Receive the close status code and reason if sent by the remote peer, or empty if the connection completes otherwise.
receiveContent() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns a Flux of HttpContent containing received chunks.
receiveForm() - Method in interface reactor.netty.http.server.HttpServerRequest
When the request is POST and have Content-Type with value application/x-www-form-urlencoded or multipart/form-data, returns a Flux of HttpData containing received Attribute/FileUpload.
receiveForm(Consumer<HttpServerFormDecoderProvider.Builder>) - Method in interface reactor.netty.http.server.HttpServerRequest
When the request is POST and have Content-Type with value application/x-www-form-urlencoded or multipart/form-data, returns a Flux of HttpData containing received Attribute/FileUpload.
receiveFrames() - Method in interface reactor.netty.http.websocket.WebsocketInbound
Receive a Flux of WebSocketFrame formed frame content.
receiveObject() - Method in class reactor.netty.channel.ChannelOperations
 
receiveObject() - Method in interface reactor.netty.NettyInbound
a Object inbound Flux.
recordConnectTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the time that is spent for connecting to the remote address.
recordConnectTime(ContextView, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
Records the time that is spent for connecting to the remote address.
recordConnectTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
 
recordConnectTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordDataReceived(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the amount of the data that is received, in bytes.
recordDataReceived(ContextView, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
Records the amount of the data that is received, in bytes.
recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
 
recordDataReceived(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordDataReceived(ContextView, SocketAddress, String, long) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
Records the amount of the data that is received, in bytes.
recordDataReceived(SocketAddress, String, long) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
 
recordDataReceived(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder
Records the amount of the data that is received, in bytes.
recordDataReceived(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
recordDataReceivedTime(ContextView, SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
Records the time that is spent in consuming incoming data.
recordDataReceivedTime(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(ContextView, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
Records the time that is spent in consuming incoming data.
recordDataReceivedTime(String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
 
recordDataReceivedTime(String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Records the time that is spent in consuming incoming data.
recordDataSent(SocketAddress, long) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the amount of the data that is sent, in bytes.
recordDataSent(ContextView, SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
Records the amount of the data that is sent, in bytes.
recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
 
recordDataSent(SocketAddress, long) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordDataSent(ContextView, SocketAddress, String, long) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
Records the amount of the data that is sent, in bytes.
recordDataSent(SocketAddress, String, long) - Method in class reactor.netty.http.ContextAwareHttpMetricsRecorder
 
recordDataSent(SocketAddress, String, long) - Method in interface reactor.netty.http.HttpMetricsRecorder
Records the amount of the data that is sent, in bytes.
recordDataSent(SocketAddress, String, long) - Method in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
recordDataSentTime(ContextView, SocketAddress, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
Records the time that is spent in sending outgoing data.
recordDataSentTime(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(ContextView, String, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
Records the time that is spent in sending outgoing data.
recordDataSentTime(String, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
 
recordDataSentTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Records the time that is spent in sending outgoing data.
recorder() - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
recorder() - Method in class reactor.netty.channel.ChannelMetricsHandler
 
recorder() - Method in class reactor.netty.channel.MicrometerChannelMetricsHandler
 
recordException(ChannelHandlerContext, SocketAddress) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
recordRead(ChannelHandlerContext, SocketAddress, long) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
recordResolveAddressTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the time that is spent for resolving the remote address.
recordResolveAddressTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordResponseTime(ContextView, SocketAddress, String, String, String, Duration) - Method in class reactor.netty.http.client.ContextAwareHttpClientMetricsRecorder
Records the total time for the request/response.
recordResponseTime(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(ContextView, String, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
Records the total time for the request/response.
recordResponseTime(String, String, String, Duration) - Method in class reactor.netty.http.server.ContextAwareHttpServerMetricsRecorder
 
recordResponseTime(String, String, String, Duration) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Records the total time for the request/response.
recordServerConnectionActive(SocketAddress) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Record a new active in-use http connection.
recordServerConnectionClosed(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records a just disconnected server connection.
recordServerConnectionClosed(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordServerConnectionInactive(SocketAddress) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Record an inactive http connection.
recordServerConnectionOpened(SocketAddress) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records a just accepted server connection.
recordServerConnectionOpened(SocketAddress) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordStreamClosed(SocketAddress) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Record a closed HTTP/2 stream.
recordStreamOpened(SocketAddress) - Method in interface reactor.netty.http.server.HttpServerMetricsRecorder
Record an opened HTTP/2 stream.
recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in interface reactor.netty.channel.ChannelMetricsRecorder
Records the time that is spent for TLS handshake.
recordTlsHandshakeTime(ContextView, SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
Records the time that is spent for TLS handshake.
recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.ContextAwareChannelMetricsRecorder
 
recordTlsHandshakeTime(SocketAddress, Duration, String) - Method in class reactor.netty.channel.MicrometerChannelMetricsRecorder
 
recordWrite(ChannelHandlerContext, SocketAddress, long) - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
redirectedFrom() - Method in interface reactor.netty.http.client.HttpClientInfos
Return the previous redirections or empty array.
redirectHttpToHttps() - Method in class reactor.netty.http.server.HttpServerConfig
Returns true if that HttpServer will redirect HTTP to HTTPS by changing the scheme only but otherwise leaving the port the same when SSL is enabled.
redirectRequestBiConsumer() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured redirect request BiConsumer or null.
redirectRequestConsumer() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured redirect request consumer or null.
registerDefaultMetrics(String, SocketAddress, InstrumentedPool.PoolMetrics) - Method in class reactor.netty.resources.PooledConnectionProvider
 
registerMetrics(String, String, SocketAddress, ConnectionPoolMetrics) - Method in interface reactor.netty.resources.ConnectionProvider.MeterRegistrar
Invoked when a connection pool is created.
REGISTRY - Static variable in class reactor.netty.Metrics
 
RELEASED - Static variable in interface reactor.netty.ConnectionObserver.State
Propagated when a connection has been released but not fully closed (keep-alive or pooling)
releaseTimestamp() - Method in interface reactor.netty.resources.ConnectionProvider.ConnectionMetadata
Returns a timestamp that denotes the order in which the connection was last released, to millisecond precision.
REMOTE_ADDRESS - Static variable in class reactor.netty.Metrics
 
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.http.client.HttpClient
 
remoteAddress() - Method in interface reactor.netty.http.server.ConnectionInformation
Returns the address of the client that initiated the request, possibly null in case of Unix Domain Sockets.
remoteAddress() - Method in interface reactor.netty.http.server.HttpServerRequest
 
remoteAddress() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.incubator.quic.QuicClient
The address to which this client should connect on each subscribe.
remoteAddress() - Method in class reactor.netty.incubator.quic.QuicClientConfig
Return the remote configured SocketAddress.
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.tcp.TcpClient
 
remoteAddress(Supplier<? extends SocketAddress>) - Method in class reactor.netty.transport.ClientTransport
The address to which this client should connect on each subscribe.
remoteAddress() - Method in class reactor.netty.transport.ClientTransportConfig
Return the remote configured SocketAddress.
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 use HttpServerRoutes.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 the HttpClient.
requestHeader(CharSequence) - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the value of a request header with the specified name or null is case such request header does not exist.
requestHeaders() - Method in interface reactor.netty.http.client.HttpClientInfos
Return outbound headers to be sent.
requestHeaders() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns inbound HttpHeaders.
requestId() - Method in interface reactor.netty.http.HttpInfos
Return a unique id for the request.
requestId() - Method in class reactor.netty.http.HttpOperations
 
requestTimeout(Duration) - Method in class reactor.netty.http.server.HttpServer
Specifies the maximum duration for reading a given request content (resolution: ms).
requestTimeout() - Method in class reactor.netty.http.server.HttpServerConfig
Return the configured request timeout for the request or null.
reset() - Static method in class reactor.netty.http.HttpResources
Reset http resources to default and return its instance.
reset() - Static method in class reactor.netty.incubator.quic.QuicResources
Reset QUIC resources to default and return its instance.
reset() - Static method in class reactor.netty.tcp.TcpResources
Reset TCP resources to default and return its instance.
reset() - Static method in class reactor.netty.udp.UdpResources
Reset UDP resources to default and return its instance.
resolveCache(DnsCache) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Sets the resolve cache to use for DNS resolution.
resolveCache() - Method in class reactor.netty.transport.NameResolverProvider
Returns the configured DNS resolver cache or null.
resolvedAddressTypes(ResolvedAddressTypes) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Sets the list of the protocol families of the address resolved.
resolvedAddressTypes() - Method in class reactor.netty.transport.NameResolverProvider
Returns the configured list of the protocol families of the address resolved or null.
resolvePath(String) - Static method in class reactor.netty.http.HttpOperations
Returns the decoded path portion from the provided uri.
resolver(AddressResolverGroup<?>) - Method in class reactor.netty.tcp.TcpClient
 
resolver(AddressResolverGroup<?>) - Method in class reactor.netty.transport.ClientTransport
resolver(Consumer<NameResolverProvider.NameResolverSpec>) - Method in class reactor.netty.transport.ClientTransport
Apply a name resolver configuration.
resolver() - Method in class reactor.netty.transport.ClientTransportConfig
Return the configured AddressResolverGroup or null.
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 as HttpClientResponse
response(BiFunction<? super HttpClientResponse, ? super ByteBufFlux, ? extends Publisher<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
Extract a response flux from the given HttpClientResponse and body ByteBufFlux.
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 given HttpClientResponse and underlying Connection.
responseContent() - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
Return the response body chunks as ByteBufFlux.
responseHeader(CharSequence) - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the value of a response header with the specified name or null is case such response header does not exist.
responseHeaders() - Method in interface reactor.netty.http.client.HttpClientResponse
Return response HTTP headers.
responseHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse
Returns the outbound HTTP headers, sent back to the clients.
responseSingle(BiFunction<? super HttpClientResponse, ? super ByteBufMono, ? extends Mono<V>>) - Method in interface reactor.netty.http.client.HttpClient.ResponseReceiver
Extract a response mono from the given HttpClientResponse and aggregated body ByteBufMono.
responseTimeCache - Variable in class reactor.netty.http.MicrometerHttpMetricsRecorder
 
responseTimeout(Duration) - Method in class reactor.netty.http.client.HttpClient
Specifies the maximum duration allowed between each network-level read operation while reading a given response (resolution: ms).
responseTimeout() - Method in class reactor.netty.http.client.HttpClientConfig
Return the configured response timeout or null.
responseTimeout(Duration) - Method in interface reactor.netty.http.client.HttpClientRequest
Specifies the maximum duration allowed between each network-level read operation while reading a given response (resolution: ms).
ResponseTimeoutHandler - Static variable in interface reactor.netty.NettyPipeline
 
retain() - Method in class reactor.netty.ByteBufFlux
Disable auto memory release on each buffer published, retaining in order to prevent premature recycling when buffers are accumulated downstream (async).
retain() - Method in class reactor.netty.ByteBufMono
Disable auto memory release on each signal published in order to prevent premature recycling when buffers are accumulated downstream (async).
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 an AddressResolverGroup of DnsNameResolvers 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 provided HttpServerRoutes builder.
route(Predicate<? super HttpServerRequest>, BiFunction<? super HttpServerRequest, ? super HttpServerResponse, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerRoutes
A generic route predicate that if matched invoke the passed I/O handler.
run() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpClient
 
runOn(LoopResources) - Method in class reactor.netty.tcp.TcpClient
 
runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpClient
 
runOn(EventLoopGroup) - Method in class reactor.netty.tcp.TcpServer
 
runOn(LoopResources) - Method in class reactor.netty.tcp.TcpServer
 
runOn(LoopResources, boolean) - Method in class reactor.netty.tcp.TcpServer
 
runOn(LoopResources, boolean) - Method in class reactor.netty.transport.ClientTransport
 
runOn(EventLoopGroup) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Performs the communication with the DNS servers on the given EventLoopGroup.
runOn(LoopResources) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Performs the communication with the DNS servers on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Performs the communication with the DNS servers on a supplied EventLoopGroup from the LoopResources container.
runOn(EventLoopGroup) - Method in class reactor.netty.transport.Transport
Run IO loops on the given EventLoopGroup.
runOn(LoopResources) - Method in class reactor.netty.transport.Transport
Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, boolean) - Method in class reactor.netty.transport.Transport
Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpClient
 
runOn(LoopResources) - Method in class reactor.netty.udp.UdpClient
 
runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpClient
Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpClient
Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(EventLoopGroup) - Method in class reactor.netty.udp.UdpServer
 
runOn(LoopResources) - Method in class reactor.netty.udp.UdpServer
 
runOn(LoopResources, boolean) - Method in class reactor.netty.udp.UdpServer
Run IO loops on a supplied EventLoopGroup from the LoopResources container.
runOn(LoopResources, InternetProtocolFamily) - Method in class reactor.netty.udp.UdpServer
Run IO loops on a supplied EventLoopGroup from the LoopResources container.

S

safeRelease(Object) - Static method in class reactor.netty.ReactorNetty
Try to call ReferenceCounted.release() if the specified message implements ReferenceCounted.
scheduler(Scheduler) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
Sets the scheduler to be used for offloading disk operations in the decoding phase.
scheduler() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
Returns the configured scheduler to be used for offloading disk operations in the decoding phase.
scheme() - Method in interface reactor.netty.http.server.ConnectionInformation
Returns the current protocol scheme.
searchDomains(List<String>) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Sets the list of search domains of the resolver.
searchDomains() - Method in class reactor.netty.transport.NameResolverProvider
Returns the configured list of search domains of the resolver or null.
secure() - Method in class reactor.netty.http.client.HttpClient
Enable default sslContext support.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.client.HttpClient
Apply an SSL configuration customization via the passed builder.
secure(SslProvider) - Method in class reactor.netty.http.client.HttpClient
Apply an SSL configuration via the passed SslProvider.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.http.server.HttpServer
Apply an SSL configuration customization via the passed builder.
secure(Consumer<? super SslProvider.SslContextSpec>, boolean) - Method in class reactor.netty.http.server.HttpServer
Apply an SSL configuration customization via the passed builder.
secure(SslProvider) - Method in class reactor.netty.http.server.HttpServer
Applies an SSL configuration via the passed SslProvider.
secure(SslProvider, boolean) - Method in class reactor.netty.http.server.HttpServer
Applies an SSL configuration via the passed SslProvider.
secure() - Method in class reactor.netty.tcp.TcpClient
Enable default sslContext support.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpClient
Apply an SSL configuration customization via the passed builder.
secure(SslProvider) - Method in class reactor.netty.tcp.TcpClient
Apply an SSL configuration via the passed SslProvider.
secure(Consumer<? super SslProvider.SslContextSpec>) - Method in class reactor.netty.tcp.TcpServer
Apply an SSL configuration customization via the passed builder.
secure(SslProvider) - Method in class reactor.netty.tcp.TcpServer
Applies an SSL configuration via the passed SslProvider.
selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketInbound
Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or null if none was requested.
selectedSubprotocol() - Method in interface reactor.netty.http.websocket.WebsocketOutbound
Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or null if none was requested.
send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.channel.ChannelOperations
 
send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
Configure a body to send on request.
send(BiFunction<? super HttpClientRequest, ? super NettyOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
Configure a body to send on request using the NettyOutbound sending builder and returning a Publisher to signal end of the request.
send(Function<? super HttpClientRequest, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.client.HttpClient.WebsocketSender
Configure headers to send on request using the returned Publisher to signal end of the request.
send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
send(Publisher<? extends ByteBuf>) - Method in class reactor.netty.http.HttpOperations
 
send() - Method in interface reactor.netty.http.server.HttpServerResponse
Sends the HTTP headers and empty content thus delimiting a full empty body http response.
send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
 
send(Publisher<? extends ByteBuf>) - Method in interface reactor.netty.NettyOutbound
Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
send(Publisher<? extends ByteBuf>, Predicate<ByteBuf>) - Method in interface reactor.netty.NettyOutbound
Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendByteArray(Publisher<? extends byte[]>) - Method in interface reactor.netty.NettyOutbound
Sends bytes to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendClose() - Method in interface reactor.netty.http.websocket.WebsocketOutbound
Prepare to send a close frame on subscribe then close the underlying channel.
sendClose(int) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
Prepare to send a close frame on subscribe then close the underlying channel.
sendClose(int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
Prepare to send a close frame on subscribe then close the underlying channel.
sendClose(int, int, String) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
Prepare to send a close frame on subscribe then close the underlying channel.
sendFile(Path, long, long) - Method in class reactor.netty.http.HttpOperations
 
sendFile(Path) - Method in interface reactor.netty.NettyOutbound
Sends content from given Path using FileChannel.transferTo(long, long, WritableByteChannel) support.
sendFile(Path, long, long) - Method in interface reactor.netty.NettyOutbound
Sends content from the given Path using FileChannel.transferTo(long, long, WritableByteChannel) support, if the system supports it, the path resolves to a local file system File, 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 given Path using chunked read/write.
sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
Prepare to send an HTTP Form including Multipart encoded Form which support chunked file upload.
sendForm(BiConsumer<? super HttpClientRequest, HttpClientForm>, Consumer<Flux<Long>>) - Method in interface reactor.netty.http.client.HttpClient.RequestSender
Prepare to send an HTTP Form including Multipart encoded Form which support chunked file upload.
sendGroups(Publisher<? extends Publisher<? extends ByteBuf>>) - Method in interface reactor.netty.NettyOutbound
Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendHeaders() - Method in interface reactor.netty.http.server.HttpServerResponse
Returns a NettyOutbound successful on committed response.
sendNotFound() - Method in interface reactor.netty.http.server.HttpServerResponse
sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.channel.ChannelOperations
 
sendObject(Object) - Method in class reactor.netty.channel.ChannelOperations
 
sendObject(Publisher<?>, Predicate<Object>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
sendObject(Object) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
sendObject(Object) - Method in class reactor.netty.http.HttpOperations
 
sendObject(Publisher<?>) - Method in interface reactor.netty.NettyOutbound
Sends an object through Netty pipeline.
sendObject(Publisher<?>, Predicate<Object>) - Method in interface reactor.netty.NettyOutbound
Sends an object through Netty pipeline.
sendObject(Object) - Method in interface reactor.netty.NettyOutbound
Sends data to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendRedirect(String) - Method in interface reactor.netty.http.server.HttpServerResponse
Sends redirect status HttpResponseStatus.FOUND along with a location header to the remote client.
sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.http.websocket.WebsocketOutbound
 
sendString(Publisher<? extends String>) - Method in interface reactor.netty.NettyOutbound
Sends String to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendString(Publisher<? extends String>, Charset) - Method in interface reactor.netty.NettyOutbound
Sends String to the peer, listens for any error on write and closes on terminal signal (complete|error).
sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in class reactor.netty.channel.ChannelOperations
 
sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
sendUsing(Callable<? extends S>, BiFunction<? super Connection, ? super S, ?>, Consumer<? super S>) - Method in interface reactor.netty.NettyOutbound
Binds a send to a starting/cleanup lifecycle
sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>) - Method in interface reactor.netty.http.server.HttpServerResponse
Upgrades the connection to websocket.
sendWebsocket(BiFunction<? super WebsocketInbound, ? super WebsocketOutbound, ? extends Publisher<Void>>, WebsocketServerSpec) - Method in interface reactor.netty.http.server.HttpServerResponse
Upgrades the connection to websocket.
ServerCookies - Class in reactor.netty.http.server
Cookies holder from server request headers.
serverNames(SNIServerName...) - Method in interface reactor.netty.tcp.SslProvider.Builder
Sets the desired SNIServerNames.
ServerTransport<T extends ServerTransport<T,CONF>,CONF extends ServerTransportConfig<CONF>> - Class in reactor.netty.transport
A generic server Transport that will ServerTransport.bind() to a local address and provide a DisposableServer.
ServerTransport() - Constructor for class reactor.netty.transport.ServerTransport
 
ServerTransportConfig<CONF extends TransportConfig> - Class in reactor.netty.transport
Encapsulate all necessary configuration for server transport.
ServerTransportConfig(Map<ChannelOption<?>, ?>, Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.ServerTransportConfig
Default ServerTransportConfig with options.
ServerTransportConfig(ServerTransportConfig<CONF>) - Constructor for class reactor.netty.transport.ServerTransportConfig
 
set(ConnectionProvider) - Static method in class reactor.netty.http.HttpResources
Update pooling resources and return the global HTTP/1.x resources.
set(LoopResources) - Static method in class reactor.netty.http.HttpResources
Update event loops resources and return the global HTTP/1.x resources.
set(LoopResources) - Static method in class reactor.netty.incubator.quic.QuicResources
Update event loops resources and return the global QUIC resources.
set(ConnectionProvider) - Static method in class reactor.netty.tcp.TcpResources
Update pooling resources and return the global TCP resources.
set(LoopResources) - Static method in class reactor.netty.tcp.TcpResources
Update event loops resources and return the global TCP resources.
set(LoopResources) - Static method in class reactor.netty.udp.UdpResources
Update event loops resources and return the global UDP resources.
setChannelContext(Channel, ContextView) - Static method in class reactor.netty.ReactorNetty
Adds ContextView to the channel attributes.
setSniAsyncMappings(AsyncMapping<String, SslProvider>) - Method in interface reactor.netty.tcp.SslProvider.Builder
Sets the provided mappings of domain names to SslProvider.
setSniMappings(Map<String, Consumer<? super SslProvider.SslContextSpec>>) - Method in interface reactor.netty.tcp.SslProvider.Builder
Sets the provided mappings of domain names to SslProvider builders.
shouldProxy(SocketAddress) - Method in class reactor.netty.transport.ProxyProvider
Returns true when the given SocketAddress should be reached via the configured proxy.
shutdown() - Static method in class reactor.netty.udp.UdpResources
Shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
SHUTDOWN_QUIET_PERIOD - Static variable in class reactor.netty.ReactorNetty
Default quiet period that guarantees that the disposal of the underlying LoopResources will not happen, fallback to 2 seconds.
SHUTDOWN_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
Default maximum amount of time to wait until the disposal of the underlying LoopResources regardless if a task was submitted during the quiet period, fallback to 15 seconds.
shutdownLater() - Static method in class reactor.netty.udp.UdpResources
Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
shutdownLater(Duration, Duration) - Static method in class reactor.netty.udp.UdpResources
Prepare to shutdown the global UdpResources without resetting them, effectively cleaning up associated resources without creating new ones.
SMALL_CACHE_SIZE - Static variable in class reactor.netty.Metrics
The size of the small cache.
sse() - Method in interface reactor.netty.http.server.HttpServerResponse
Adds "text/event-stream" content-type for Server-Sent Events.
SSL_CLIENT_DEBUG - Static variable in class reactor.netty.ReactorNetty
Default value whether the SSL debugging on the client side will be enabled/disabled, fallback to SSL debugging disabled.
SSL_HANDSHAKE_TIMEOUT - Static variable in class reactor.netty.ReactorNetty
Default SSL handshake timeout (milliseconds), fallback to 10 seconds.
SSL_SERVER_DEBUG - Static variable in class reactor.netty.ReactorNetty
Default value whether the SSL debugging on the server side will be enabled/disabled, fallback to SSL debugging disabled.
sslContext() - Method in class reactor.netty.tcp.AbstractProtocolSslContextSpec
 
sslContext() - Method in interface reactor.netty.tcp.SslProvider.ProtocolSslContextSpec
Create a new SslContext instance with the configured settings.
sslContext(SslProvider.ProtocolSslContextSpec) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
SslContext builder that provides, specific for the protocol, default configuration e.g.
sslContext(SslContext) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
The SslContext to set when configuring SSL.
sslContext(SslContextBuilder) - Method in interface reactor.netty.tcp.SslProvider.SslContextSpec
Deprecated.
as of 1.0.6. Prefer #sslContext(ProtocolSslContextSpec), where the default configuration is applied before any other custom configuration. This method will be removed in version 1.2.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 current SslProvider if that HttpClient secured via SSL transport or null.
sslProvider() - Method in class reactor.netty.http.server.HttpServerConfig
Returns the current SslProvider if that HttpServer secured via SSL transport or null.
SslProvider - Class in reactor.netty.tcp
SSL Provider.
sslProvider() - Method in class reactor.netty.tcp.TcpClientConfig
Return the current SslProvider if that TcpClient secured via SSL transport or null.
sslProvider() - Method in class reactor.netty.tcp.TcpServerConfig
Returns the current SslProvider if that TcpServer secured via SSL transport or null.
SslProvider.Builder - Interface in reactor.netty.tcp
 
SslProvider.DefaultConfigurationSpec - Interface in reactor.netty.tcp
Deprecated.
as of 1.0.6. Prefer SslProvider.SslContextSpec#sslContext(ProtocolSslContextSpec), where the default configuration is applied before any other custom configuration. This will be removed in version 1.2.0.
SslProvider.DefaultConfigurationType - Enum in reactor.netty.tcp
Deprecated.
as of 1.0.6. Prefer SslProvider.SslContextSpec#sslContext(ProtocolSslContextSpec), where the default configuration is applied before any other custom configuration. This will be removed in version 1.2.0.
SslProvider.ProtocolSslContextSpec - Interface in reactor.netty.tcp
SslContext builder that provides, specific for the protocol, default configuration.
SslProvider.SslContextSpec - Interface in reactor.netty.tcp
 
SslReader - Static variable in interface reactor.netty.NettyPipeline
 
status() - Method in interface reactor.netty.http.client.HttpClientResponse
Return the resolved HTTP Response Status.
status() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
Returns the response status, (e.g.
status() - Method in interface reactor.netty.http.server.HttpServerResponse
Returns the assigned HTTP status.
status(HttpResponseStatus) - Method in interface reactor.netty.http.server.HttpServerResponse
Sets an HTTP status to be sent along with the headers.
status(int) - Method in interface reactor.netty.http.server.HttpServerResponse
Sets an HTTP status to be sent along with the headers.
status() - Method in interface reactor.netty.http.server.logging.AccessLogArgProvider
Returns the response status, (e.g.
STATUS - Static variable in class reactor.netty.Metrics
 
streamId() - Method in interface reactor.netty.incubator.quic.QuicStreamInfo
The id of the stream.
streaming(boolean) - Method in interface reactor.netty.http.server.HttpServerFormDecoderProvider.Builder
When set to true, the data is streamed directly from the parsed input buffer stream, which means it is not stored either in memory or file.
streaming() - Method in class reactor.netty.http.server.HttpServerFormDecoderProvider
Returns whether the streaming mode is enabled.
STREAMS_ACTIVE - Static variable in class reactor.netty.Metrics
The number of active HTTP/2 streams.
streamType() - Method in interface reactor.netty.incubator.quic.QuicStreamInfo
Returns the QuicStreamType of the stream.
stringToWebsocketFrame - Static variable in interface reactor.netty.http.websocket.WebsocketOutbound
 
subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufFlux
 
subscribe(CoreSubscriber<? super ByteBuf>) - Method in class reactor.netty.ByteBufMono
 
subscribe(Subscriber<? super Void>) - Method in interface reactor.netty.NettyOutbound
Subscribes a Void subscriber to this outbound and trigger all eventual parent outbound send.
SUCCESS - Static variable in class reactor.netty.Metrics
 
supportsContext(Observation.Context) - Method in class reactor.netty.http.observability.ReactorNettyPropagatingReceiverTracingObservationHandler
 
supportsContext(Observation.Context) - Method in class reactor.netty.http.observability.ReactorNettyPropagatingSenderTracingObservationHandler
 
supportsContext(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTimerObservationHandler
 
supportsContext(Observation.Context) - Method in class reactor.netty.observability.ReactorNettyTracingObservationHandler
 

T

tagSpan(ReceiverContext<HttpRequest>, Span) - Method in class reactor.netty.http.observability.ReactorNettyPropagatingReceiverTracingObservationHandler
 
tagSpan(SenderContext<HttpRequest>, Span) - Method in class reactor.netty.http.observability.ReactorNettyPropagatingSenderTracingObservationHandler
 
tagSpan(Observation.Context, Span) - Method in class reactor.netty.observability.ReactorNettyTracingObservationHandler
 
TCP_CLIENT_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the TCP client's metrics registered in Micrometer's global registry.
TCP_SERVER_PREFIX - Static variable in class reactor.netty.Metrics
Name prefix that will be used for the TCP server's metrics registered in Micrometer's global registry.
TcpClient - Class in reactor.netty.tcp
A TcpClient allows building in a safe immutable way a TCP client that is materialized and connecting when TcpClient.connect() is ultimately called.
TcpClient() - Constructor for class reactor.netty.tcp.TcpClient
 
TcpClientConfig - Class in reactor.netty.tcp
Encapsulate all necessary configuration for TCP client transport.
tcpConfiguration(Function<? super TcpClient, ? extends TcpClient>) - Method in class reactor.netty.http.client.HttpClient
Deprecated.
Use the other methods exposed by HttpClient to 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 by HttpServer to 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 when ServerTransport.bind() is ultimately called.
TcpServer() - Constructor for class reactor.netty.tcp.TcpServer
 
TcpServerConfig - Class in reactor.netty.tcp
Encapsulate all necessary configuration for TCP server transport.
TcpSslContextSpec - Class in reactor.netty.tcp
SslContext builder that provides default configuration specific to TCP as follows: SslProvider will be set depending on OpenSsl.isAvailable() The default cipher suites will be used Application protocol negotiation configuration is disabled
terminate() - Method in class reactor.netty.channel.ChannelOperations
Final release/close (last packet).
TEST_EXCEPTION - Static variable in exception reactor.netty.http.client.PrematureCloseException
 
textFile(String, File) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP File Upload attribute for a text file.
textFile(String, InputStream) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP File Upload attribute for a text file.
textFile(String, File, String) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP File Upload attribute for a text file.
textFile(String, InputStream, String) - Method in interface reactor.netty.http.client.HttpClientForm
Add an HTTP File Upload attribute for a text file.
then(ChannelPipelineConfigurer) - Method in interface reactor.netty.ChannelPipelineConfigurer
Chain together another ChannelPipelineConfigurer.
then(ConnectionObserver) - Method in interface reactor.netty.ConnectionObserver
Chain together another ConnectionObserver.
then() - Method in class reactor.netty.http.HttpOperations.PostHeadersNettyOutbound
 
then() - Method in class reactor.netty.http.HttpOperations
 
then() - Method in interface reactor.netty.NettyOutbound
Obtains a Mono of pending outbound(s) write completion.
then(Publisher<Void>) - Method in interface reactor.netty.NettyOutbound
Appends a Publisher task such as a Mono and returns a new NettyOutbound to sequence further send.
then(Publisher<Void>, Runnable) - Method in interface reactor.netty.NettyOutbound
Append a Publisher task such as a Mono and return a new NettyOutbound to sequence further send.
THREAD_LOCAL_CACHES - Static variable in class reactor.netty.Metrics
The number of thread local caches.
timestamp() - Method in interface reactor.netty.http.server.HttpServerRequest
Returns the time when the request was received.
TLS_HANDSHAKE_TIME - Static variable in class reactor.netty.Metrics
Time spent for TLS handshake.
tlsMetricsHandler() - Method in class reactor.netty.channel.AbstractChannelMetricsHandler
 
tlsMetricsHandler() - Method in class reactor.netty.channel.ChannelMetricsHandler
 
tlsMetricsHandler() - Method in class reactor.netty.channel.MicrometerChannelMetricsHandler
 
TlsMetricsHandler - Static variable in interface reactor.netty.NettyPipeline
 
tokenHandler(QuicTokenHandler) - Method in class reactor.netty.incubator.quic.QuicServer
Configure the QuicTokenHandler that is used to generate and validate tokens.
tokenHandler() - Method in class reactor.netty.incubator.quic.QuicServerConfig
Return the configured QuicTokenHandler or null.
toLoggingHandler(String, LogLevel, Charset) - Method in enum reactor.netty.transport.logging.AdvancedByteBufFormat
Creates the matching LoggingHandler regarding the format.
toPrettyHexDump(Object) - Static method in class reactor.netty.ReactorNetty
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(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 given HttpMessageArgProvider for a log with a level TRACE.
trace(String, LogLevel) - Method in interface reactor.netty.transport.NameResolverProvider.NameResolverSpec
Sets a specific category and log level to be used by this resolver when generating a detailed trace information in case of resolution failure.
trailerHeaders() - Method in interface reactor.netty.http.client.HttpClientResponse
Return response trailer headers.
trailerHeaders(Consumer<? super HttpHeaders>) - Method in interface reactor.netty.http.server.HttpServerResponse
Callback for setting outbound trailer headers.
trailingHeaders() - Method in interface reactor.netty.http.logging.HttpMessageArgProvider
Returns the request/response trailing headers.
Transport<T extends Transport<T,C>,C extends TransportConfig> - Class in reactor.netty.transport
An immutable transport builder for clients and servers.
Transport() - Constructor for class reactor.netty.transport.Transport
 
TransportConfig - Class in reactor.netty.transport
A basic configuration holder.
TransportConfig(Map<ChannelOption<?>, ?>) - Constructor for class reactor.netty.transport.TransportConfig
Default TransportConfig with options.
TransportConfig(Map<ChannelOption<?>, ?>, Supplier<? extends SocketAddress>) - Constructor for class reactor.netty.transport.TransportConfig
Default TransportConfig with options.
TransportConfig(TransportConfig) - Constructor for class reactor.netty.transport.TransportConfig
Create TransportConfig from an existing one.
TransportConnector - Class in reactor.netty.transport
TransportConnector is a helper class that creates, initializes and registers the channel.
TYPE - Static variable in class reactor.netty.Metrics
 
type(ProxyProvider.Proxy) - Method in interface reactor.netty.transport.ProxyProvider.TypeSpec
The proxy type.

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 when UdpClient.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 underlying Channel.
UdpOutbound - Interface in reactor.netty.udp
An outbound-traffic API delegating to an underlying Channel.
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 when UdpServer.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 support VoidChannelPromise.
updateChannelContext(Channel, Observation) - Static method in class reactor.netty.Metrics
Updates the ContextView in the channel attributes with this Observation.
updateContext(Context, Object) - Static method in class reactor.netty.Metrics
 
updateDefaultConfiguration(SslProvider, SslProvider.DefaultConfigurationType) - Static method in class reactor.netty.tcp.SslProvider
Deprecated.
as of 1.0.6. Prefer SslProvider.SslContextSpec#sslContext(ProtocolSslContextSpec), where the default configuration is applied before any other custom configuration. This will be removed in version 1.2.0.
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.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.
uri(String) - 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(URI) - Method in interface reactor.netty.http.client.HttpClient.UriConfiguration
Configure URI to use for this request/response.
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 - 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 with Metrics.URI tag.
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 with Metrics.URI tag.
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
 
username(String) - Method in interface reactor.netty.transport.ProxyProvider.Builder
The proxy username.

V

validateHeaders - Variable in class reactor.netty.http.HttpDecoderSpec
 
validateHeaders(boolean) - Method in class reactor.netty.http.HttpDecoderSpec
Configure whether to validate headers when decoding requests.
validateHeaders() - Method in class reactor.netty.http.HttpDecoderSpec
Return the configuration whether to validate headers when decoding requests.
valueOf(String) - Static method in enum reactor.netty.channel.ChannelMeters.ChannelMetersTags
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.channel.ChannelMeters.ConnectionsTotalMeterTags
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.channel.ChannelMeters
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.client.HttpClientState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.HttpProtocol
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.logging.HttpMessageType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.server.HttpServerState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.http.server.ProxyProtocolSupportType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType
Deprecated.
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.transport.logging.AdvancedByteBufFormat
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum reactor.netty.transport.ProxyProvider.Proxy
Returns the enum constant of this type with the specified name.
values() - Static method in enum reactor.netty.channel.ChannelMeters.ChannelMetersTags
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.channel.ChannelMeters.ConnectionsTotalMeterTags
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.channel.ChannelMeters
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.client.HttpClientState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.HttpProtocol
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.logging.HttpMessageType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.server.HttpServerState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.server.logging.AccessLogHandlerFactory
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.http.server.ProxyProtocolSupportType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.tcp.SslProvider.DefaultConfigurationType
Deprecated.
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.transport.logging.AdvancedByteBufFormat
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum reactor.netty.transport.ProxyProvider.Proxy
Returns an array containing the constants of this enum type, in the order they are declared.
version(WebSocketVersion) - Method in class reactor.netty.http.client.WebsocketClientSpec.Builder
Sets websocket version to use.
version() - Method in interface reactor.netty.http.client.WebsocketClientSpec
Returns the configured WebSocket version.
version() - Method in interface reactor.netty.http.HttpInfos
Returns the resolved request version (HTTP 1.1 etc).

W

warmup() - Method in class reactor.netty.http.client.HttpClient
Based on the actual configuration, returns a Mono that 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, the first request absorbs the extra time needed to load resources.
warmup() - Method in class reactor.netty.http.server.HttpServer
Based on the actual configuration, returns a Mono that 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, the bind operation absorbs the extra time needed to load resources.
warmup() - Method in class reactor.netty.tcp.TcpClient
Based on the actual configuration, returns a Mono that 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, the connect operation absorbs the extra time needed to load resources.
warmup() - Method in class reactor.netty.tcp.TcpServer
Based on the actual configuration, returns a Mono that 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, the bind operation absorbs the extra time needed to load resources.
warmup() - Method in class reactor.netty.transport.ClientTransport
Based on the actual configuration, returns a Mono that 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, the connect operation absorbs the extra time needed to initialize and load the resources.
warmup() - Method in class reactor.netty.transport.ServerTransport
Based on the actual configuration, returns a Mono that triggers: an initialization of the event loop groups loads the necessary native libraries for the transport By default, when method is not used, the bind operation absorbs the extra time needed to load resources.
warmup() - Method in class reactor.netty.udp.UdpServer
Based on the actual configuration, returns a Mono that triggers: an initialization of the event loop group loads the necessary native libraries for the transport By default, when method is not used, the bind operation absorbs 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 given HttpMessageArgProvider for a log with a level WARN.
websocket() - Method in class reactor.netty.http.client.HttpClient
HTTP Websocket to connect the HttpClient.
websocket(WebsocketClientSpec) - Method in class reactor.netty.http.client.HttpClient
HTTP Websocket to connect the HttpClient.
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 for WebsocketSpec.
WebsocketSpecImpl(WebsocketSpec.Builder<?>) - Constructor for class reactor.netty.http.websocket.WebsocketSpecImpl
 
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(String) - Method in class reactor.netty.tcp.TcpClient
 
wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpClient
 
wiretap(boolean) - Method in class reactor.netty.tcp.TcpServer
 
wiretap(String) - Method in class reactor.netty.tcp.TcpServer
 
wiretap(String, LogLevel) - Method in class reactor.netty.tcp.TcpServer
 
wiretap(boolean) - Method in class reactor.netty.transport.Transport
Apply or remove a wire logger configuration using Transport category (logger), DEBUG logger level and AdvancedByteBufFormat.HEX_DUMP for ByteBuf format, which means both events and content will be logged and the content will be in hex format.
wiretap(String) - Method in class reactor.netty.transport.Transport
Apply a wire logger configuration using the specified category (logger), DEBUG logger level and AdvancedByteBufFormat.HEX_DUMP for ByteBuf format, 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.transport.Transport
Apply a wire logger configuration using the specified category (logger), logger level and AdvancedByteBufFormat.HEX_DUMP for ByteBuf format, which means both events and content will be logged and the content will be in hex format.
wiretap(String, LogLevel, AdvancedByteBufFormat) - Method in class reactor.netty.transport.Transport
Apply a wire logger configuration using the specified category (logger), logger level and ByteBuf format.
wiretap(String, LogLevel, AdvancedByteBufFormat, Charset) - Method in class reactor.netty.transport.Transport
Apply a wire logger configuration using the specific category (logger), logger level, ByteBuf format and charset.
wiretap(boolean) - Method in class reactor.netty.udp.UdpClient
 
wiretap(String) - Method in class reactor.netty.udp.UdpClient
 
wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpClient
 
wiretap(boolean) - Method in class reactor.netty.udp.UdpServer
 
wiretap(String) - Method in class reactor.netty.udp.UdpServer
 
wiretap(String, LogLevel) - Method in class reactor.netty.udp.UdpServer
 
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 a Connection to operate on the underlying Channel state.
withConnection(Consumer<? super Connection>) - Method in interface reactor.netty.NettyOutbound
Call the passed callback with a Connection to operate on the underlying Channel state.
withHostAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo
Return a new ConnectionInfo with the updated host address.
withHostAddress(InetSocketAddress, String, int) - Method in class reactor.netty.http.server.ConnectionInfo
Return a new ConnectionInfo with updated host address, host name, and host port information.
withRemoteAddress(InetSocketAddress) - Method in class reactor.netty.http.server.ConnectionInfo
Return a new ConnectionInfo with the updated remote address.
withScheme(String) - Method in class reactor.netty.http.server.ConnectionInfo
Return a new ConnectionInfo with 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 using AccessLogArgProvider.accessDateTime() This method will be removed in version 1.2.0.

_

_dispose() - Method in class reactor.netty.incubator.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.incubator.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.
A B C D E F G H I K L M N O P Q R S T U V W Z _ 
Skip navigation links
reactor-netty