More

Author: n1v0lg

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

@@ -49,4 +49,8 @@ public RemoteConnectionStrategy.ConnectionStrategy getConnectionMode() {
     public Settings getSettings() {
         return settings;
     }
+
+    public String getClusterAlias() {
+        return clusterAlias;
+    }
 }

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

@@ -220,9 +220,7 @@ void validateAndUpdateRemoteCluster(String clusterAlias, LinkedClusterConnection
      */
     protected abstract void updateRemoteCluster(String clusterAlias, LinkedClusterConnectionConfig config);
 
-    /**
-     * Registers this instance to listen to updates on the cluster settings.
-     */
+    // This will go away
     public void listenForUpdates(ClusterSettings clusterSettings) {
         List<Setting.AffixSetting<?>> remoteClusterSettings = List.of(
             RemoteClusterService.REMOTE_CLUSTER_COMPRESS,
@@ -244,6 +242,9 @@ public void listenForUpdates(ClusterSettings clusterSettings) {
         );
     }
 
+    /**
+     * Registers this instance to listen to updates on linked cluster configuration.
+     */
     public void listenForUpdates(LinkedClusterConnectionConfigListener listener) {
         listener.listen(this::validateAndUpdateRemoteCluster);
     }