Package org.elasticsearch.transport

Class RemoteConnectionStrategy

java.lang.Object

org.elasticsearch.transport.RemoteConnectionStrategy

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, TransportConnectionListener

Direct Known Subclasses:

ProxyConnectionStrategy, SniffConnectionStrategy

public abstract class RemoteConnectionStrategy
extends java.lang.Object
implements TransportConnectionListener, java.io.Closeable

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.String	clusterAlias
protected RemoteConnectionManager	connectionManager
protected org.apache.logging.log4j.Logger	logger
static Setting.AffixSetting<org.elasticsearch.transport.RemoteConnectionStrategy.ConnectionStrategy>	REMOTE_CONNECTION_MODE
static Setting<java.lang.Integer>	REMOTE_MAX_PENDING_CONNECTION_LISTENERS
protected TransportService	transportService

Method Summary

Modifier and Type	Method	Description
void	close()
protected abstract void	connectImpl(ActionListener<java.lang.Void> listener)
protected abstract RemoteConnectionInfo.ModeInfo	getModeInfo()
boolean	isClosed()
static boolean	isConnectionEnabled(java.lang.String clusterAlias, java.util.Map<Setting<?>,java.lang.Object> settings)
static boolean	isConnectionEnabled(java.lang.String clusterAlias, Settings settings)
void	onNodeDisconnected(DiscoveryNode node, Transport.Connection connection)	Called once a node connection is closed and unregistered.
protected abstract boolean	shouldOpenMoreConnections()
protected abstract boolean	strategyMustBeRebuilt(Settings newSettings)
protected abstract org.elasticsearch.transport.RemoteConnectionStrategy.ConnectionStrategy	strategyType()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.transport.TransportConnectionListener

onConnectionClosed, onConnectionOpened, onNodeConnected

Field Details

REMOTE_CONNECTION_MODE

public static final Setting.AffixSetting<org.elasticsearch.transport.RemoteConnectionStrategy.ConnectionStrategy> REMOTE_CONNECTION_MODE

REMOTE_MAX_PENDING_CONNECTION_LISTENERS

public static final Setting<java.lang.Integer> REMOTE_MAX_PENDING_CONNECTION_LISTENERS

logger

protected final org.apache.logging.log4j.Logger logger

transportService

protected final TransportService transportService

connectionManager

protected final RemoteConnectionManager connectionManager

clusterAlias

protected final java.lang.String clusterAlias

Method Details

isConnectionEnabled

public static boolean isConnectionEnabled(java.lang.String clusterAlias,
Settings settings)

isConnectionEnabled

public static boolean isConnectionEnabled(java.lang.String clusterAlias,
java.util.Map<Setting<?>,java.lang.Object> settings)

strategyMustBeRebuilt

protected abstract boolean strategyMustBeRebuilt(Settings newSettings)

strategyType

protected abstract org.elasticsearch.transport.RemoteConnectionStrategy.ConnectionStrategy strategyType()

onNodeDisconnected

public void onNodeDisconnected(DiscoveryNode node,
Transport.Connection connection)

Description copied from interface: TransportConnectionListener

Called once a node connection is closed and unregistered.

Specified by:

onNodeDisconnected in interface TransportConnectionListener

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

isClosed

public boolean isClosed()

shouldOpenMoreConnections

protected abstract boolean shouldOpenMoreConnections()

connectImpl

protected abstract void connectImpl(ActionListener<java.lang.Void> listener)

getModeInfo

protected abstract RemoteConnectionInfo.ModeInfo getModeInfo()