Ser/de changes

Signed-off-by: Bukhtawar Khan <bukhtawa@amazon.com>
opensearch-project · Oct 11, 2023 · 55586c5 · 55586c5
1 parent c9688ee
commit 55586c5
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 1 deletion.
diff --git a/server/src/main/java/org/opensearch/action/admin/cluster/node/stats/NodeStats.java b/server/src/main/java/org/opensearch/action/admin/cluster/node/stats/NodeStats.java
@@ -202,6 +202,11 @@ public NodeStats(StreamInput in) throws IOException {
         } else {
             searchPipelineStats = null;
         }
+        if (in.getVersion().onOrAfter(Version.V_3_0_0)) {
+            repositoriesStats = in.readOptionalWriteable(RepositoriesStats::new);
+        } else {
+            repositoriesStats = null;
+        }
     }
 
     public NodeStats(

diff --git a/server/src/main/java/org/opensearch/repositories/RepositoriesStats.java b/server/src/main/java/org/opensearch/repositories/RepositoriesStats.java
@@ -8,6 +8,7 @@
 
 package org.opensearch.repositories;
 
+import org.opensearch.core.common.io.stream.StreamInput;
 import org.opensearch.core.common.io.stream.StreamOutput;
 import org.opensearch.core.common.io.stream.Writeable;
 import org.opensearch.core.common.util.CollectionUtils;
@@ -24,10 +25,14 @@ public class RepositoriesStats implements Writeable, ToXContentObject {
 
     List<RepositoryStatsSnapshot> repositoryStatsSnapshots;
 
-    RepositoriesStats(List<RepositoryStatsSnapshot> repositoryStatsSnapshots) {
+    public RepositoriesStats(List<RepositoryStatsSnapshot> repositoryStatsSnapshots) {
         this.repositoryStatsSnapshots = repositoryStatsSnapshots;
     }
 
+    public RepositoriesStats(StreamInput in) throws IOException {
+        this.repositoryStatsSnapshots = in.readList(RepositoryStatsSnapshot::new);
+    }
+
     @Override
     public void writeTo(StreamOutput out) throws IOException {
         out.writeList(repositoryStatsSnapshots);