-
Notifications
You must be signed in to change notification settings - Fork 73
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Adding remote index and multi-index checks in validation (#1290)
* Adding remote index and multi index checks in validation Signed-off-by: Amit Galitzky <amgalitz@amazon.com> * adding more tests Signed-off-by: Amit Galitzky <amgalitz@amazon.com> --------- Signed-off-by: Amit Galitzky <amgalitz@amazon.com>
- Loading branch information
1 parent
e47e3c3
commit ec16d53
Showing
13 changed files
with
417 additions
and
93 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
218 changes: 140 additions & 78 deletions
218
src/main/java/org/opensearch/timeseries/rest/handler/AbstractTimeSeriesActionHandler.java
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
98 changes: 98 additions & 0 deletions
98
src/main/java/org/opensearch/timeseries/util/CrossClusterConfigUtils.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,98 @@ | ||
| /* | ||
| * Copyright OpenSearch Contributors | ||
| * SPDX-License-Identifier: Apache-2.0 | ||
| */ | ||
|
|
||
| package org.opensearch.timeseries.util; | ||
|
|
||
| import java.util.ArrayList; | ||
| import java.util.HashMap; | ||
| import java.util.List; | ||
|
|
||
| import org.apache.commons.lang3.tuple.Pair; | ||
| import org.apache.logging.log4j.LogManager; | ||
| import org.apache.logging.log4j.Logger; | ||
| import org.opensearch.client.Client; | ||
| import org.opensearch.client.node.NodeClient; | ||
| import org.opensearch.cluster.service.ClusterService; | ||
|
|
||
| public class CrossClusterConfigUtils { | ||
| private static final Logger logger = LogManager.getLogger(ParseUtils.class); | ||
|
|
||
| /** | ||
| * Uses the clusterName to determine whether the target client is the local or a remote client, | ||
| * and returns the appropriate client. | ||
| * @param clusterName The name of the cluster to evaluate. | ||
| * @param client The local {@link NodeClient}. | ||
| * @param localClusterName The name of the local cluster. | ||
| * @return The local {@link NodeClient} for the local cluster, or a remote client for a remote cluster. | ||
| */ | ||
| public static Client getClientForCluster(String clusterName, Client client, String localClusterName) { | ||
| return clusterName.equals(localClusterName) ? client : client.getRemoteClusterClient(clusterName); | ||
| } | ||
|
|
||
| /** | ||
| * Uses the clusterName to determine whether the target client is the local or a remote client, | ||
| * and returns the appropriate client. | ||
| * @param clusterName The name of the cluster to evaluate. | ||
| * @param client The local {@link NodeClient}. | ||
| * @param clusterService Used to retrieve the name of the local cluster. | ||
| * @return The local {@link NodeClient} for the local cluster, or a remote client for a remote cluster. | ||
| */ | ||
| public static Client getClientForCluster(String clusterName, Client client, ClusterService clusterService) { | ||
| return getClientForCluster(clusterName, client, clusterService.getClusterName().value()); | ||
| } | ||
|
|
||
| /** | ||
| * Parses the list of indexes into a map of cluster_name to List of index names | ||
| * @param indexes A list of index names in cluster_name:index_name format. | ||
| * Local indexes can also be in index_name format. | ||
| * @param clusterService Used to retrieve the name of the local cluster. | ||
| * @return A map of cluster_name:index names | ||
| */ | ||
| public static HashMap<String, List<String>> separateClusterIndexes(List<String> indexes, ClusterService clusterService) { | ||
| return separateClusterIndexes(indexes, clusterService.getClusterName().value()); | ||
| } | ||
|
|
||
| /** | ||
| * Parses the list of indexes into a map of cluster_name to list of index_name | ||
| * @param indexes A list of index names in cluster_name:index_name format. | ||
| * @param localClusterName The name of the local cluster. | ||
| * @return A map of cluster_name to List index_name | ||
| */ | ||
| public static HashMap<String, List<String>> separateClusterIndexes(List<String> indexes, String localClusterName) { | ||
| HashMap<String, List<String>> output = new HashMap<>(); | ||
| for (String index : indexes) { | ||
| // Use the refactored method to get both cluster and index names in one call | ||
| Pair<String, String> clusterAndIndex = parseClusterAndIndexName(index); | ||
| String clusterName = clusterAndIndex.getKey(); | ||
| String indexName = clusterAndIndex.getValue(); | ||
| logger.info("clusterName: " + clusterName); | ||
| logger.info("indexName: " + indexName); | ||
|
|
||
| // If the index entry does not have a cluster_name, it indicates the index is on the local cluster. | ||
| if (clusterName.isEmpty()) { | ||
| clusterName = localClusterName; | ||
| } | ||
| output.computeIfAbsent(clusterName, k -> new ArrayList<>()).add(indexName); | ||
| } | ||
| return output; | ||
| } | ||
|
|
||
| /** | ||
| * Parses the cluster and index names from the given input string. | ||
| * The input can be in either "cluster_name:index_name" format or just "index_name". | ||
| * @param index The name of the index to evaluate. | ||
| * @return A Pair where the left is the cluster name (or empty if not present), and the right is the index name. | ||
| */ | ||
| public static Pair<String, String> parseClusterAndIndexName(String index) { | ||
| if (index.contains(":")) { | ||
| String[] parts = index.split(":", 2); | ||
| String clusterName = parts[0]; | ||
| String indexName = parts.length > 1 ? parts[1] : ""; | ||
| return Pair.of(clusterName, indexName); | ||
| } else { | ||
| return Pair.of("", index); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.