Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- accept(ChannelHandlerContext, InetSocketAddress) - Method in class org.elasticsearch.transport.netty4.AcceptChannelHandler
- AcceptChannelHandler - Class in org.elasticsearch.transport.netty4
- AcceptChannelHandler(BiPredicate<String, InetSocketAddress>, String, ThreadContext) - Constructor for class org.elasticsearch.transport.netty4.AcceptChannelHandler
- AcceptChannelHandler.AcceptPredicate - Interface in org.elasticsearch.transport.netty4
- addCloseListener(ActionListener<Void>) - Method in class org.elasticsearch.http.netty4.Netty4HttpChannel
- addCloseListener(ActionListener<Void>) - Method in class org.elasticsearch.http.netty4.Netty4HttpServerChannel
- addCloseListener(ActionListener<Void>) - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- addCloseListener(ActionListener<Void>) - Method in class org.elasticsearch.transport.netty4.Netty4TcpServerChannel
- addConnectListener(ActionListener<Void>) - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- addHeader(String, String) - Method in class org.elasticsearch.http.netty4.Netty4FullHttpResponse
- additionalSettings() - Method in class org.elasticsearch.transport.netty4.Netty4Plugin
- addListener(ChannelFuture, ChannelFutureListener) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
- addListener(Future<Void>, ActionListener<Void>) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
-
Subscribes the given
ActionListener
to the givenFuture
. - addTracingHandler(HttpBody.ChunkHandler) - Method in class org.elasticsearch.http.netty4.Netty4HttpRequestBodyStream
- asHttpPreRequest(HttpRequest) - Static method in class org.elasticsearch.http.netty4.internal.HttpHeadersAuthenticatorUtils
-
Translates the netty request internal type to a
HttpPreRequest
instance that code outside the network plugin has access to. - authenticationContextSetOnce - Variable in class org.elasticsearch.http.netty4.internal.HttpHeadersWithAuthenticationContext
B
- bind(String, InetSocketAddress) - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- bind(InetSocketAddress) - Method in class org.elasticsearch.http.netty4.Netty4HttpServerTransport
- body() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- buffer() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- buffer(int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- buffer(int, int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
C
- calculateNewCapacity(int, int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- channelInactive(ChannelHandlerContext) - Method in class org.elasticsearch.http.netty4.Netty4HttpHeaderValidator
- channelInactive(ChannelHandlerContext) - Method in class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
- channelInactive(ChannelHandlerContext) - Method in class org.elasticsearch.transport.netty4.Netty4MessageInboundHandler
- channelInactive(ChannelHandlerContext) - Method in class org.elasticsearch.transport.netty4.Netty4WriteThrottlingHandler
- channelRead(ChannelHandlerContext, Object) - Method in class org.elasticsearch.http.netty4.Netty4HttpAggregator
- channelRead(ChannelHandlerContext, Object) - Method in class org.elasticsearch.http.netty4.Netty4HttpHeaderValidator
- channelRead(ChannelHandlerContext, Object) - Method in class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
- channelRead(ChannelHandlerContext, Object) - Method in class org.elasticsearch.transport.netty4.Netty4MessageInboundHandler
- channelWritabilityChanged(ChannelHandlerContext) - Method in class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
- channelWritabilityChanged(ChannelHandlerContext) - Method in class org.elasticsearch.transport.netty4.Netty4WriteThrottlingHandler
- ClientChannelInitializer() - Constructor for class org.elasticsearch.transport.netty4.Netty4Transport.ClientChannelInitializer
- close() - Method in class org.elasticsearch.http.netty4.Netty4HttpChannel
- close() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequestBodyStream
- close() - Method in class org.elasticsearch.http.netty4.Netty4HttpServerChannel
- close() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- close() - Method in class org.elasticsearch.transport.netty4.Netty4TcpServerChannel
- compositeBuffer() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- compositeBuffer(int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- compositeDirectBuffer() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- compositeDirectBuffer(int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- compositeHeapBuffer() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- compositeHeapBuffer(int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- configureServerChannelHandler() - Method in class org.elasticsearch.http.netty4.Netty4HttpServerTransport
- containsHeader(String) - Method in class org.elasticsearch.http.netty4.Netty4FullHttpResponse
- copy() - Method in class org.elasticsearch.http.netty4.internal.HttpHeadersWithAuthenticationContext
- CopyBytesServerSocketChannel - Class in org.elasticsearch.transport.netty4
-
This class is adapted from
NioServerSocketChannel
class in the Netty project. - CopyBytesServerSocketChannel() - Constructor for class org.elasticsearch.transport.netty4.CopyBytesServerSocketChannel
- CopyBytesSocketChannel - Class in org.elasticsearch.transport.netty4
-
This class is adapted from
NioSocketChannel
class in the Netty project. - CopyBytesSocketChannel() - Constructor for class org.elasticsearch.transport.netty4.CopyBytesSocketChannel
- create(SslConfiguration, String, int) - Method in interface org.elasticsearch.transport.netty4.TLSConfig.EngineProvider
- createRecycler(Settings) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
- createRecycler(Settings, PageCacheRecycler) - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- createResponse(RestStatus, BytesReference) - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- createResponse(RestStatus, ChunkedRestResponseBodyPart) - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- createServerSSLEngine() - Method in record class org.elasticsearch.transport.netty4.TLSConfig
D
- decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.elasticsearch.transport.netty4.NettyByteBufSizer
- directBuffer() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- directBuffer(int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- directBuffer(int, int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- doReadBytes(ByteBuf) - Method in class org.elasticsearch.transport.netty4.CopyBytesSocketChannel
- doReadMessages(List<Object>) - Method in class org.elasticsearch.transport.netty4.CopyBytesServerSocketChannel
- doStart() - Method in class org.elasticsearch.http.netty4.Netty4HttpServerTransport
- doStart() - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- doWrite(ChannelOutboundBuffer) - Method in class org.elasticsearch.transport.netty4.CopyBytesSocketChannel
E
- engineProvider() - Method in record class org.elasticsearch.transport.netty4.TLSConfig
-
Returns the value of the
engineProvider
record component. - equals(Object) - Method in record class org.elasticsearch.transport.netty4.TLSConfig
-
Indicates whether some other object is "equal to" this one.
- exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
- exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.elasticsearch.http.netty4.Netty4HttpServerTransport.HttpChannelHandler
- exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.elasticsearch.transport.netty4.Netty4MessageInboundHandler
- exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.elasticsearch.transport.netty4.Netty4Transport.ClientChannelInitializer
- exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.elasticsearch.transport.netty4.Netty4Transport.ServerChannelInitializer
- extractAuthenticationContext(HttpRequest) - Static method in class org.elasticsearch.http.netty4.internal.HttpHeadersAuthenticatorUtils
-
Returns the authentication thread context for the .
F
- flush(ChannelHandlerContext) - Method in class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
- flush(ChannelHandlerContext) - Method in class org.elasticsearch.transport.netty4.Netty4WriteThrottlingHandler
- fullHttpBodyFrom(ByteBuf) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
G
- getAllocator() - Static method in class org.elasticsearch.transport.netty4.NettyAllocator
- getAllocatorDescription() - Static method in class org.elasticsearch.transport.netty4.NettyAllocator
- getChannelStats() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- getChannelType() - Static method in class org.elasticsearch.transport.netty4.NettyAllocator
- getClientBootstrap(ConnectionProfile) - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- getClientChannelInitializer(DiscoveryNode, ConnectionProfile) - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- getDelegate() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- getHeaders() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- getHttpGroup() - Method in class org.elasticsearch.transport.netty4.SharedGroupFactory
- getHttpHeadersAsMap(HttpHeaders) - Static method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- getHttpTransports(Settings, ThreadPool, BigArrays, PageCacheRecycler, CircuitBreakerService, NamedXContentRegistry, NetworkService, HttpServerTransport.Dispatcher, BiConsumer<HttpPreRequest, ThreadContext>, ClusterSettings, Tracer) - Method in class org.elasticsearch.transport.netty4.Netty4Plugin
- getInboundException() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- getInboundPipeline(Channel, boolean) - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- getLocalAddress() - Method in class org.elasticsearch.http.netty4.Netty4HttpChannel
- getLocalAddress() - Method in class org.elasticsearch.http.netty4.Netty4HttpServerChannel
- getLocalAddress() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- getLocalAddress() - Method in class org.elasticsearch.transport.netty4.Netty4TcpServerChannel
- getLowLevelGroup() - Method in class org.elasticsearch.transport.netty4.SharedGroupFactory.SharedGroup
- getNettyChannel() - Method in class org.elasticsearch.http.netty4.Netty4HttpChannel
- getNettyChannel() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- getNettyRequest() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- getProfile() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- getRecycler() - Static method in class org.elasticsearch.transport.netty4.NettyAllocator
- getRemoteAddress() - Method in class org.elasticsearch.http.netty4.Netty4HttpChannel
- getRemoteAddress() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- getSequence() - Method in class org.elasticsearch.http.netty4.Netty4FullHttpResponse
- getServerChannelInitializer(String) - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- getServerChannelType() - Static method in class org.elasticsearch.transport.netty4.NettyAllocator
- getSettings() - Method in class org.elasticsearch.transport.netty4.Netty4Plugin
- getSettings() - Method in class org.elasticsearch.transport.netty4.SharedGroupFactory
- getTcpKeepCountSocketOption() - Static method in class org.elasticsearch.transport.netty4.NetUtils
-
Returns the extended TCP_KEEPCOUNT socket option.
- getTcpKeepIdleSocketOption() - Static method in class org.elasticsearch.transport.netty4.NetUtils
-
Returns the extended TCP_KEEPIDLE socket option.
- getTcpKeepIntervalSocketOption() - Static method in class org.elasticsearch.transport.netty4.NetUtils
-
Returns the extended TCP_KEEPINTERVAL socket option.
- getTransportGroup() - Method in class org.elasticsearch.transport.netty4.SharedGroupFactory
- getTransports(Settings, ThreadPool, PageCacheRecycler, CircuitBreakerService, NamedWriteableRegistry, NetworkService) - Method in class org.elasticsearch.transport.netty4.Netty4Plugin
- getTransportWorkerCount() - Method in class org.elasticsearch.transport.netty4.SharedGroupFactory
- getValidatorInboundHandler(HttpValidator, ThreadContext) - Static method in class org.elasticsearch.http.netty4.internal.HttpHeadersAuthenticatorUtils
-
Supplies a netty
ChannelInboundHandler
that runs the provided on the HTTP request headers.
H
- handleNettyContent(HttpContent) - Method in class org.elasticsearch.http.netty4.Netty4HttpRequestBodyStream
- handlePipelinedRequest(ChannelHandlerContext, Netty4HttpRequest) - Method in class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
- handler() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequestBodyStream
- hashCode() - Method in record class org.elasticsearch.transport.netty4.TLSConfig
-
Returns a hash code value for this object.
- heapBuffer() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- heapBuffer(int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- heapBuffer(int, int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- HttpChannelHandler(Netty4HttpServerTransport, HttpHandlingSettings, TLSConfig, BiPredicate<String, InetSocketAddress>, HttpValidator, IncrementalBulkService.Enabled) - Constructor for class org.elasticsearch.http.netty4.Netty4HttpServerTransport.HttpChannelHandler
- HttpHeadersAuthenticatorUtils - Class in org.elasticsearch.http.netty4.internal
-
Provides utilities for hooking into the netty pipeline and authenticate each HTTP request's headers.
- HttpHeadersWithAuthenticationContext - Class in org.elasticsearch.http.netty4.internal
-
HttpHeaders
implementation that carries along theThreadContext.StoredContext
iff the HTTP headers have been authenticated successfully. - HttpHeadersWithAuthenticationContext(HttpHeaders) - Constructor for class org.elasticsearch.http.netty4.internal.HttpHeadersWithAuthenticationContext
- HttpValidator - Interface in org.elasticsearch.http.netty4.internal
I
- initChannel(Channel) - Method in class org.elasticsearch.http.netty4.Netty4HttpServerTransport.HttpChannelHandler
- initChannel(Channel) - Method in class org.elasticsearch.transport.netty4.Netty4Transport.ClientChannelInitializer
- initChannel(Channel) - Method in class org.elasticsearch.transport.netty4.Netty4Transport.ServerChannelInitializer
- initiateChannel(DiscoveryNode, ConnectionProfile) - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- INSTANCE - Static variable in class org.elasticsearch.transport.netty4.NettyByteBufSizer
- ioBuffer() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- ioBuffer(int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- ioBuffer(int, int) - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- isCloseDuringHandshakeException(Throwable) - Static method in class org.elasticsearch.transport.netty4.SSLExceptionHelper
- isDirectBufferPooled() - Method in class org.elasticsearch.transport.netty4.NettyAllocator.NoDirectBuffers
- isInsufficientBufferRemainingException(Throwable) - Static method in class org.elasticsearch.transport.netty4.SSLExceptionHelper
- isNotSslRecordException(Throwable) - Static method in class org.elasticsearch.transport.netty4.SSLExceptionHelper
- isOpen() - Method in class org.elasticsearch.http.netty4.Netty4HttpChannel
- isOpen() - Method in class org.elasticsearch.http.netty4.Netty4HttpServerChannel
- isOpen() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- isOpen() - Method in class org.elasticsearch.transport.netty4.Netty4TcpServerChannel
- isReceivedCertificateUnknownException(Throwable) - Static method in class org.elasticsearch.transport.netty4.SSLExceptionHelper
- isServerChannel() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- isTLSEnabled() - Method in record class org.elasticsearch.transport.netty4.TLSConfig
J
- javaChannel() - Method in class org.elasticsearch.transport.netty4.Netty4NioSocketChannel
L
- logAllocatorDescriptionIfNeeded() - Static method in class org.elasticsearch.transport.netty4.NettyAllocator
M
- MAX_BYTES_PER_WRITE - Static variable in class org.elasticsearch.transport.netty4.Netty4WriteThrottlingHandler
- method() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
N
- name - Variable in class org.elasticsearch.transport.netty4.Netty4Transport.ServerChannelInitializer
- NETTY_BOSS_COUNT - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- NETTY_HTTP_TRANSPORT_NAME - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- NETTY_RECEIVE_PREDICTOR_MAX - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- NETTY_RECEIVE_PREDICTOR_MIN - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- NETTY_TRANSPORT_NAME - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- Netty4FullHttpResponse - Class in org.elasticsearch.http.netty4
- Netty4HttpAggregator - Class in org.elasticsearch.http.netty4
-
A wrapper around
HttpObjectAggregator
. - Netty4HttpAggregator(int, Predicate<HttpPreRequest>) - Constructor for class org.elasticsearch.http.netty4.Netty4HttpAggregator
- Netty4HttpChannel - Class in org.elasticsearch.http.netty4
- Netty4HttpHeaderValidator - Class in org.elasticsearch.http.netty4
- Netty4HttpHeaderValidator(HttpValidator, ThreadContext) - Constructor for class org.elasticsearch.http.netty4.Netty4HttpHeaderValidator
- Netty4HttpPipeliningHandler - Class in org.elasticsearch.http.netty4
-
Implements HTTP pipelining ordering, ensuring that responses are completely served in the same order as their corresponding requests.
- Netty4HttpPipeliningHandler(int, Netty4HttpServerTransport, ThreadWatchdog.ActivityTracker) - Constructor for class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
-
Construct a new pipelining handler; this handler should be used downstream of HTTP decoding/aggregation.
- Netty4HttpRequest - Class in org.elasticsearch.http.netty4
- Netty4HttpRequestBodyStream - Class in org.elasticsearch.http.netty4
-
Netty based implementation of
HttpBody.Stream
. - Netty4HttpRequestBodyStream(Channel, ThreadContext) - Constructor for class org.elasticsearch.http.netty4.Netty4HttpRequestBodyStream
- Netty4HttpServerChannel - Class in org.elasticsearch.http.netty4
- Netty4HttpServerTransport - Class in org.elasticsearch.http.netty4
- Netty4HttpServerTransport(Settings, NetworkService, ThreadPool, NamedXContentRegistry, HttpServerTransport.Dispatcher, ClusterSettings, SharedGroupFactory, Tracer, TLSConfig, AcceptChannelHandler.AcceptPredicate, HttpValidator) - Constructor for class org.elasticsearch.http.netty4.Netty4HttpServerTransport
- Netty4HttpServerTransport.HttpChannelHandler - Class in org.elasticsearch.http.netty4
- Netty4MessageInboundHandler - Class in org.elasticsearch.transport.netty4
-
A handler (must be the last one!) that does size based frame decoding and forwards the actual message to the relevant action.
- Netty4MessageInboundHandler(Netty4Transport, InboundPipeline, ThreadWatchdog.ActivityTracker) - Constructor for class org.elasticsearch.transport.netty4.Netty4MessageInboundHandler
- Netty4NioSocketChannel - Class in org.elasticsearch.transport.netty4
-
Helper class to expose
Netty4NioSocketChannel.javaChannel()
method - Netty4NioSocketChannel() - Constructor for class org.elasticsearch.transport.netty4.Netty4NioSocketChannel
- Netty4NioSocketChannel(Channel, SocketChannel) - Constructor for class org.elasticsearch.transport.netty4.Netty4NioSocketChannel
- Netty4Plugin - Class in org.elasticsearch.transport.netty4
- Netty4Plugin() - Constructor for class org.elasticsearch.transport.netty4.Netty4Plugin
- Netty4TcpChannel - Class in org.elasticsearch.transport.netty4
- Netty4TcpServerChannel - Class in org.elasticsearch.transport.netty4
- Netty4Transport - Class in org.elasticsearch.transport.netty4
-
There are 4 types of connections per node, low/med/high/ping.
- Netty4Transport(Settings, TransportVersion, ThreadPool, NetworkService, PageCacheRecycler, NamedWriteableRegistry, CircuitBreakerService, SharedGroupFactory) - Constructor for class org.elasticsearch.transport.netty4.Netty4Transport
- Netty4Transport.ClientChannelInitializer - Class in org.elasticsearch.transport.netty4
- Netty4Transport.ServerChannelInitializer - Class in org.elasticsearch.transport.netty4
- Netty4Utils - Class in org.elasticsearch.transport.netty4
- Netty4Utils() - Constructor for class org.elasticsearch.transport.netty4.Netty4Utils
- Netty4WriteThrottlingHandler - Class in org.elasticsearch.transport.netty4
-
Channel handler that queues up writes it receives and tries to only flush bytes as they can be written by the backing channel.
- Netty4WriteThrottlingHandler(ThreadContext, ThreadWatchdog.ActivityTracker) - Constructor for class org.elasticsearch.transport.netty4.Netty4WriteThrottlingHandler
- NettyAllocator - Class in org.elasticsearch.transport.netty4
- NettyAllocator() - Constructor for class org.elasticsearch.transport.netty4.NettyAllocator
- NettyAllocator.NoDirectBuffers - Class in org.elasticsearch.transport.netty4
- NettyByteBufSizer - Class in org.elasticsearch.transport.netty4
- NetUtils - Class in org.elasticsearch.transport.netty4
-
Utilities for network-related methods.
- next() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequestBodyStream
- noTLS() - Static method in record class org.elasticsearch.transport.netty4.TLSConfig
O
- onException(HttpChannel, Exception) - Method in class org.elasticsearch.http.netty4.Netty4HttpServerTransport
- OPTION_TCP_KEEP_COUNT - Static variable in class org.elasticsearch.transport.netty4.Netty4Transport
- OPTION_TCP_KEEP_IDLE - Static variable in class org.elasticsearch.transport.netty4.Netty4Transport
- OPTION_TCP_KEEP_INTERVAL - Static variable in class org.elasticsearch.transport.netty4.Netty4Transport
- org.elasticsearch.http.netty4 - package org.elasticsearch.http.netty4
- org.elasticsearch.http.netty4.internal - package org.elasticsearch.http.netty4.internal
- org.elasticsearch.transport.netty4 - module org.elasticsearch.transport.netty4
- org.elasticsearch.transport.netty4 - package org.elasticsearch.transport.netty4
P
- protocolVersion() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
R
- rawPath() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- readFromSocketChannel(SocketChannel, ByteBuffer) - Method in class org.elasticsearch.transport.netty4.CopyBytesSocketChannel
- release() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- releaseAndCopy() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- remoteClusterPortEnabled - Variable in class org.elasticsearch.transport.netty4.Netty4Transport
- removeHeader(String) - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
S
- safeWriteAndFlush(Channel, Object, ActionListener<Void>) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
-
Calls
ChannelOutboundInvoker.writeAndFlush(java.lang.Object, io.netty.channel.ChannelPromise)
to write the given message to the given channel, but ensures that the listener is completed even if the event loop is concurrently shutting down since Netty does not offer this guarantee. - sendMessage(BytesReference, ActionListener<Void>) - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- sendResponse(HttpResponse, ActionListener<Void>) - Method in class org.elasticsearch.http.netty4.Netty4HttpChannel
- ServerChannelInitializer(String) - Constructor for class org.elasticsearch.transport.netty4.Netty4Transport.ServerChannelInitializer
- setAuthenticationContext(ThreadContext.StoredContext) - Method in class org.elasticsearch.http.netty4.internal.HttpHeadersWithAuthenticationContext
-
Must be called at most once in order to mark the http headers as successfully authenticated.
- setAvailableProcessors(int) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
-
Set the number of available processors that Netty uses for sizing various resources (e.g., thread pools).
- setBoundAddress(BoundTransportAddress) - Method in interface org.elasticsearch.transport.netty4.AcceptChannelHandler.AcceptPredicate
- setHandler(HttpBody.ChunkHandler) - Method in class org.elasticsearch.http.netty4.Netty4HttpRequestBodyStream
- SETTING_HTTP_NETTY_MAX_COMPOSITE_BUFFER_COMPONENTS - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_SIZE - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- SETTING_HTTP_WORKER_COUNT - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- settings() - Method in class org.elasticsearch.http.netty4.Netty4HttpServerTransport
- SharedGroupFactory - Class in org.elasticsearch.transport.netty4
-
Creates and returns
EventLoopGroup
instances. - SharedGroupFactory(Settings) - Constructor for class org.elasticsearch.transport.netty4.SharedGroupFactory
- SharedGroupFactory.SharedGroup - Class in org.elasticsearch.transport.netty4
-
Wraps the
SharedGroupFactory.RefCountedGroup
. - shutdown() - Method in class org.elasticsearch.transport.netty4.SharedGroupFactory.SharedGroup
- sslConfiguration() - Method in record class org.elasticsearch.transport.netty4.TLSConfig
-
Returns the value of the
sslConfiguration
record component. - SSLExceptionHelper - Class in org.elasticsearch.transport.netty4
- stopInternal() - Method in class org.elasticsearch.http.netty4.Netty4HttpServerTransport
- stopInternal() - Method in class org.elasticsearch.transport.netty4.Netty4Transport
- strictCookies() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- suggestedMaxAllocationSize() - Static method in class org.elasticsearch.transport.netty4.NettyAllocator
T
- TLSConfig - Record Class in org.elasticsearch.transport.netty4
- TLSConfig(SslConfiguration, TLSConfig.EngineProvider) - Constructor for record class org.elasticsearch.transport.netty4.TLSConfig
-
Creates an instance of a
TLSConfig
record class. - TLSConfig.EngineProvider - Interface in org.elasticsearch.transport.netty4
- toByteBuf(BytesReference) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
-
Turns the given BytesReference into a ByteBuf.
- toBytesReference(ByteBuf) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
-
Wraps the given ChannelBuffer with a BytesReference
- toReleasableBytesReference(ByteBuf) - Static method in class org.elasticsearch.transport.netty4.Netty4Utils
-
Wrap Netty's
ByteBuf
intoReleasableBytesReference
and delegating reference count to ByteBuf. - toString() - Method in class org.elasticsearch.http.netty4.Netty4HttpChannel
- toString() - Method in class org.elasticsearch.http.netty4.Netty4HttpServerChannel
- toString() - Method in class org.elasticsearch.transport.netty4.Netty4TcpChannel
- toString() - Method in class org.elasticsearch.transport.netty4.Netty4TcpServerChannel
- toString() - Method in record class org.elasticsearch.transport.netty4.TLSConfig
-
Returns a string representation of this record class.
- translateRequestMethod(HttpMethod) - Static method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- tryEnsureReasonableKeepAliveConfig(NetworkChannel) - Static method in class org.elasticsearch.transport.netty4.NetUtils
-
If SO_KEEPALIVE is enabled (default), this method ensures sane default values for the extended socket options TCP_KEEPIDLE and TCP_KEEPINTERVAL.
U
- uri() - Method in class org.elasticsearch.http.netty4.Netty4HttpRequest
- userEventTriggered(ChannelHandlerContext, Object) - Method in class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
V
- validate(HttpRequest, Channel, ActionListener<Void>) - Method in interface org.elasticsearch.http.netty4.internal.HttpValidator
-
An async HTTP request validating function that receives as arguments the initial part of a decoded HTTP request (which contains all the HTTP headers, but not the body contents), as well as the netty channel that the request is being received over, and must then call the
ActionListener#onResponse
method on the listener parameter in case the authentication is to be considered successful, or otherwise callActionListener#onFailure
and pass the failure exception.
W
- WORKER_COUNT - Static variable in class org.elasticsearch.transport.netty4.Netty4Plugin
- wrapAsMessageWithAuthenticationContext(HttpMessage) - Static method in class org.elasticsearch.http.netty4.internal.HttpHeadersAuthenticatorUtils
-
Given a
DefaultHttpRequest
argument, this returns a newDefaultHttpRequest
instance that's identical to the passed-in one, but the headers of the latter can be authenticated, in the sense that the channel handlers returned byHttpHeadersAuthenticatorUtils.getValidatorInboundHandler(HttpValidator, ThreadContext)
can use this to convey the authentication result context. - write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.elasticsearch.http.netty4.Netty4HttpPipeliningHandler
- write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.elasticsearch.transport.netty4.Netty4WriteThrottlingHandler
- writeToSocketChannel(SocketChannel, ByteBuffer) - Method in class org.elasticsearch.transport.netty4.CopyBytesSocketChannel
All Classes and Interfaces|All Packages|Constant Field Values