Package org.elasticsearch.transport
Class SniffConnectionStrategy
java.lang.Object
org.elasticsearch.transport.RemoteConnectionStrategy
org.elasticsearch.transport.SniffConnectionStrategy
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,TransportConnectionListener
public class SniffConnectionStrategy extends RemoteConnectionStrategy
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
SniffConnectionStrategy.SniffModeInfo
-
Field Summary
Fields Modifier and Type Field Description static Setting.AffixSetting<java.util.List<java.lang.String>>
REMOTE_CLUSTER_SEEDS
A list of initial seed nodes to discover eligible nodes from the remote clusterstatic Setting.AffixSetting<java.lang.String>
REMOTE_CLUSTERS_PROXY
A proxy address for the remote cluster.static Setting<java.lang.Integer>
REMOTE_CONNECTIONS_PER_CLUSTER
The maximum number of connections that will be established to a remote cluster.static Setting.AffixSetting<java.lang.Integer>
REMOTE_NODE_CONNECTIONS
The maximum number of node connections that will be established to a remote cluster.static SettingUpgrader<java.util.List<java.lang.String>>
SEARCH_REMOTE_CLUSTER_SEEDS_UPGRADER
static Setting.AffixSetting<java.lang.String>
SEARCH_REMOTE_CLUSTERS_PROXY
static SettingUpgrader<java.lang.String>
SEARCH_REMOTE_CLUSTERS_PROXY_UPGRADER
static Setting.AffixSetting<java.util.List<java.lang.String>>
SEARCH_REMOTE_CLUSTERS_SEEDS
static Setting<java.lang.Integer>
SEARCH_REMOTE_CONNECTIONS_PER_CLUSTER
Fields inherited from class org.elasticsearch.transport.RemoteConnectionStrategy
clusterAlias, connectionManager, REMOTE_CONNECTION_MODE, transportService
-
Method Summary
Modifier and Type Method Description protected void
connectImpl(ActionListener<java.lang.Void> listener)
protected RemoteConnectionInfo.ModeInfo
getModeInfo()
protected boolean
shouldOpenMoreConnections()
protected boolean
strategyMustBeRebuilt(Settings newSettings)
protected org.elasticsearch.transport.RemoteConnectionStrategy.ConnectionStrategy
strategyType()
Methods inherited from class org.elasticsearch.transport.RemoteConnectionStrategy
close, isClosed, isConnectionEnabled, isConnectionEnabled, onNodeDisconnected
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
-
SEARCH_REMOTE_CLUSTERS_SEEDS
public static final Setting.AffixSetting<java.util.List<java.lang.String>> SEARCH_REMOTE_CLUSTERS_SEEDS -
SEARCH_REMOTE_CLUSTER_SEEDS_UPGRADER
public static final SettingUpgrader<java.util.List<java.lang.String>> SEARCH_REMOTE_CLUSTER_SEEDS_UPGRADER -
REMOTE_CLUSTER_SEEDS
A list of initial seed nodes to discover eligible nodes from the remote cluster -
SEARCH_REMOTE_CLUSTERS_PROXY
-
REMOTE_CLUSTERS_PROXY
A proxy address for the remote cluster. By default this is not set, meaning that Elasticsearch will connect directly to the nodes in the remote cluster using their publish addresses. If this setting is set to an IP address or hostname then Elasticsearch will connect to the nodes in the remote cluster using this address instead. Use of this setting is not recommended and it is deliberately undocumented as it does not work well with all proxies. -
SEARCH_REMOTE_CONNECTIONS_PER_CLUSTER
-
REMOTE_CONNECTIONS_PER_CLUSTER
The maximum number of connections that will be established to a remote cluster. For instance if there is only a single seed node, other nodes will be discovered up to the given number of nodes in this setting. The default is 3. -
REMOTE_NODE_CONNECTIONS
The maximum number of node connections that will be established to a remote cluster. For instance if there is only a single seed node, other nodes will be discovered up to the given number of nodes in this setting. The default is 3. -
SEARCH_REMOTE_CLUSTERS_PROXY_UPGRADER
-
-
Method Details
-
shouldOpenMoreConnections
protected boolean shouldOpenMoreConnections()- Specified by:
shouldOpenMoreConnections
in classRemoteConnectionStrategy
-
strategyMustBeRebuilt
- Specified by:
strategyMustBeRebuilt
in classRemoteConnectionStrategy
-
strategyType
protected org.elasticsearch.transport.RemoteConnectionStrategy.ConnectionStrategy strategyType()- Specified by:
strategyType
in classRemoteConnectionStrategy
-
connectImpl
- Specified by:
connectImpl
in classRemoteConnectionStrategy
-
getModeInfo
- Specified by:
getModeInfo
in classRemoteConnectionStrategy
-