Package org.elasticsearch.transport.netty4

Class Netty4Transport

java.lang.Object
org.elasticsearch.common.component.AbstractLifecycleComponent
org.elasticsearch.transport.TcpTransport
org.elasticsearch.transport.netty4.Netty4Transport
All Implemented Interfaces:
java.io.Closeable, java.lang.AutoCloseable, org.elasticsearch.common.component.LifecycleComponent, org.elasticsearch.common.lease.Releasable, org.elasticsearch.transport.Transport
public class Netty4Transport
extends org.elasticsearch.transport.TcpTransport
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 Classes 
    Modifier and Type Class Description
    protected class  Netty4Transport.ClientChannelInitializer  
    protected class  Netty4Transport.ServerChannelInitializer  

    Nested classes/interfaces inherited from class org.elasticsearch.transport.TcpTransport

    org.elasticsearch.transport.TcpTransport.HttpRequestOnTransportException, org.elasticsearch.transport.TcpTransport.NodeChannels, org.elasticsearch.transport.TcpTransport.ProfileSettings

    Nested classes/interfaces inherited from interface org.elasticsearch.transport.Transport

    org.elasticsearch.transport.Transport.Connection, org.elasticsearch.transport.Transport.RequestHandlers, org.elasticsearch.transport.Transport.ResponseContext<T extends org.elasticsearch.transport.TransportResponse>, org.elasticsearch.transport.Transport.ResponseHandlers

  • Field Summary

    Fields 
    Modifier and Type Field Description
    static org.elasticsearch.common.settings.Setting<java.lang.Integer> NETTY_BOSS_COUNT  
    static org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue> NETTY_RECEIVE_PREDICTOR_MAX  
    static org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue> NETTY_RECEIVE_PREDICTOR_MIN  
    static org.elasticsearch.common.settings.Setting<org.elasticsearch.common.unit.ByteSizeValue> NETTY_RECEIVE_PREDICTOR_SIZE  
    static org.elasticsearch.common.settings.Setting<java.lang.Integer> WORKER_COUNT  

    Fields inherited from class org.elasticsearch.transport.TcpTransport

    networkService, pageCacheRecycler, profileSettings, settings, threadPool, TRANSPORT_WORKER_THREAD_NAME_PREFIX

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

    lifecycle

  • Constructor Summary

    Constructors 
    Constructor Description
    Netty4Transport​(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.Version version, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.common.network.NetworkService networkService, org.elasticsearch.common.util.PageCacheRecycler pageCacheRecycler, org.elasticsearch.common.io.stream.NamedWriteableRegistry namedWriteableRegistry, org.elasticsearch.indices.breaker.CircuitBreakerService circuitBreakerService, SharedGroupFactory sharedGroupFactory)  

  • Method Summary

    Modifier and Type Method Description
    protected Netty4TcpServerChannel bind​(java.lang.String name, java.net.InetSocketAddress address)  
    protected void doStart()  
    protected io.netty.channel.ChannelHandler getClientChannelInitializer​(org.elasticsearch.cluster.node.DiscoveryNode node)  
    protected io.netty.channel.ChannelHandler getServerChannelInitializer​(java.lang.String name)  
    protected Netty4TcpChannel initiateChannel​(org.elasticsearch.cluster.node.DiscoveryNode node)  
    protected void stopInternal()  

    Methods inherited from class org.elasticsearch.transport.TcpTransport

    addressesFromString, bindServer, boundAddress, doClose, doStop, executeHandshake, getDefaultSeedAddresses, getInflightBreaker, getProfileSettings, getRequestHandlers, getResponseHandlers, getStats, getStatsTracker, getThreadPool, getVersion, inboundMessage, maybeOverrideConnectionProfile, onException, onServerException, openConnection, profileBoundAddresses, readMessageLength, serverAcceptedChannel, setMessageListener, setSlowLogThreshold

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

    addLifecycleListener, close, 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.component.LifecycleComponent

    addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

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

    close

    Methods inherited from interface org.elasticsearch.transport.Transport

    isSecure, registerRequestHandler

  • Field Details

    • WORKER_COUNT

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

    • NETTY_RECEIVE_PREDICTOR_SIZE

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

    • NETTY_RECEIVE_PREDICTOR_MIN

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

    • NETTY_RECEIVE_PREDICTOR_MAX

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

    • NETTY_BOSS_COUNT

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

  • Constructor Details

    • Netty4Transport

      public Netty4Transport​(org.elasticsearch.common.settings.Settings settings, org.elasticsearch.Version version, org.elasticsearch.threadpool.ThreadPool threadPool, org.elasticsearch.common.network.NetworkService networkService, org.elasticsearch.common.util.PageCacheRecycler pageCacheRecycler, org.elasticsearch.common.io.stream.NamedWriteableRegistry namedWriteableRegistry, org.elasticsearch.indices.breaker.CircuitBreakerService circuitBreakerService, SharedGroupFactory sharedGroupFactory)

  • Method Details

    • doStart

      protected void doStart()
      Overrides:
      doStart in class org.elasticsearch.transport.TcpTransport

    • getServerChannelInitializer

      protected io.netty.channel.ChannelHandler getServerChannelInitializer​(java.lang.String name)

    • getClientChannelInitializer

      protected io.netty.channel.ChannelHandler getClientChannelInitializer​(org.elasticsearch.cluster.node.DiscoveryNode node)

    • initiateChannel

      protected Netty4TcpChannel initiateChannel​(org.elasticsearch.cluster.node.DiscoveryNode node) throws java.io.IOException
      Specified by:
      initiateChannel in class org.elasticsearch.transport.TcpTransport
      Throws:
      java.io.IOException

    • bind

      protected Netty4TcpServerChannel bind​(java.lang.String name, java.net.InetSocketAddress address)
      Specified by:
      bind in class org.elasticsearch.transport.TcpTransport

    • stopInternal

      protected void stopInternal()
      Specified by:
      stopInternal in class org.elasticsearch.transport.TcpTransport