BytesTransportRequest |
A specialized, bytes only request, that can potentially be optimized on the network
layer, specifically for the same large buffer send to several nodes.
|
CloseableConnection |
Abstract Transport.Connection that provides common close logic.
|
ConnectionManager |
This class manages node connections.
|
ConnectionProfile |
A connection profile describes how many connection are established to specific node for each of the available request types.
|
ConnectionProfile.Builder |
|
EmptyTransportResponseHandler |
|
FutureTransportResponseHandler<T extends TransportResponse> |
A response handler to be used when all interaction will be done through the TransportFuture .
|
InboundHandler |
|
InboundMessage |
|
InboundMessage.Request |
|
InboundMessage.Response |
|
NetworkMessage |
Represents a transport message sent over the network.
|
PlainTransportFuture<V extends TransportResponse> |
|
ProxyConnectionStrategy |
|
ProxyConnectionStrategy.ProxyModeInfo |
|
RemoteClusterAware |
Base class for all services and components that need up-to-date information about the registered remote clusters
|
RemoteClusterService |
Basic service for accessing remote clusters via gateway nodes
|
RemoteConnectionInfo |
This class encapsulates all remote cluster information to be rendered on
_remote/info requests.
|
RemoteConnectionManager |
|
RemoteConnectionStrategy |
|
RequestHandlerRegistry<Request extends TransportRequest> |
|
SniffConnectionStrategy |
|
SniffConnectionStrategy.SniffModeInfo |
|
TaskTransportChannel |
|
TcpChannel.ChannelStats |
|
TcpHeader |
|
TcpTransport |
|
TcpTransport.ProfileSettings |
Representation of a transport profile settings for a transport.profiles.$profilename.*
|
TcpTransportChannel |
|
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.
|
Transport.ResponseHandlers |
This class is a registry that allows
|
TransportActionProxy |
TransportActionProxy 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.
|
TransportInfo |
|
TransportLogger |
|
TransportMessage |
|
TransportRequest |
|
TransportRequest.Empty |
|
TransportRequestDeduplicator<T extends TransportRequest> |
|
TransportRequestOptions |
|
TransportRequestOptions.Builder |
|
TransportResponse |
|
TransportResponse.Empty |
|
TransportService |
|
TransportService.ContextRestoreResponseHandler<T extends TransportResponse> |
This handler wrapper ensures that the response thread executes with the correct thread context.
|
TransportService.HandshakeResponse |
|
TransportSettings |
|
TransportStats |
|
TransportStatus |
|