Package org.elasticsearch.transport
Interface Transport
-
- All Superinterfaces:
java.lang.AutoCloseable
,java.io.Closeable
,LifecycleComponent
,Releasable
- All Known Implementing Classes:
TcpTransport
public interface Transport extends LifecycleComponent
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
Transport.Connection
A unidirectional connection to aDiscoveryNode
static class
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.static class
Transport.ResponseHandlers
This class is a registry that allows
-
Method Summary
Modifier and Type Method Description TransportAddress[]
addressesFromString(java.lang.String address)
Returns an address from its string representation.BoundTransportAddress
boundAddress()
The address the transport is bound on.java.util.List<java.lang.String>
getDefaultSeedAddresses()
Returns a list of all local addresses for this transportdefault CircuitBreaker
getInFlightRequestBreaker()
RequestHandlerRegistry<? extends TransportRequest>
getRequestHandler(java.lang.String action)
Returns the registered request handler registry for the given action ornull
if it's not registeredTransport.ResponseHandlers
getResponseHandlers()
TransportStats
getStats()
Releasable
openConnection(DiscoveryNode node, ConnectionProfile profile, ActionListener<Transport.Connection> listener)
Opens a new connection to the given node.java.util.Map<java.lang.String,BoundTransportAddress>
profileBoundAddresses()
Further profile bound addresses<Request extends TransportRequest>
voidregisterRequestHandler(RequestHandlerRegistry<Request> reg)
Registers a new request handlervoid
setMessageListener(TransportMessageListener listener)
-
Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent
addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop
-
Methods inherited from interface org.elasticsearch.common.lease.Releasable
close
-
-
-
-
Method Detail
-
registerRequestHandler
<Request extends TransportRequest> void registerRequestHandler(RequestHandlerRegistry<Request> reg)
Registers a new request handler
-
getRequestHandler
RequestHandlerRegistry<? extends TransportRequest> getRequestHandler(java.lang.String action)
Returns the registered request handler registry for the given action ornull
if it's not registered- Parameters:
action
- the action to look up
-
setMessageListener
void setMessageListener(TransportMessageListener listener)
-
boundAddress
BoundTransportAddress boundAddress()
The address the transport is bound on.
-
profileBoundAddresses
java.util.Map<java.lang.String,BoundTransportAddress> profileBoundAddresses()
Further profile bound addresses- Returns:
null
iff profiles are unsupported, otherwise a map with name of profile and its bound transport address
-
addressesFromString
TransportAddress[] addressesFromString(java.lang.String address) throws java.net.UnknownHostException
Returns an address from its string representation.- Throws:
java.net.UnknownHostException
-
getDefaultSeedAddresses
java.util.List<java.lang.String> getDefaultSeedAddresses()
Returns a list of all local addresses for this transport
-
getInFlightRequestBreaker
default CircuitBreaker getInFlightRequestBreaker()
-
openConnection
Releasable openConnection(DiscoveryNode node, ConnectionProfile profile, ActionListener<Transport.Connection> listener)
Opens a new connection to the given node. When the connection is fully connected, the listener is called. AReleasable
is returned representing the pending connection. If the caller of this method decides to move on before the listener is called with the completed connection, they should release the pending connection to prevent hanging connections.
-
getStats
TransportStats getStats()
-
getResponseHandlers
Transport.ResponseHandlers getResponseHandlers()
-
-