Package org.elasticsearch.http.netty4

Class Netty4HttpServerTransport

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.http.netty4.Netty4HttpServerTransport

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.elasticsearch.common.component.LifecycleComponent, org.elasticsearch.common.lease.Releasable, org.elasticsearch.http.HttpServerTransport

public class Netty4HttpServerTransport
extends org.elasticsearch.common.component.AbstractLifecycleComponent
implements org.elasticsearch.http.HttpServerTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	Netty4HttpServerTransport.HttpChannelHandler

Nested classes/interfaces inherited from interface org.elasticsearch.http.HttpServerTransport

org.elasticsearch.http.HttpServerTransport.Dispatcher

Field Summary

Fields

Modifier and Type	Field	Description
protected org.elasticsearch.common.util.BigArrays	bigArrays
protected java.lang.String[]	bindHosts
protected org.elasticsearch.common.transport.BoundTransportAddress	boundAddress
protected boolean	compression
protected int	compressionLevel
protected boolean	detailedErrorsEnabled
protected org.elasticsearch.common.unit.ByteSizeValue	maxChunkSize
protected int	maxCompositeBufferComponents
protected org.elasticsearch.common.unit.ByteSizeValue	maxContentLength
protected org.elasticsearch.common.unit.ByteSizeValue	maxHeaderSize
protected org.elasticsearch.common.unit.ByteSizeValue	maxInitialLineLength
protected org.elasticsearch.common.network.NetworkService	networkService
protected boolean	pipelining
protected int	pipeliningMaxEvents
protected org.elasticsearch.common.transport.PortsRange	port
protected java.lang.String[]	publishHosts
protected io.netty.channel.RecvByteBufAllocator	recvByteBufAllocator
protected boolean	resetCookies
protected boolean	reuseAddress
protected io.netty.bootstrap.ServerBootstrap	serverBootstrap
protected java.util.List<io.netty.channel.Channel>	serverChannels
static org.elasticsearch.common.settings.Setting<java.lang.Integer>	SETTING_HTTP_NETTY_MAX_COMPOSITE_BUFFER_COMPONENTS
static org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue>	SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_MAX	Deprecated. This (undocumented) setting is deprecated to reduce complexity and is removed in 7.0.
static org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue>	SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_MIN	Deprecated. This (undocumented) setting is deprecated to reduce complexity and is removed in 7.0.
static org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue>	SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_SIZE
static org.elasticsearch.common.settings.Setting<java.lang.Integer>	SETTING_HTTP_WORKER_COUNT
protected boolean	tcpKeepAlive
protected boolean	tcpNoDelay
protected org.elasticsearch.common.unit.ByteSizeValue	tcpReceiveBufferSize
protected org.elasticsearch.common.unit.ByteSizeValue	tcpSendBufferSize
protected org.elasticsearch.threadpool.ThreadPool	threadPool
protected int	workerCount
protected org.elasticsearch.common.xcontent.NamedXContentRegistry	xContentRegistry	The registry used to construct parsers so they support XContentParser.namedObject(Class, String, Object).

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Fields inherited from interface org.elasticsearch.http.HttpServerTransport

HTTP_SERVER_WORKER_THREAD_NAME_PREFIX

Constructor Summary

Constructors

Constructor	Description
Netty4HttpServerTransport(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.common.network.NetworkService networkService, org.elasticsearch.common.util.BigArrays bigArrays, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry, org.elasticsearch.http.HttpServerTransport.Dispatcher dispatcher)

Method Summary

Modifier and Type	Method	Description
org.elasticsearch.common.transport.BoundTransportAddress	boundAddress()
io.netty.channel.ChannelHandler	configureServerChannelHandler()
protected void	doClose()
protected void	doStart()
protected void	doStop()
protected void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, java.lang.Throwable cause)
Netty4CorsConfig	getCorsConfig()
org.elasticsearch.http.HttpInfo	info()
org.elasticsearch.common.settings.Settings	settings()
org.elasticsearch.http.HttpStats	stats()

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.elasticsearch.common.lease.Releasable

close

Field Detail

SETTING_HTTP_NETTY_MAX_COMPOSITE_BUFFER_COMPONENTS

public static org.elasticsearch.common.settings.Setting<java.lang.Integer> SETTING_HTTP_NETTY_MAX_COMPOSITE_BUFFER_COMPONENTS

SETTING_HTTP_WORKER_COUNT

public static final org.elasticsearch.common.settings.Setting<java.lang.Integer> SETTING_HTTP_WORKER_COUNT

SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_SIZE

public static final org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue> SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_SIZE

SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_MIN

@Deprecated
public static final org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue> SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_MIN

Deprecated.

This (undocumented) setting is deprecated to reduce complexity and is removed in 7.0. See #26165 for details.

SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_MAX

@Deprecated
public static final org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue> SETTING_HTTP_NETTY_RECEIVE_PREDICTOR_MAX

Deprecated.

This (undocumented) setting is deprecated to reduce complexity and is removed in 7.0. See #26165 for details.

networkService

protected final org.elasticsearch.common.network.NetworkService networkService

bigArrays

protected final org.elasticsearch.common.util.BigArrays bigArrays

maxContentLength

protected final org.elasticsearch.common.unit.ByteSizeValue maxContentLength

maxInitialLineLength

protected final org.elasticsearch.common.unit.ByteSizeValue maxInitialLineLength

maxHeaderSize

protected final org.elasticsearch.common.unit.ByteSizeValue maxHeaderSize

maxChunkSize

protected final org.elasticsearch.common.unit.ByteSizeValue maxChunkSize

workerCount

protected final int workerCount

pipelining

protected final boolean pipelining

pipeliningMaxEvents

protected final int pipeliningMaxEvents

compression

protected final boolean compression

compressionLevel

protected final int compressionLevel

resetCookies

protected final boolean resetCookies

port

protected final org.elasticsearch.common.transport.PortsRange port

bindHosts

protected final java.lang.String[] bindHosts

publishHosts

protected final java.lang.String[] publishHosts

detailedErrorsEnabled

protected final boolean detailedErrorsEnabled

threadPool

protected final org.elasticsearch.threadpool.ThreadPool threadPool

xContentRegistry

protected final org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry

The registry used to construct parsers so they support XContentParser.namedObject(Class, String, Object).

tcpNoDelay

protected final boolean tcpNoDelay

tcpKeepAlive

protected final boolean tcpKeepAlive

reuseAddress

protected final boolean reuseAddress

tcpSendBufferSize

protected final org.elasticsearch.common.unit.ByteSizeValue tcpSendBufferSize

tcpReceiveBufferSize

protected final org.elasticsearch.common.unit.ByteSizeValue tcpReceiveBufferSize

recvByteBufAllocator

protected final io.netty.channel.RecvByteBufAllocator recvByteBufAllocator

maxCompositeBufferComponents

protected final int maxCompositeBufferComponents

serverBootstrap

protected volatile io.netty.bootstrap.ServerBootstrap serverBootstrap

boundAddress

protected volatile org.elasticsearch.common.transport.BoundTransportAddress boundAddress

serverChannels

protected final java.util.List<io.netty.channel.Channel> serverChannels

Constructor Detail

Netty4HttpServerTransport

public Netty4HttpServerTransport(org.elasticsearch.common.settings.Settings settings,
                                 org.elasticsearch.common.network.NetworkService networkService,
                                 org.elasticsearch.common.util.BigArrays bigArrays,
                                 org.elasticsearch.threadpool.ThreadPool threadPool,
                                 org.elasticsearch.common.xcontent.NamedXContentRegistry xContentRegistry,
                                 org.elasticsearch.http.HttpServerTransport.Dispatcher dispatcher)

Method Detail

settings

public org.elasticsearch.common.settings.Settings settings()

doStart

protected void doStart()

Specified by:

doStart in class org.elasticsearch.common.component.AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class org.elasticsearch.common.component.AbstractLifecycleComponent

doClose

protected void doClose()

Specified by:

doClose in class org.elasticsearch.common.component.AbstractLifecycleComponent

boundAddress

public org.elasticsearch.common.transport.BoundTransportAddress boundAddress()

Specified by:

boundAddress in interface org.elasticsearch.http.HttpServerTransport

info

public org.elasticsearch.http.HttpInfo info()

Specified by:

info in interface org.elasticsearch.http.HttpServerTransport

stats

public org.elasticsearch.http.HttpStats stats()

Specified by:

stats in interface org.elasticsearch.http.HttpServerTransport

getCorsConfig

public Netty4CorsConfig getCorsConfig()

exceptionCaught

protected void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                               java.lang.Throwable cause)
                        throws java.lang.Exception

Throws:

java.lang.Exception

configureServerChannelHandler

public io.netty.channel.ChannelHandler configureServerChannelHandler()