Package org.elasticsearch.transport
Interface ConnectionManager
- All Superinterfaces:
java.lang.AutoCloseable,java.io.Closeable
- All Known Implementing Classes:
ClusterConnectionManager,RemoteConnectionManager
public interface ConnectionManager
extends java.io.Closeable
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceConnectionManager.ConnectionValidatorstatic classConnectionManager.DelegatingNodeConnectionListener -
Method Summary
Modifier and Type Method Description voidaddListener(TransportConnectionListener listener)voidclose()voidcloseNoBlock()voidconnectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, ActionListener<java.lang.Void> listener)voiddisconnectFromNode(DiscoveryNode node)java.util.Set<DiscoveryNode>getAllConnectedNodes()Transport.ConnectiongetConnection(DiscoveryNode node)ConnectionProfilegetConnectionProfile()booleannodeConnected(DiscoveryNode node)voidopenConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener)voidremoveListener(TransportConnectionListener listener)intsize()
-
Method Details
-
addListener
-
removeListener
-
openConnection
void openConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener) -
connectToNode
void connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, ActionListener<java.lang.Void> listener) throws ConnectTransportException- Throws:
ConnectTransportException
-
getConnection
-
nodeConnected
-
disconnectFromNode
-
getAllConnectedNodes
java.util.Set<DiscoveryNode> getAllConnectedNodes() -
size
int size() -
close
void close()- Specified by:
closein interfacejava.lang.AutoCloseable- Specified by:
closein interfacejava.io.Closeable
-
closeNoBlock
void closeNoBlock() -
getConnectionProfile
ConnectionProfile getConnectionProfile()
-