Package org.elasticsearch.transport

Class RemoteClusterService

org.elasticsearch.transport.RemoteClusterAware
org.elasticsearch.transport.RemoteClusterService
All Implemented Interfaces:
,
public final class RemoteClusterService extends RemoteClusterAware implements
Basic service for accessing remote clusters via gateway nodes

  • Field Details

    • SEARCH_REMOTE_INITIAL_CONNECTION_TIMEOUT_SETTING

      public static final Setting<org.elasticsearch.core.TimeValue> SEARCH_REMOTE_INITIAL_CONNECTION_TIMEOUT_SETTING

    • REMOTE_INITIAL_CONNECTION_TIMEOUT_SETTING

      public static final Setting<org.elasticsearch.core.TimeValue> REMOTE_INITIAL_CONNECTION_TIMEOUT_SETTING
      The initial connect timeout for remote cluster connections

    • SEARCH_REMOTE_NODE_ATTRIBUTE

      public static final > SEARCH_REMOTE_NODE_ATTRIBUTE

    • REMOTE_NODE_ATTRIBUTE

      public static final > REMOTE_NODE_ATTRIBUTE
      The name of a node attribute to select nodes that should be connected to in the remote cluster. For instance a node can be configured with node.attr.gateway: true in order to be eligible as a gateway node between clusters. In that case search.remote.node.attr: gateway can be used to filter out other nodes in the remote cluster. The value of the setting is expected to be a boolean, true for nodes that can become gateways, false otherwise.

    • SEARCH_ENABLE_REMOTE_CLUSTERS

      public static final > SEARCH_ENABLE_REMOTE_CLUSTERS

    • ENABLE_REMOTE_CLUSTERS

      public static final > ENABLE_REMOTE_CLUSTERS
      If true connecting to remote clusters is supported on this node. If false this node will not establish connections to any remote clusters configured. Search requests executed against this node (where this node is the coordinating node) will fail if remote cluster syntax is used as an index pattern. The default is true

    • SEARCH_REMOTE_CLUSTER_SKIP_UNAVAILABLE

      public static final > SEARCH_REMOTE_CLUSTER_SKIP_UNAVAILABLE

    • SEARCH_REMOTE_CLUSTER_SKIP_UNAVAILABLE_UPGRADER

      public static final > SEARCH_REMOTE_CLUSTER_SKIP_UNAVAILABLE_UPGRADER

    • REMOTE_CLUSTER_SKIP_UNAVAILABLE

      public static final > REMOTE_CLUSTER_SKIP_UNAVAILABLE

    • REMOTE_CLUSTER_PING_SCHEDULE

      public static final Setting.AffixSetting<org.elasticsearch.core.TimeValue> REMOTE_CLUSTER_PING_SCHEDULE

    • REMOTE_CLUSTER_COMPRESS

      public static final Setting.AffixSetting<Compression.Enabled> REMOTE_CLUSTER_COMPRESS

  • Method Details

    • isEnabled

      public boolean isEnabled()

    • getLocalNode

      public DiscoveryNode getLocalNode()

    • isCrossClusterSearchEnabled

      public boolean isCrossClusterSearchEnabled()
      Returns true if at least one remote cluster is configured

    • groupIndices

      public <,​OriginalIndices> groupIndices​(IndicesOptions indicesOptions, [] indices, <> indexExists)

    • getRegisteredRemoteClusterNames

      public <> getRegisteredRemoteClusterNames()
      Returns the registered remote cluster names.

    • getConnection

      public Transport.Connection getConnection​(DiscoveryNode node,  cluster)
      Returns a connection to the given node on the given remote cluster
      Throws:
      - if the remote cluster is unknown

    • isSkipUnavailable

      public boolean isSkipUnavailable​( clusterAlias)
      Returns whether the cluster identified by the provided alias is configured to be skipped when unavailable

    • getConnection

      public  cluster)

    • listenForUpdates

      public void listenForUpdates​(ClusterSettings clusterSettings)
      Description copied from class: RemoteClusterAware
      Registers this instance to listen to updates on the cluster settings.
      Overrides:
      listenForUpdates in class RemoteClusterAware

    • updateRemoteCluster

      protected void updateRemoteCluster​( clusterAlias, Settings settings)
      Description copied from class: RemoteClusterAware
      Subclasses must implement this to receive information about updated cluster aliases.
      Specified by:
      updateRemoteCluster in class RemoteClusterAware

    • close

      public void close() throws
      Specified by:
       in interface 
      Specified by:
       in interface 
      Throws:

    • getRemoteConnectionInfos

      public <RemoteConnectionInfo> getRemoteConnectionInfos()

    • collectNodes

      public void collectNodes​(<> clusters, <,​,​DiscoveryNode>> listener)
      Collects all nodes of the given clusters and returns / passes a (clusterAlias, nodeId) to DiscoveryNode function on success.

    • getRemoteClusterClient

      public Client getRemoteClusterClient​(ThreadPool threadPool,  clusterAlias)
      Returns a client to the remote cluster if the given cluster alias exists.
      Parameters:
      threadPool - the ThreadPool for the client
      clusterAlias - the cluster alias the remote cluster is registered under
      Throws:
      - if the given clusterAlias doesn't exist