From 901898511afc36f8f4842ed4e5bac15be018ea3c Mon Sep 17 00:00:00 2001 From: mloufra Date: Wed, 20 Jul 2022 05:11:40 +0000 Subject: [PATCH] issue #28 --- .../InitializeExtensionsResponse.java | 88 +++++++++++++++++++ 1 file changed, 88 insertions(+) create mode 100644 server/src/main/java/org/opensearch/discovery/InitializeExtensionsResponse.java diff --git a/server/src/main/java/org/opensearch/discovery/InitializeExtensionsResponse.java b/server/src/main/java/org/opensearch/discovery/InitializeExtensionsResponse.java new file mode 100644 index 0000000000000..c87909e88908f --- /dev/null +++ b/server/src/main/java/org/opensearch/discovery/InitializeExtensionsResponse.java @@ -0,0 +1,88 @@ +/* + * SPDX-License-Identifier: Apache-2.0 + * + * The OpenSearch Contributors require contributions made to + * this file be licensed under the Apache-2.0 license or a + * compatible open source license. + */ + +/* + * Licensed to Elasticsearch under one or more contributor + * license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright + * ownership. Elasticsearch licenses this file to you under + * the Apache License, Version 2.0 (the "License"); you may + * not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +/* + * Modifications Copyright OpenSearch Contributors. See + * GitHub history for details. + */ + +package org.opensearch.discovery; + +import org.opensearch.common.io.stream.StreamInput; +import org.opensearch.common.io.stream.StreamOutput; +import org.opensearch.transport.TransportResponse; + +import java.io.IOException; +import java.util.Objects; + +/** + * PluginResponse to intialize plugin + * + * @opensearch.internal + */ +public class InitializeExtensionsResponse extends TransportResponse { + private String name; + + public InitializeExtensionsResponse(String name) { + this.name = name; + } + + public InitializeExtensionsResponse(StreamInput in) throws IOException { + name = in.readString(); + } + + @Override + public void writeTo(StreamOutput out) throws IOException { + out.writeString(name); + } + + /** + * @return the node that is currently leading, according to the responding node. + */ + + public String getName() { + return this.name; + } + + @Override + public String toString() { + return "PluginResponse{" + "name" + name + "}"; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + InitializeExtensionsResponse that = (InitializeExtensionsResponse) o; + return Objects.equals(name, that.name); + } + + @Override + public int hashCode() { + return Objects.hash(name); + } +}