Package org.elasticsearch.transport

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()