diff --git a/docs/CHANGELOG.asciidoc b/docs/CHANGELOG.asciidoc index a105951203a..2b4c316e7cb 100644 --- a/docs/CHANGELOG.asciidoc +++ b/docs/CHANGELOG.asciidoc @@ -176,6 +176,9 @@ started or stopped. ({pull}30118[#30118]) Added put index template API to the high level rest client ({pull}30400[#30400]) +Add ability to filter coordinating-only nodes when interacting with cluster +APIs. ({pull}30313[#30313]) + [float] === Bug Fixes diff --git a/server/src/main/java/org/elasticsearch/cluster/node/DiscoveryNode.java b/server/src/main/java/org/elasticsearch/cluster/node/DiscoveryNode.java index f6f18540825..afab4af3204 100644 --- a/server/src/main/java/org/elasticsearch/cluster/node/DiscoveryNode.java +++ b/server/src/main/java/org/elasticsearch/cluster/node/DiscoveryNode.java @@ -44,6 +44,8 @@ import java.util.function.Predicate; */ public class DiscoveryNode implements Writeable, ToXContentFragment { + static final String COORDINATING_ONLY = "coordinating_only"; + public static boolean nodeRequiresLocalStorage(Settings settings) { boolean localStorageEnable = Node.NODE_LOCAL_STORAGE_SETTING.get(settings); if (localStorageEnable == false && diff --git a/server/src/main/java/org/elasticsearch/cluster/node/DiscoveryNodes.java b/server/src/main/java/org/elasticsearch/cluster/node/DiscoveryNodes.java index c657af38703..2e0e6318691 100644 --- a/server/src/main/java/org/elasticsearch/cluster/node/DiscoveryNodes.java +++ b/server/src/main/java/org/elasticsearch/cluster/node/DiscoveryNodes.java @@ -148,6 +148,19 @@ public class DiscoveryNodes extends AbstractDiffable implements return nodes.build(); } + /** + * Get a {@link Map} of the coordinating only nodes (nodes which are neither master, nor data, nor ingest nodes) arranged by their ids + * + * @return {@link Map} of the coordinating only nodes arranged by their ids + */ + public ImmutableOpenMap getCoordinatingOnlyNodes() { + ImmutableOpenMap.Builder nodes = ImmutableOpenMap.builder(this.nodes); + nodes.removeAll(masterNodes.keys()); + nodes.removeAll(dataNodes.keys()); + nodes.removeAll(ingestNodes.keys()); + return nodes.build(); + } + /** * Get a node by its id * @@ -297,7 +310,7 @@ public class DiscoveryNodes extends AbstractDiffable implements * - "_local" or "_master" for the relevant nodes * - a node id * - a wild card pattern that will be matched against node names - * - a "attr:value" pattern, where attr can be a node role (master, data, ingest etc.) in which case the value can be true of false + * - a "attr:value" pattern, where attr can be a node role (master, data, ingest etc.) in which case the value can be true or false, * or a generic node attribute name in which case value will be treated as a wildcard and matched against the node attribute values. */ public String[] resolveNodes(String... nodes) { @@ -349,6 +362,12 @@ public class DiscoveryNodes extends AbstractDiffable implements } else { resolvedNodesIds.removeAll(ingestNodes.keys()); } + } else if (DiscoveryNode.COORDINATING_ONLY.equals(matchAttrName)) { + if (Booleans.parseBoolean(matchAttrValue, true)) { + resolvedNodesIds.addAll(getCoordinatingOnlyNodes().keys()); + } else { + resolvedNodesIds.removeAll(getCoordinatingOnlyNodes().keys()); + } } else { for (DiscoveryNode node : this) { for (Map.Entry entry : node.getAttributes().entrySet()) { diff --git a/server/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodesTests.java b/server/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodesTests.java index 80f2401ed77..cf0b1eebe98 100644 --- a/server/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodesTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/node/DiscoveryNodesTests.java @@ -102,9 +102,17 @@ public class DiscoveryNodesTests extends ESTestCase { .map(DiscoveryNode::getId) .toArray(String[]::new); - assertThat( - discoveryNodes.resolveNodes("_all", "data:false", "ingest:false", "master:false"), - arrayContainingInAnyOrder(coordinatorOnlyNodes)); + final String[] nonCoordinatorOnlyNodes = + StreamSupport.stream(discoveryNodes.getNodes().values().spliterator(), false) + .map(n -> n.value) + .filter(n -> n.isMasterNode() || n.isDataNode() || n.isIngestNode()) + .map(DiscoveryNode::getId) + .toArray(String[]::new); + + assertThat(discoveryNodes.resolveNodes("coordinating_only:true"), arrayContainingInAnyOrder(coordinatorOnlyNodes)); + assertThat(discoveryNodes.resolveNodes("_all", "data:false", "ingest:false", "master:false"), + arrayContainingInAnyOrder(coordinatorOnlyNodes)); + assertThat(discoveryNodes.resolveNodes("_all", "coordinating_only:false"), arrayContainingInAnyOrder(nonCoordinatorOnlyNodes)); } public void testResolveNodesIds() { @@ -275,6 +283,13 @@ public class DiscoveryNodesTests extends ESTestCase { nodes.getIngestNodes().keysIt().forEachRemaining(ids::add); return ids; } + }, COORDINATING_ONLY(DiscoveryNode.COORDINATING_ONLY + ":true") { + @Override + Set matchingNodeIds(DiscoveryNodes nodes) { + Set ids = new HashSet<>(); + nodes.getCoordinatingOnlyNodes().keysIt().forEachRemaining(ids::add); + return ids; + } }, CUSTOM_ATTRIBUTE("attr:value") { @Override Set matchingNodeIds(DiscoveryNodes nodes) {