org.elasticsearch.transport

Class TransportService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.transport.TransportService

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, LifecycleComponent, Releasable

public class TransportService
extends AbstractLifecycleComponent

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TransportService.Adapter
static class	TransportService.ContextRestoreResponseHandler<T extends TransportResponse> This handler wrapper ensures that the response thread executes with the correct thread context.
static class	TransportService.HandshakeResponse

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterName	clusterName
static java.lang.String	DIRECT_RESPONSE_PROFILE
static java.lang.String	HANDSHAKE_ACTION_NAME
static TransportInterceptor	NOOP_TRANSPORT_INTERCEPTOR
protected TaskManager	taskManager
protected ThreadPool	threadPool
static Setting<java.util.List<java.lang.String>>	TRACE_LOG_EXCLUDE_SETTING
static Setting<java.util.List<java.lang.String>>	TRACE_LOG_INCLUDE_SETTING
protected Transport	transport

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

lifecycle

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

deprecationLogger, logger, settings

Constructor Summary

Constructors

Constructor and Description
TransportService(Settings settings, Transport transport, ThreadPool threadPool, TransportInterceptor transportInterceptor, java.util.function.Function<BoundTransportAddress,DiscoveryNode> localNodeFactory, ClusterSettings clusterSettings) Build the service.

Method Summary

Modifier and Type	Method and Description
void	acceptIncomingRequests() start accepting incoming requests.
void	addConnectionListener(TransportConnectionListener listener)
TransportAddress[]	addressesFromString(java.lang.String address, int perAddressLimit)
boolean	addressSupported(java.lang.Class<? extends TransportAddress> address)
BoundTransportAddress	boundAddress()
void	connectToNode(DiscoveryNode node)
void	connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile) Connect to the specified node with the given connection profile
protected TransportService.Adapter	createAdapter()
protected TaskManager	createTaskManager()
void	disconnectFromNode(DiscoveryNode node)
protected void	doClose()
protected void	doStart()
protected void	doStop()
Transport.Connection	getConnection(DiscoveryNode node) Returns either a real transport connection or a local node connection if we are using the local node optimization.
protected java.util.concurrent.ExecutorService	getExecutorService() The executor service for this transport service.
java.util.List<java.lang.String>	getLocalAddresses()
DiscoveryNode	getLocalNode()
RemoteClusterService	getRemoteClusterService()
protected RequestHandlerRegistry	getRequestHandler(java.lang.String action)
TaskManager	getTaskManager()
ThreadPool	getThreadPool() Returns the internal thread pool
DiscoveryNode	handshake(Transport.Connection connection, long handshakeTimeout) Executes a high-level handshake using the given connection and returns the discovery node of the node the connection was established with.
TransportService.HandshakeResponse	handshake(Transport.Connection connection, long handshakeTimeout, java.util.function.Predicate<ClusterName> clusterNamePredicate) Executes a high-level handshake using the given connection and returns the discovery node of the node the connection was established with.
TransportInfo	info()
boolean	nodeConnected(DiscoveryNode node) Returns true iff the given node is already connected.
Transport.Connection	openConnection(DiscoveryNode node, ConnectionProfile profile) Establishes and returns a new connection to the given node.
<Request extends TransportRequest> void	registerRequestHandler(java.lang.String action, java.util.function.Supplier<Request> request, java.lang.String executor, boolean forceExecution, boolean canTripCircuitBreaker, TransportRequestHandler<Request> handler) Registers a new request handler
<Request extends TransportRequest> void	registerRequestHandler(java.lang.String action, java.util.function.Supplier<Request> requestFactory, java.lang.String executor, TransportRequestHandler<Request> handler) Registers a new request handler
void	removeConnectionListener(TransportConnectionListener listener)
<T extends TransportResponse> void	sendChildRequest(Transport.Connection connection, java.lang.String action, TransportRequest request, Task parentTask, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendChildRequest(Transport.Connection connection, java.lang.String action, TransportRequest request, Task parentTask, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendRequest(Transport.Connection connection, java.lang.String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
TransportStats	stats()
<T extends TransportResponse> TransportFuture<T>	submitRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> TransportFuture<T>	submitRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, TransportResponseHandler<T> handler)

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

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

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

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class java.lang.Object

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

Field Detail

DIRECT_RESPONSE_PROFILE

public static final java.lang.String DIRECT_RESPONSE_PROFILE

See Also:

Constant Field Values

HANDSHAKE_ACTION_NAME

public static final java.lang.String HANDSHAKE_ACTION_NAME

See Also:

Constant Field Values

transport

protected final Transport transport

threadPool

protected final ThreadPool threadPool

clusterName

protected final ClusterName clusterName

taskManager

protected final TaskManager taskManager

NOOP_TRANSPORT_INTERCEPTOR

public static final TransportInterceptor NOOP_TRANSPORT_INTERCEPTOR

TRACE_LOG_INCLUDE_SETTING

public static final Setting<java.util.List<java.lang.String>> TRACE_LOG_INCLUDE_SETTING

TRACE_LOG_EXCLUDE_SETTING

public static final Setting<java.util.List<java.lang.String>> TRACE_LOG_EXCLUDE_SETTING

Constructor Detail

TransportService

public TransportService(Settings settings,
                        Transport transport,
                        ThreadPool threadPool,
                        TransportInterceptor transportInterceptor,
                        java.util.function.Function<BoundTransportAddress,DiscoveryNode> localNodeFactory,
                        @Nullable
                        ClusterSettings clusterSettings)

Build the service.

Parameters:

clusterSettings - if non null the the TransportService will register with the ClusterSettings for settings updates for TRACE_LOG_EXCLUDE_SETTING and TRACE_LOG_INCLUDE_SETTING.

Method Detail

getRemoteClusterService

public RemoteClusterService getRemoteClusterService()

getLocalNode

public DiscoveryNode getLocalNode()

getTaskManager

public TaskManager getTaskManager()

createAdapter

protected TransportService.Adapter createAdapter()

createTaskManager

protected TaskManager createTaskManager()

getExecutorService

protected java.util.concurrent.ExecutorService getExecutorService()

The executor service for this transport service.

Returns:

the executor service

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()
                throws java.io.IOException

Specified by:

doClose in class AbstractLifecycleComponent

Throws:

java.io.IOException

acceptIncomingRequests

public final void acceptIncomingRequests()

start accepting incoming requests. when the transport layer starts up it will block any incoming requests until this method is called

addressSupported

public final boolean addressSupported(java.lang.Class<? extends TransportAddress> address)

info

public TransportInfo info()

stats

public TransportStats stats()

boundAddress

public BoundTransportAddress boundAddress()

getLocalAddresses

public java.util.List<java.lang.String> getLocalAddresses()

nodeConnected

public boolean nodeConnected(DiscoveryNode node)

Returns true iff the given node is already connected.

connectToNode

public void connectToNode(DiscoveryNode node)
                   throws ConnectTransportException

Throws:

ConnectTransportException

connectToNode

public void connectToNode(DiscoveryNode node,
                          ConnectionProfile connectionProfile)

Connect to the specified node with the given connection profile

Parameters:

node - the node to connect to

connectionProfile - the connection profile to use when connecting to this node

openConnection

public Transport.Connection openConnection(DiscoveryNode node,
                                           ConnectionProfile profile)
                                    throws java.io.IOException

Establishes and returns a new connection to the given node. The connection is NOT maintained by this service, it's the callers responsibility to close the connection once it goes out of scope.

Parameters:

node - the node to connect to

profile - the connection profile to use

Throws:

java.io.IOException

handshake

public DiscoveryNode handshake(Transport.Connection connection,
                               long handshakeTimeout)
                        throws ConnectTransportException

Executes a high-level handshake using the given connection and returns the discovery node of the node the connection was established with. The handshake will fail if the cluster name on the target node mismatches the local cluster name.

Parameters:

connection - the connection to a specific node

handshakeTimeout - handshake timeout

Returns:

the connected node

Throws:

ConnectTransportException - if the connection failed

java.lang.IllegalStateException - if the handshake failed

handshake

public TransportService.HandshakeResponse handshake(Transport.Connection connection,
                                                    long handshakeTimeout,
                                                    java.util.function.Predicate<ClusterName> clusterNamePredicate)
                                             throws ConnectTransportException

Executes a high-level handshake using the given connection and returns the discovery node of the node the connection was established with. The handshake will fail if the cluster name on the target node doesn't match the local cluster name.

Parameters:

connection - the connection to a specific node

handshakeTimeout - handshake timeout

clusterNamePredicate - cluster name validation predicate

Returns:

the handshake response

Throws:

ConnectTransportException - if the connection failed

java.lang.IllegalStateException - if the handshake failed

disconnectFromNode

public void disconnectFromNode(DiscoveryNode node)

addConnectionListener

public void addConnectionListener(TransportConnectionListener listener)

removeConnectionListener

public void removeConnectionListener(TransportConnectionListener listener)

submitRequest

public <T extends TransportResponse> TransportFuture<T> submitRequest(DiscoveryNode node,
                                                                      java.lang.String action,
                                                                      TransportRequest request,
                                                                      TransportResponseHandler<T> handler)
                                                               throws TransportException

Throws:

TransportException

submitRequest

public <T extends TransportResponse> TransportFuture<T> submitRequest(DiscoveryNode node,
                                                                      java.lang.String action,
                                                                      TransportRequest request,
                                                                      TransportRequestOptions options,
                                                                      TransportResponseHandler<T> handler)
                                                               throws TransportException

Throws:

TransportException

sendRequest

public <T extends TransportResponse> void sendRequest(DiscoveryNode node,
                                                      java.lang.String action,
                                                      TransportRequest request,
                                                      TransportResponseHandler<T> handler)

sendRequest

public final <T extends TransportResponse> void sendRequest(DiscoveryNode node,
                                                            java.lang.String action,
                                                            TransportRequest request,
                                                            TransportRequestOptions options,
                                                            TransportResponseHandler<T> handler)

sendRequest

public final <T extends TransportResponse> void sendRequest(Transport.Connection connection,
                                                            java.lang.String action,
                                                            TransportRequest request,
                                                            TransportRequestOptions options,
                                                            TransportResponseHandler<T> handler)

getConnection

public Transport.Connection getConnection(DiscoveryNode node)

Returns either a real transport connection or a local node connection if we are using the local node optimization.

Throws:

NodeNotConnectedException - if the given node is not connected

sendChildRequest

public <T extends TransportResponse> void sendChildRequest(Transport.Connection connection,
                                                           java.lang.String action,
                                                           TransportRequest request,
                                                           Task parentTask,
                                                           TransportResponseHandler<T> handler)

sendChildRequest

public <T extends TransportResponse> void sendChildRequest(Transport.Connection connection,
                                                           java.lang.String action,
                                                           TransportRequest request,
                                                           Task parentTask,
                                                           TransportRequestOptions options,
                                                           TransportResponseHandler<T> handler)

addressesFromString

public TransportAddress[] addressesFromString(java.lang.String address,
                                              int perAddressLimit)
                                       throws java.net.UnknownHostException

Throws:

java.net.UnknownHostException

registerRequestHandler

public <Request extends TransportRequest> void registerRequestHandler(java.lang.String action,
                                                                      java.util.function.Supplier<Request> requestFactory,
                                                                      java.lang.String executor,
                                                                      TransportRequestHandler<Request> handler)

Registers a new request handler

Parameters:

action - The action the request handler is associated with

requestFactory - a callable to be used construct new instances for streaming

executor - The executor the request handling will be executed on

handler - The handler itself that implements the request handling

registerRequestHandler

public <Request extends TransportRequest> void registerRequestHandler(java.lang.String action,
                                                                      java.util.function.Supplier<Request> request,
                                                                      java.lang.String executor,
                                                                      boolean forceExecution,
                                                                      boolean canTripCircuitBreaker,
                                                                      TransportRequestHandler<Request> handler)

Registers a new request handler

Parameters:

action - The action the request handler is associated with

request - The request class that will be used to construct new instances for streaming

executor - The executor the request handling will be executed on

forceExecution - Force execution on the executor queue and never reject it

canTripCircuitBreaker - Check the request size and raise an exception in case the limit is breached.

handler - The handler itself that implements the request handling

getRequestHandler

protected RequestHandlerRegistry getRequestHandler(java.lang.String action)

getThreadPool

public ThreadPool getThreadPool()

Returns the internal thread pool