Index

A B C D E F G H I J L M N O P R S T U V W 
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 given Future.
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 the ThreadContext.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 into ReleasableBytesReference 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 call ActionListener#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 new DefaultHttpRequest 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 by HttpHeadersAuthenticatorUtils.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
 
A B C D E F G H I J L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values