Relocate RemoteClusterService methods only used in tests.

server/src/main/java/org/elasticsearch/transport/RemoteClusterService.java

@@ -173,17 +173,6 @@ public DiscoveryNode getLocalNode() {
         return transportService.getLocalNode();
     }
 
-    /**
-     * Returns <code>true</code> if at least one remote cluster is configured
-     */
-    public boolean isCrossClusterSearchEnabled() {
-        return remoteClusters.isEmpty() == false;
-    }
-
-    boolean isRemoteNodeConnected(final String remoteCluster, final DiscoveryNode node) {
-        return remoteClusters.get(remoteCluster).isNodeConnected(node);
-    }
-
     /**
      * Group indices by cluster alias mapped to OriginalIndices for that cluster.
      * @param remoteClusterNames Set of configured remote cluster names.
@@ -259,13 +248,6 @@ public Set<String> getConfiguredClusters() {
         return getRegisteredRemoteClusterNames();
     }
 
-    /**
-     * Returns <code>true</code> iff the given cluster is configured as a remote cluster. Otherwise <code>false</code>
-     */
-    boolean isRemoteClusterRegistered(String clusterName) {
-        return remoteClusters.containsKey(clusterName);
-    }
-
     /**
      * Returns the registered remote cluster names.
      */

server/src/test/java/org/elasticsearch/transport/RemoteClusterClientTests.java

@@ -95,7 +95,7 @@ public void testConnectAndExecuteRequest() throws Exception {
                 service.acceptIncomingRequests();
                 logger.info("now accepting incoming requests on local transport");
                 RemoteClusterService remoteClusterService = service.getRemoteClusterService();
-                assertTrue(remoteClusterService.isRemoteNodeConnected("test", remoteNode));
+                assertTrue(isRemoteNodeConnected("test", remoteNode, remoteClusterService));
                 var client = remoteClusterService.getRemoteClusterClient(
                     "test",
                     threadPool.executor(TEST_THREAD_POOL_NAME),
@@ -172,7 +172,7 @@ public void testEnsureWeReconnect() throws Exception {
                 // the right calls in place in the RemoteAwareClient
                 service.acceptIncomingRequests();
                 RemoteClusterService remoteClusterService = service.getRemoteClusterService();
-                assertBusy(() -> assertTrue(remoteClusterService.isRemoteNodeConnected("test", remoteNode)));
+                assertBusy(() -> assertTrue(isRemoteNodeConnected("test", remoteNode, remoteClusterService)));
                 for (int i = 0; i < 10; i++) {
                     RemoteClusterConnection remoteClusterConnection = remoteClusterService.getRemoteClusterConnection("test");
                     assertBusy(remoteClusterConnection::assertNoRunningConnections);
@@ -286,7 +286,7 @@ public void testQuicklySkipUnavailableClusters() throws Exception {
                 );
 
                 try {
-                    assertFalse(remoteClusterService.isRemoteNodeConnected("test", remoteNode));
+                    assertFalse(isRemoteNodeConnected("test", remoteNode, remoteClusterService));
 
                     // check that we quickly fail
                     if (randomBoolean()) {
@@ -325,8 +325,12 @@ public void testQuicklySkipUnavailableClusters() throws Exception {
                         () -> safeAwait(listener -> client.getConnection(null, listener.map(v -> v)))
                     )
                 );
-                assertTrue(remoteClusterService.isRemoteNodeConnected("test", remoteNode));
+                assertTrue(isRemoteNodeConnected("test", remoteNode, remoteClusterService));
             }
         }
     }
+
+    private static boolean isRemoteNodeConnected(String clusterName, DiscoveryNode node, RemoteClusterService service) {
+        return service.getRemoteClusterConnection(clusterName).isNodeConnected(node);
+    }
 }