Issue opensearch-project#28

Signed-off-by: Ubuntu <[email protected]>
mloufra · Jul 20, 2022 · 3d912b2 · 3d912b2
1 parent cc9d101
commit 3d912b2
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/server/src/main/java/org/opensearch/discovery/PluginRequest.java b/server/src/main/java/org/opensearch/discovery/PluginRequest.java
@@ -23,19 +23,19 @@
  *
  * @opensearch.internal
  */
-public class PluginRequest extends TransportRequest {
+public class InitializeExtensionsRequest extends TransportRequest {
     private final DiscoveryNode sourceNode;
     /*
      * TODO change DiscoveryNode to Extension information
      */
     private final List<DiscoveryExtension> extensions;
 
-    public PluginRequest(DiscoveryNode sourceNode, List<DiscoveryExtension> extensions) {
+    public InitializeExtensionsRequest(DiscoveryNode sourceNode, List<DiscoveryExtension> extensions) {
         this.sourceNode = sourceNode;
         this.extensions = extensions;
     }
 
-    public PluginRequest(StreamInput in) throws IOException {
+    public InitializeExtensionsRequest(StreamInput in) throws IOException {
         super(in);
         sourceNode = new DiscoveryNode(in);
         extensions = in.readList(DiscoveryExtension::new);
@@ -65,7 +65,7 @@ public String toString() {
     public boolean equals(Object o) {
         if (this == o) return true;
         if (o == null || getClass() != o.getClass()) return false;
-        PluginRequest that = (PluginRequest) o;
+        InitializeExtensionsRequest that = (InitializeExtensionsRequest) o;
         return Objects.equals(sourceNode, that.sourceNode) && Objects.equals(extensions, that.extensions);
     }
 

diff --git a/server/src/main/java/org/opensearch/discovery/PluginResponse.java b/server/src/main/java/org/opensearch/discovery/PluginResponse.java
@@ -44,14 +44,14 @@
  *
  * @opensearch.internal
  */
-public class PluginResponse extends TransportResponse {
+public class InitializeExtensionsResponse extends TransportResponse {
     private String name;
 
-    public PluginResponse(String name) {
+    public InitializeExtensionsResponse(String name) {
         this.name = name;
     }
 
-    public PluginResponse(StreamInput in) throws IOException {
+    public InitializeExtensionsResponse(StreamInput in) throws IOException {
         name = in.readString();
     }
 
@@ -77,7 +77,7 @@ public String toString() {
     public boolean equals(Object o) {
         if (this == o) return true;
         if (o == null || getClass() != o.getClass()) return false;
-        PluginResponse that = (PluginResponse) o;
+        InitializeExtensionsResponse that = (InitializeExtensionsResponse) o;
         return Objects.equals(name, that.name);
     }