Package org.elasticsearch.xpack.core.security.transport.netty4

Class SecurityNetty4Transport

java.lang.Object
org.elasticsearch.common.component.AbstractLifecycleComponent
org.elasticsearch.transport.TcpTransport
org.elasticsearch.transport.netty4.Netty4Transport
org.elasticsearch.xpack.core.security.transport.netty4.SecurityNetty4Transport
All Implemented Interfaces:
Closeable, AutoCloseable, org.elasticsearch.common.component.LifecycleComponent, org.elasticsearch.core.Releasable, org.elasticsearch.transport.Transport
Direct Known Subclasses:
SecurityNetty4ServerTransport
public class SecurityNetty4Transport extends org.elasticsearch.transport.netty4.Netty4Transport
Implementation of a transport that extends the Netty4Transport to add SSL and IP Filtering

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    class 
    SecurityNetty4Transport.SslChannelInitializer
     

    Nested classes/interfaces inherited from class org.elasticsearch.transport.netty4.Netty4Transport

    org.elasticsearch.transport.netty4.Netty4Transport.ClientChannelInitializer, org.elasticsearch.transport.netty4.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 inherited from class org.elasticsearch.transport.netty4.Netty4Transport

    NETTY_BOSS_COUNT, NETTY_RECEIVE_PREDICTOR_MAX, NETTY_RECEIVE_PREDICTOR_MIN, NETTY_RECEIVE_PREDICTOR_SIZE, WORKER_COUNT

    Fields inherited from class org.elasticsearch.transport.TcpTransport

    networkService, profileSettingsSet, recycler, rstOnClose, settings, threadPool, TRANSPORT_WORKER_THREAD_NAME_PREFIX

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

    lifecycle

  • Constructor Summary

    Constructors
    Constructor
    Description
    SecurityNetty4Transport(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, org.elasticsearch.xpack.core.ssl.SSLService sslService, org.elasticsearch.transport.netty4.SharedGroupFactory sharedGroupFactory)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    doStart()
     
    protected io.netty.channel.ChannelHandler
    getClientChannelInitializer(org.elasticsearch.cluster.node.DiscoveryNode node)
     
    protected io.netty.channel.ChannelHandler
    getNoSslChannelInitializer(String name)
     
    final io.netty.channel.ChannelHandler
    getServerChannelInitializer(String name)
     
    protected org.elasticsearch.transport.netty4.Netty4Transport.ServerChannelInitializer
    getSslChannelInitializer(String name, org.elasticsearch.common.ssl.SslConfiguration configuration)
     
    boolean
    isSecure()
     
    void
    onException(org.elasticsearch.transport.TcpChannel channel, Exception e)
     

    Methods inherited from class org.elasticsearch.transport.netty4.Netty4Transport

    bind, createRecycler, initiateChannel, stopInternal

    Methods inherited from class org.elasticsearch.transport.TcpTransport

    addressesFromString, bindServer, boundAddress, doClose, doStop, executeHandshake, getDefaultSeedAddresses, getInflightBreaker, getProfileSettings, getRequestHandlers, getResponseHandlers, getStats, getStatsTracker, getThreadPool, getVersion, ignoreDeserializationErrors, inboundMessage, maybeOverrideConnectionProfile, newNetworkBytesStream, 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.core.Releasable

    close

    Methods inherited from interface org.elasticsearch.transport.Transport

    registerRequestHandler

  • Constructor Details

    • SecurityNetty4Transport

      public SecurityNetty4Transport(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, org.elasticsearch.xpack.core.ssl.SSLService sslService, org.elasticsearch.transport.netty4.SharedGroupFactory sharedGroupFactory)

  • Method Details

    • doStart

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

    • getServerChannelInitializer

      public final io.netty.channel.ChannelHandler getServerChannelInitializer(String name)
      Overrides:
      getServerChannelInitializer in class org.elasticsearch.transport.netty4.Netty4Transport

    • getNoSslChannelInitializer

      protected io.netty.channel.ChannelHandler getNoSslChannelInitializer(String name)

    • getClientChannelInitializer

      protected io.netty.channel.ChannelHandler getClientChannelInitializer(org.elasticsearch.cluster.node.DiscoveryNode node)
      Overrides:
      getClientChannelInitializer in class org.elasticsearch.transport.netty4.Netty4Transport

    • onException

      public void onException(org.elasticsearch.transport.TcpChannel channel, Exception e)
      Overrides:
      onException in class org.elasticsearch.transport.TcpTransport

    • getSslChannelInitializer

      protected org.elasticsearch.transport.netty4.Netty4Transport.ServerChannelInitializer getSslChannelInitializer(String name, org.elasticsearch.common.ssl.SslConfiguration configuration)

    • isSecure

      public boolean isSecure()