Class StubbableConnectionManager

java.lang.Object

org.opensearch.test.transport.StubbableConnectionManager

All Implemented Interfaces:

Closeable, AutoCloseable, org.opensearch.transport.ConnectionManager

public class StubbableConnectionManager
extends Object
implements org.opensearch.transport.ConnectionManager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	StubbableConnectionManager.GetConnectionBehavior
static interface	StubbableConnectionManager.NodeConnectedBehavior

Nested classes/interfaces inherited from interface org.opensearch.transport.ConnectionManager

org.opensearch.transport.ConnectionManager.ConnectionValidator, org.opensearch.transport.ConnectionManager.DelegatingNodeConnectionListener

Constructor Summary

Constructors

Constructor	Description
StubbableConnectionManager(org.opensearch.transport.ConnectionManager delegate)

Method Summary

Modifier and Type	Method	Description
boolean	addGetConnectionBehavior(org.opensearch.core.common.transport.TransportAddress transportAddress, StubbableConnectionManager.GetConnectionBehavior connectBehavior)
void	addListener(org.opensearch.transport.TransportConnectionListener listener)
void	clearBehavior(org.opensearch.core.common.transport.TransportAddress transportAddress)
void	clearBehaviors()
void	clearPendingDisconnections()
void	close()
void	closeNoBlock()
void	connectToNode(org.opensearch.cluster.node.DiscoveryNode node, org.opensearch.transport.ConnectionProfile connectionProfile, org.opensearch.transport.ConnectionManager.ConnectionValidator connectionValidator, org.opensearch.core.action.ActionListener<Void> listener)
void	disconnectFromNode(org.opensearch.cluster.node.DiscoveryNode node)
Set<org.opensearch.cluster.node.DiscoveryNode>	getAllConnectedNodes()
org.opensearch.transport.Transport.Connection	getConnection(org.opensearch.cluster.node.DiscoveryNode node)
org.opensearch.transport.ConnectionProfile	getConnectionProfile()
boolean	nodeConnected(org.opensearch.cluster.node.DiscoveryNode node)
void	openConnection(org.opensearch.cluster.node.DiscoveryNode node, org.opensearch.transport.ConnectionProfile connectionProfile, org.opensearch.core.action.ActionListener<org.opensearch.transport.Transport.Connection> listener)
void	removeListener(org.opensearch.transport.TransportConnectionListener listener)
boolean	setDefaultGetConnectionBehavior(StubbableConnectionManager.GetConnectionBehavior behavior)
boolean	setDefaultNodeConnectedBehavior(StubbableConnectionManager.NodeConnectedBehavior behavior)
void	setPendingDisconnection(org.opensearch.cluster.node.DiscoveryNode node)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Details

StubbableConnectionManager

public StubbableConnectionManager(org.opensearch.transport.ConnectionManager delegate)

Method Details

addGetConnectionBehavior

public boolean addGetConnectionBehavior(org.opensearch.core.common.transport.TransportAddress transportAddress,
 StubbableConnectionManager.GetConnectionBehavior connectBehavior)

setDefaultGetConnectionBehavior

public boolean setDefaultGetConnectionBehavior(StubbableConnectionManager.GetConnectionBehavior behavior)

setDefaultNodeConnectedBehavior

public boolean setDefaultNodeConnectedBehavior(StubbableConnectionManager.NodeConnectedBehavior behavior)

clearBehaviors

public void clearBehaviors()

clearBehavior

public void clearBehavior(org.opensearch.core.common.transport.TransportAddress transportAddress)

openConnection

public void openConnection(org.opensearch.cluster.node.DiscoveryNode node,
 org.opensearch.transport.ConnectionProfile connectionProfile,
 org.opensearch.core.action.ActionListener<org.opensearch.transport.Transport.Connection> listener)

Specified by:

openConnection in interface org.opensearch.transport.ConnectionManager

getConnection

public org.opensearch.transport.Transport.Connection getConnection(org.opensearch.cluster.node.DiscoveryNode node)

Specified by:

getConnection in interface org.opensearch.transport.ConnectionManager

nodeConnected

public boolean nodeConnected(org.opensearch.cluster.node.DiscoveryNode node)

Specified by:

nodeConnected in interface org.opensearch.transport.ConnectionManager

addListener

public void addListener(org.opensearch.transport.TransportConnectionListener listener)

Specified by:

addListener in interface org.opensearch.transport.ConnectionManager

removeListener

public void removeListener(org.opensearch.transport.TransportConnectionListener listener)

Specified by:

removeListener in interface org.opensearch.transport.ConnectionManager

connectToNode

public void connectToNode(org.opensearch.cluster.node.DiscoveryNode node,
 org.opensearch.transport.ConnectionProfile connectionProfile,
 org.opensearch.transport.ConnectionManager.ConnectionValidator connectionValidator,
 org.opensearch.core.action.ActionListener<Void> listener)
                   throws org.opensearch.transport.ConnectTransportException

Specified by:

connectToNode in interface org.opensearch.transport.ConnectionManager

Throws:

org.opensearch.transport.ConnectTransportException

disconnectFromNode

public void disconnectFromNode(org.opensearch.cluster.node.DiscoveryNode node)

Specified by:

disconnectFromNode in interface org.opensearch.transport.ConnectionManager

setPendingDisconnection

public void setPendingDisconnection(org.opensearch.cluster.node.DiscoveryNode node)

Specified by:

setPendingDisconnection in interface org.opensearch.transport.ConnectionManager

clearPendingDisconnections

public void clearPendingDisconnections()

Specified by:

clearPendingDisconnections in interface org.opensearch.transport.ConnectionManager

size

public int size()

Specified by:

size in interface org.opensearch.transport.ConnectionManager

getAllConnectedNodes

public Set<org.opensearch.cluster.node.DiscoveryNode> getAllConnectedNodes()

Specified by:

getAllConnectedNodes in interface org.opensearch.transport.ConnectionManager

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.opensearch.transport.ConnectionManager

closeNoBlock

public void closeNoBlock()

Specified by:

closeNoBlock in interface org.opensearch.transport.ConnectionManager

getConnectionProfile

public org.opensearch.transport.ConnectionProfile getConnectionProfile()

Specified by:

getConnectionProfile in interface org.opensearch.transport.ConnectionManager