Class Netty4Transport
java.lang.Object
org.elasticsearch.common.component.AbstractLifecycleComponent
org.elasticsearch.transport.TcpTransport
org.elasticsearch.transport.netty4.Netty4Transport
- All Implemented Interfaces:
Closeable,AutoCloseable,LifecycleComponent,org.elasticsearch.core.Releasable,Transport
There are 4 types of connections per node, low/med/high/ping. Low if for batch oriented APIs (like recovery or
batch) with high payload that will cause regular request. (like search or single index) to take
longer. Med is for the typical search / single doc index. And High for things like cluster state. Ping is reserved for
sending out ping requests to other nodes.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprotected classprotected classNested classes/interfaces inherited from class org.elasticsearch.transport.TcpTransport
TcpTransport.HttpRequestOnTransportException, TcpTransport.NodeChannels, TcpTransport.ProfileSettingsNested classes/interfaces inherited from interface org.elasticsearch.transport.Transport
Transport.Connection, Transport.RequestHandlers, Transport.ResponseContext<T extends TransportResponse>, Transport.ResponseHandlers -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final io.netty.channel.ChannelOption<Integer> static final io.netty.channel.ChannelOption<Integer> static final io.netty.channel.ChannelOption<Integer> protected final booleanFields inherited from class org.elasticsearch.transport.TcpTransport
networkService, profileSettingsSet, recycler, rstOnClose, settings, threadPool, TRANSPORT_WORKER_THREAD_NAME_PREFIXFields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
lifecycle -
Constructor Summary
ConstructorsConstructorDescriptionNetty4Transport(Settings settings, TransportVersion version, ThreadPool threadPool, NetworkService networkService, PageCacheRecycler pageCacheRecycler, NamedWriteableRegistry namedWriteableRegistry, CircuitBreakerService circuitBreakerService, SharedGroupFactory sharedGroupFactory) -
Method Summary
Modifier and TypeMethodDescriptionprotected Netty4TcpServerChannelbind(String name, InetSocketAddress address) protected Recycler<org.apache.lucene.util.BytesRef> createRecycler(Settings settings, PageCacheRecycler pageCacheRecycler) protected voiddoStart()protected io.netty.bootstrap.BootstrapgetClientBootstrap(ConnectionProfile connectionProfile) protected io.netty.channel.ChannelHandlergetClientChannelInitializer(DiscoveryNode node, ConnectionProfile connectionProfile) protected InboundPipelinegetInboundPipeline(io.netty.channel.Channel ch, boolean isRemoteClusterServerChannel) protected io.netty.channel.ChannelHandlerprotected Netty4TcpChannelinitiateChannel(DiscoveryNode node, ConnectionProfile connectionProfile) protected voidMethods inherited from class org.elasticsearch.transport.TcpTransport
addressesFromString, bindServer, boundAddress, boundRemoteIngressAddress, doClose, doStop, executeHandshake, getDefaultSeedAddresses, getInflightBreaker, getProfileSettings, getRequestHandlers, getResponseHandlers, getStats, getStatsTracker, getThreadPool, ignoreDeserializationErrors, inboundMessage, maybeOverrideConnectionProfile, newNetworkBytesStream, onException, onServerException, openConnection, profileBoundAddresses, readMessageLength, serverAcceptedChannel, setMessageListener, setSlowLogThresholdMethods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent
addLifecycleListener, close, lifecycleState, start, stopMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.common.component.LifecycleComponent
addLifecycleListener, lifecycleState, start, stopMethods inherited from interface org.elasticsearch.core.Releasable
closeMethods inherited from interface org.elasticsearch.transport.Transport
isSecure, registerRequestHandler
-
Field Details
-
OPTION_TCP_KEEP_IDLE
-
OPTION_TCP_KEEP_INTERVAL
-
OPTION_TCP_KEEP_COUNT
-
remoteClusterPortEnabled
protected final boolean remoteClusterPortEnabled
-
-
Constructor Details
-
Method Details
-
createRecycler
protected Recycler<org.apache.lucene.util.BytesRef> createRecycler(Settings settings, PageCacheRecycler pageCacheRecycler) - Overrides:
createRecyclerin classTcpTransport
-
doStart
protected void doStart()- Specified by:
doStartin classAbstractLifecycleComponent
-
getServerChannelInitializer
-
getClientChannelInitializer
protected io.netty.channel.ChannelHandler getClientChannelInitializer(DiscoveryNode node, ConnectionProfile connectionProfile) -
initiateChannel
protected Netty4TcpChannel initiateChannel(DiscoveryNode node, ConnectionProfile connectionProfile) throws IOException - Specified by:
initiateChannelin classTcpTransport- Throws:
IOException
-
getClientBootstrap
-
bind
- Specified by:
bindin classTcpTransport
-
stopInternal
protected void stopInternal()- Specified by:
stopInternalin classTcpTransport
-
getInboundPipeline
protected InboundPipeline getInboundPipeline(io.netty.channel.Channel ch, boolean isRemoteClusterServerChannel)
-