Package org.elasticsearch.transport
package org.elasticsearch.transport
-
Interface SummaryInterfaceDescriptionRequests that implement this interface will be compressed when
TransportSettings.TRANSPORT_COMPRESSis configured toCompression.Enabled.INDEXING_DATAand isRawIndexingData() returns true.This is a tcp channel representing a single channel connection to another node.This is a tcp channel representing a server channel listening for new connections.A unidirectional connection to aDiscoveryNodeA transport channel allows to send a response to a request on the channel.A listener interface that allows to react on transport events.This interface allows plugins to intercept requests on both the sender and the receiver side.TransportRequestHandler<T extends TransportRequest>TransportResponseHandler<T extends TransportResponse> -
Class SummaryClassDescriptionA specialized, bytes only request, that can potentially be optimized on the network layer, specifically for the same large buffer send to several nodes.Abstract Transport.Connection that provides common close logic.This class manages node connections within a cluster.A connection profile describes how many connection are established to specific node for each of the available request types.A builder to build a new
ConnectionProfileFutureTransportResponseHandler<T extends TransportResponse>A response handler to be used when all interaction will be done through theTransportFuture.Handles inbound messages by first deserializing aTransportMessagefrom anInboundMessageand then passing it to the appropriate handler.This file is forked from the https://netty.io project.Represents a transport message sent over the network.PlainTransportFuture<V extends TransportResponse>Base class for all services and components that need up-to-date information about the registered remote clustersBasic service for accessing remote clusters via gateway nodesThis class encapsulates all remote cluster information to be rendered on_remote/inforequests.RequestHandlerRegistry<Request extends TransportRequest>This file is forked from https://github.com/lz4/lz4-java.Representation of a transport profile settings for atransport.profiles.$profilename.*Transport.ResponseContext<T extends TransportResponse>This class represents a response context that encapsulates the actual response handler, the action and the connection it was executed on.This class is a registry that allowsTransportActionProxy allows an arbitrary action to be executed on a defined target node while the initial request is sent to a second node that acts as a request proxy to the target node.Implementations ofTransportResponseHandlerthat handles the empty responseTransportResponse.Empty.This handler wrapper ensures that the response thread executes with the correct thread context. -
Enum Class SummaryEnum ClassDescription
-
Exception SummaryExceptionDescriptionAn exception indicating that a transport action was not found.An action invocation failure.An exception indicating that a message is sent to a node that is not connected.Thrown after failed to connect to all seed nodes of the remote cluster.An exception that remote cluster is missing or connectivity to the remote connection is failingA remote exception for an action.A failure to handle the response of a transaction action.A helper exception to mark an incoming connection as potentially being HTTP so an appropriate error code can be returnedException indicating that the
TransportServicereceived a request before it was ready to handle it, so the request should be rejected and the connection closed.