Class RemoteConnectionStrategy

java.lang.Object
org.elasticsearch.transport.RemoteConnectionStrategy
All Implemented Interfaces:
Closeable, AutoCloseable, TransportConnectionListener
Direct Known Subclasses:
ProxyConnectionStrategy, SniffConnectionStrategy

public abstract class RemoteConnectionStrategy extends Object implements TransportConnectionListener, Closeable
  • 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<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 String clusterAlias
  • Method Details

    • isConnectionEnabled

      public static boolean isConnectionEnabled(String clusterAlias, Settings settings)
    • isConnectionEnabled

      public static boolean isConnectionEnabled(String clusterAlias, Map<Setting<?>,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 AutoCloseable
      Specified by:
      close in interface Closeable
    • isClosed

      public boolean isClosed()
    • shouldOpenMoreConnections

      protected abstract boolean shouldOpenMoreConnections()
    • connectImpl

      protected abstract void connectImpl(ActionListener<Void> listener)
    • getModeInfo

      protected abstract RemoteConnectionInfo.ModeInfo getModeInfo()