All Classes and Interfaces
Class
Description
An exception marking prematurely or unexpectedly closed inbound.
Base
ChannelHandler
for collecting metrics on protocol level.An abstract factory for generating one and the same type of log message
no matter the log level that will be used.
SslContext builder that provides, specific for protocol, default configuration.
Log the http access information into a Logger named
reactor.netty.http.server.AccessLog
at INFO level.A provider of the args required for access log.
An interface to declare more concisely a
Function
that apply an AccessLog
by an
AccessLogArgProvider
.Use to create an access-log handler.
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.Used to control the format and verbosity of logging for
ByteBuf
s and ByteBufHolder
s.Represents a failing attempt to bind a local socket address.
Channel meters.
ChannelHandler
for collecting metrics on protocol level.Interface for recording metrics on protocol level.
A
ChannelOperations
factory.Provides short/long string representation of the channel.
Configure the channel pipeline while initializing the channel.
A generic client
Transport
that will ClientTransport.connect()
to a remote address and provide a Connection
.An interface for selecting resolved addresses based on configuration and available socket addresses.
Encapsulate all necessary configuration for client transport.
Hold contextual information for the underlying
Channel
.Resolve information about the current connection, including the
host (server) address, the remote (client) address and the scheme.
Resolve information about the connection from which an http request is received.
Event listeners for connection lifecycle.
A marker interface for various state signals used in
ConnectionObserver.onStateChange(Connection, State)
A
ConnectionProvider
will produce Connection
.Build a
ConnectionProvider
to cache and reuse a fixed maximum number of
Connection
.Configuration for a connection pool.
Configuration for a connection pool per remote host.
A strategy to register which metrics are collected in a particular connection pool.
ContextView
aware class for recording metrics on protocol level.ContextView
aware class for collecting metrics on HTTP client level.ContextView
aware class for recording metrics for HTTP protocol.ContextView
aware class for collecting metrics on HTTP server level.Store cookies for the http channel.
Handler for logging errors that occur in the HTTP Server.
SslContext builder that does not provide any default configuration.
Deflate compression option configuration.
Holds contextual information for the underlying channel and provides
non-blocking resource disposing API.
Holds contextual information for the underlying server.
Internal utility class for UDS on Java 8.
Represents a log entry for HTTP server errors.
A provider of the args required for error log.
Define an interface to handle error log events propagated through UserEvent.
Convert Netty Future into void
Mono
.GZIP compression option configuration.
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
A configuration builder to fine tune the
Http2Settings
.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
Utility class around HTTP/3.
A configuration builder to fine tune the HTTP/3 settings.
SslContext builder that provides default configuration specific to HTTP/3 as follows:
Supported application protocols
An HttpClient allows building in a safe immutable way an http client that is
materialized and connecting when
ClientTransport.connect()
is ultimately called.Marker interface for use with
HttpClient.RequestSender.send(BiFunction)
.Allow a request body configuration before calling one of the terminal,
Publisher
based, HttpClient.ResponseReceiver
API.A response extractor for this configured
HttpClient
.A URI configuration.
Allow a websocket handling.
Allow a request body configuration before calling one of the terminal,
Publisher
based, HttpClient.WebsocketReceiver
API.Encapsulate all necessary configuration for HTTP client transport.
An HTTP Form builder.
An Http Reactive Channel with several accessors related to HTTP flow: resource URL,
information for redirections etc...
Interface for collecting metrics on HTTP client level.
An Http Reactive client metadata contract for outgoing requests.
An HttpClient Reactive metadata contract for incoming response.
Provides utilities for
HttpClient
SSL/TLS configuration.Specific Http Client state observable by
HttpClient.observe(ConnectionObserver)
.HTTP compression option configuration.
HTTP Compression configuration for the SimpleCompressionHandler.
Interface for collecting HTTP/2 or HTTP/3 specific connection pool metrics.
A configuration builder to fine tune the
HttpCodec
(or more precisely
the settings for the decoder).An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
A provider of the args required for logging
HttpMessage
details.Factory for creating
HttpContentArgProvider
based on the provided HTTP object.Factory for generating a log message based on a given
HttpMessageArgProvider
.Utilities for creating log message based on a given
HttpMessageArgProvider
.Representation of various
HttpMessage
types.An abstract adapter class for registering HTTP/2 or HTTP/3 specific metrics in a connection pool.
Interface for recording metrics for HTTP protocol.
An HTTP ready
ChannelOperations
with state management for status and headers
(first HTTP response packet).An enum defining various HTTP negotiations between H2, H2C-upgrade,
H2C-prior-knowledge and HTTP/1.1.
A configuration builder to fine tune the
HttpServerCodec
(or more precisely the HttpServerCodec.HttpServerRequestDecoder
) for HTTP/1.1
or HttpServerUpgradeHandler
for H2C.Hold the default HTTP/1.x resources.
A configuration builder to fine tune the
HttpClientCodec
(or more precisely the HttpClientCodec.Decoder
).Provides the metadata that a given handler can handle.
An HttpServer allows building in a safe immutable way an HTTP server that is
materialized and connecting when
ServerTransport.bind()
is ultimately called.Encapsulate all necessary configuration for HTTP server transport.
A configuration builder to fine tune the HTTP form decoder.
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
Interface for collecting metrics on HTTP server level.
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
An Http Reactive Channel with several accessors related to HTTP flow: headers, params,
URI, method, websocket...
Server routes are unique and only the first matching in order of declaration will be
invoked.
Specific Http Server state observable by
Transport.observe(ConnectionObserver)
.An
EventLoopGroup
selector with associated
Channel
factories.This class contains temporary workarounds for Java 8
Map
issues.Contains meters' tags values.
Utility class around instrumentation and metrics with Micrometer.
Constants and utilities around metrics.
ChannelHandler
for collecting metrics on protocol level.A
ChannelMetricsRecorder
implementation for integration with Micrometer.An
HttpMetricsRecorder
implementation for integration with Micrometer.A
NameResolverProvider
will produce DnsAddressResolverGroup
.An inbound-traffic API delegating to an underlying
Channel
.An outbound-traffic API delegating to an underlying
Channel
.Constant for names used when adding/removing
ChannelHandler
.Base
ConnectionProvider
implementation.An error for signalling that the connection was closed prematurely
ChannelInboundHandler.channelInactive(io.netty.channel.ChannelHandlerContext)
,
ChannelOperations.onInboundClose()
,
ChannelOperations#onInboundError()
.Proxy protocol support type, this enum class defines how the HttpServer handles proxy protocol.
Proxy configuration.
Proxy Type.
A QuicClient allows building in a safe immutable way a QUIC client that is materialized
and connecting when
QuicClient.connect()
is ultimately called.Encapsulate all necessary configuration for QUIC client transport.
API for creating and handling streams.
An inbound-traffic API delegating to an underlying
Channel
.A configuration builder to fine tune the QUIC initial settings.
An outbound-traffic API delegating to an underlying
Channel
.Hold the default QUIC resources.
A QuicServer allows building in a safe immutable way a QUIC server that is materialized
and bound when
QuicServer.bind()
is ultimately called.Encapsulate all necessary configuration for QUIC server transport.
Exposes information for the
QuicStreamChannel
as stream id etc.Internal helpers for reactor-netty contracts.
Abstraction over all Reactor Netty contexts.
Reactor Netty factory for generating a log message based on a given
HttpMessageArgProvider
.Reactor Netty specific
PropagatingReceiverTracingObservationHandler
.Reactor Netty specific
PropagatingSenderTracingObservationHandler
.Reactor Netty timer observation handler.
Abstraction over all Reactor Netty handlers.
Cookies
holder from server request headers.A generic server
Transport
that will ServerTransport.bind()
to a local address and provide a DisposableServer
.Encapsulate all necessary configuration for server transport.
SSL Provider.
Generic SslContext builder that provides, specific for the protocol, default configuration.
SslContext builder that provides, specific for the protocol, default configuration.
A TcpClient allows building in a safe immutable way a TCP client that
is materialized and connecting when
TcpClient.connect()
is ultimately called.Encapsulate all necessary configuration for TCP client transport.
Hold the default Tcp resources.
A TcpServer allows building in a safe immutable way a TCP server that is materialized
and connecting when
ServerTransport.bind()
is ultimately called.Encapsulate all necessary configuration for TCP server transport.
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
An immutable transport builder for clients and servers.
A basic configuration holder.
TransportConnector
is a helper class that creates, initializes and registers the channel.A UdpClient allows building in a safe immutable way a UDP client that is materialized
and connecting when
UdpClient.connect()
is ultimately called.Encapsulate all necessary configuration for UDP client transport.
An inbound-traffic API delegating to an underlying
Channel
.An outbound-traffic API delegating to an underlying
Channel
.Hold the default UDP resources.
A UdpServer allows building in a safe immutable way a UDP server that is materialized
and connecting when
UdpServer.bind()
is ultimately called.Encapsulate all necessary configuration for UDP server transport.
Websocket client configuration.
A websocket framed inbound.
A websocket framed outbound.
Websocket server configuration.
Wrapper for websocket configuration.
Configurer implementation for
WebsocketSpec
.ZSTD compression option configuration.