opensearch 2.18.0

codelibs · Nov 10, 2024 · 902ce29 · 902ce29
1 parent 85832ed
commit 902ce29
Show file tree

Hide file tree

Showing 4 changed files with 15 additions and 4 deletions.
diff --git a/pom.xml b/pom.xml
@@ -5,7 +5,7 @@
 	<artifactId>fesen-httpclient</artifactId>
 	<packaging>jar</packaging>
 	<name>fesen-httpclient</name>
-	<version>2.17.1-SNAPSHOT</version>
+	<version>2.18.0-SNAPSHOT</version>
 	<description />
 	<url>https://github.com/codelibs/fesen-httpclient</url>
 	<inceptionYear>2012</inceptionYear>
@@ -32,7 +32,7 @@
 	</parent>
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-		<opensearch.version>2.17.1</opensearch.version>
+		<opensearch.version>2.18.0</opensearch.version>
 		<log4j.version>2.21.0</log4j.version>
 		<junit.jupiter.version>5.10.0</junit.jupiter.version>
 		<testcontainers.version>1.19.1</testcontainers.version>

diff --git a/src/main/java/org/codelibs/fesen/client/HttpAbstractClient.java b/src/main/java/org/codelibs/fesen/client/HttpAbstractClient.java
@@ -195,6 +195,9 @@
 import org.opensearch.action.admin.cluster.tasks.PendingClusterTasksRequest;
 import org.opensearch.action.admin.cluster.tasks.PendingClusterTasksRequestBuilder;
 import org.opensearch.action.admin.cluster.tasks.PendingClusterTasksResponse;
+import org.opensearch.action.admin.cluster.wlm.WlmStatsAction;
+import org.opensearch.action.admin.cluster.wlm.WlmStatsRequest;
+import org.opensearch.action.admin.cluster.wlm.WlmStatsResponse;
 import org.opensearch.action.admin.indices.alias.IndicesAliasesAction;
 import org.opensearch.action.admin.indices.alias.IndicesAliasesRequest;
 import org.opensearch.action.admin.indices.alias.IndicesAliasesRequestBuilder;
@@ -1502,6 +1505,11 @@ public RemoteStoreStatsRequestBuilder prepareRemoteStoreStats(final String index
             }
             return remoteStoreStatsRequestBuilder;
         }
+
+        @Override
+        public void wlmStats(WlmStatsRequest request, ActionListener<WlmStatsResponse> listener) {
+            execute(WlmStatsAction.INSTANCE, request, listener);
+        }
     }
 
     static class IndicesAdmin implements IndicesAdminClient {

diff --git a/src/main/java/org/codelibs/fesen/client/HttpClient.java b/src/main/java/org/codelibs/fesen/client/HttpClient.java
@@ -840,7 +840,7 @@ public HttpClient(final Settings settings, final ThreadPool threadPool, final Li
         // org.codelibs.fesen.action.admin.indices.upgrade.post.UpgradeSettingsAction
         // org.codelibs.fesen.action.termvectors.MultiTermVectorsAction
         // org.codelibs.fesen.action.termvectors.TermVectorsAction
-
+        // org.opensearch.action.admin.cluster.wlm.WlmStatsAction
     }
 
     @Override

diff --git a/src/main/java/org/codelibs/fesen/client/action/HttpNodesStatsAction.java b/src/main/java/org/codelibs/fesen/client/action/HttpNodesStatsAction.java
@@ -95,6 +95,7 @@
 import org.opensearch.monitor.process.ProcessStats;
 import org.opensearch.node.AdaptiveSelectionStats;
 import org.opensearch.node.NodesResourceUsageStats;
+import org.opensearch.node.remotestore.RemoteStoreNodeStats;
 import org.opensearch.ratelimitting.admissioncontrol.stats.AdmissionControlStats;
 import org.opensearch.repositories.RepositoriesStats;
 import org.opensearch.script.ScriptCacheStats;
@@ -221,6 +222,7 @@ protected NodeStats parseNodeStats(final XContentParser parser, final String nod
         RepositoriesStats repositoriesStats = null; // TODO
         AdmissionControlStats admissionControlStats = null; // TODO
         NodeCacheStats nodeCacheStats = null; // TODO
+        RemoteStoreNodeStats remoteStoreNodeStats = null; // TODO
         final Map<String, String> attributes = new HashMap<>();
         XContentParser.Token token;
         TransportAddress transportAddress = new TransportAddress(TransportAddress.META_ADDRESS, 0);
@@ -320,7 +322,8 @@ protected NodeStats parseNodeStats(final XContentParser parser, final String nod
                 segmentReplicationRejectionStats, //
                 repositoriesStats, //
                 admissionControlStats, //
-                nodeCacheStats);
+                nodeCacheStats, //
+                remoteStoreNodeStats);
     }
 
     public static TransportAddress parseTransportAddress(final String addr) {