Module org.elasticsearch.security
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,LifecycleComponent,org.elasticsearch.core.Releasable,Transport
- Direct Known Subclasses:
SecurityNetty4ServerTransport
Implementation of a transport that extends the
Netty4Transport to add SSL and IP Filtering-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from class org.elasticsearch.transport.netty4.Netty4Transport
Netty4Transport.ClientChannelInitializer, Netty4Transport.ServerChannelInitializerNested 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
Fields inherited from class org.elasticsearch.transport.netty4.Netty4Transport
OPTION_TCP_KEEP_COUNT, OPTION_TCP_KEEP_IDLE, OPTION_TCP_KEEP_INTERVAL, remoteClusterPortEnabledFields 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
ConstructorsConstructorDescriptionSecurityNetty4Transport(Settings settings, TransportVersion version, ThreadPool threadPool, NetworkService networkService, PageCacheRecycler pageCacheRecycler, NamedWriteableRegistry namedWriteableRegistry, CircuitBreakerService circuitBreakerService, SSLService sslService, SharedGroupFactory sharedGroupFactory, CrossClusterAccessAuthenticationService crossClusterAccessAuthenticationService) -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoStart()protected io.netty.bootstrap.BootstrapgetClientBootstrap(ConnectionProfile connectionProfile) protected io.netty.channel.ChannelHandlergetClientChannelInitializer(DiscoveryNode node, ConnectionProfile connectionProfile) protected InboundPipelinegetInboundPipeline(io.netty.channel.Channel channel, boolean isRemoteClusterServerChannel) protected io.netty.channel.ChannelHandlerfinal io.netty.channel.ChannelHandlerprotected Netty4Transport.ServerChannelInitializergetSslChannelInitializer(String name, org.elasticsearch.common.ssl.SslConfiguration configuration) booleanisSecure()voidonException(TcpChannel channel, Exception e) Methods inherited from class org.elasticsearch.transport.netty4.Netty4Transport
bind, createRecycler, initiateChannel, stopInternalMethods 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, 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
registerRequestHandler
-
Constructor Details
-
Method Details
-
doStart
protected void doStart()- Overrides:
doStartin classNetty4Transport
-
getServerChannelInitializer
- Overrides:
getServerChannelInitializerin classNetty4Transport
-
getNoSslChannelInitializer
-
getClientChannelInitializer
protected io.netty.channel.ChannelHandler getClientChannelInitializer(DiscoveryNode node, ConnectionProfile connectionProfile) - Overrides:
getClientChannelInitializerin classNetty4Transport
-
getInboundPipeline
protected InboundPipeline getInboundPipeline(io.netty.channel.Channel channel, boolean isRemoteClusterServerChannel) - Overrides:
getInboundPipelinein classNetty4Transport
-
getClientBootstrap
- Overrides:
getClientBootstrapin classNetty4Transport
-
onException
- Overrides:
onExceptionin classTcpTransport
-
getSslChannelInitializer
protected Netty4Transport.ServerChannelInitializer getSslChannelInitializer(String name, org.elasticsearch.common.ssl.SslConfiguration configuration) -
isSecure
public boolean isSecure()
-