Added new baseclasses in opensearch for ccr classloader issue

Signed-off-by: aggarwalShivani <shivani.aggarwal@nokia.com>

Author: aggarwalShivani

server/src/main/java/org/opensearch/action/support/clustermanager/ClusterManagerNodeAckRequest.java

@@ -0,0 +1,108 @@
+/*
+ * 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.action.support.clustermanager;
+
+import org.opensearch.action.ActionRequest;
+import org.opensearch.action.ActionRequestValidationException;
+import org.opensearch.cluster.ack.AckedRequest;
+import org.opensearch.common.unit.TimeValue;
+import org.opensearch.core.common.io.stream.StreamInput;
+import org.opensearch.core.common.io.stream.StreamOutput;
+import static org.opensearch.common.unit.TimeValue.timeValueSeconds;
+
+
+import java.io.IOException;
+
+/**
+ * A base request for cluster-manager based operations.
+ * It is similar to ClusterManagerNodeRequest, but extends ActionRequest and AckedRequest.
+ * @opensearch.api
+ */
+public abstract class ClusterManagerNodeAckRequest extends ActionRequest implements AckedRequest {
+
+    public static final TimeValue DEFAULT_CLUSTER_MANAGER_NODE_TIMEOUT = TimeValue.timeValueSeconds(30);
+    protected TimeValue clusterManagerNodeTimeout = DEFAULT_CLUSTER_MANAGER_NODE_TIMEOUT;
+    protected TimeValue masterNodeTimeout = clusterManagerNodeTimeout;
+    public static final TimeValue DEFAULT_ACK_TIMEOUT = timeValueSeconds(30);
+    protected TimeValue timeout = DEFAULT_ACK_TIMEOUT;
+
+    protected ClusterManagerNodeAckRequest() {}
+
+    protected ClusterManagerNodeAckRequest(StreamInput in) throws IOException {
+        super(in);
+        clusterManagerNodeTimeout = in.readTimeValue();
+    }
+
+    @Override
+    public void writeTo(StreamOutput out) throws IOException {
+        super.writeTo(out);
+        out.writeTimeValue(clusterManagerNodeTimeout);
+    }
+
+    /**
+     * A timeout value in case the cluster-manager has not been discovered yet or disconnected.
+     */
+    @SuppressWarnings("unchecked")
+    public final ClusterManagerNodeAckRequest clusterManagerNodeTimeout(TimeValue timeout) {
+        this.clusterManagerNodeTimeout = timeout;
+        return this;
+    }
+
+    /**
+     * A timeout value in case the cluster-manager has not been discovered yet or disconnected.
+     */
+    public final ClusterManagerNodeAckRequest clusterManagerNodeTimeout(String timeout) {
+        return clusterManagerNodeTimeout(
+            TimeValue.parseTimeValue(timeout, null, getClass().getSimpleName() + ".clusterManagerNodeTimeout")
+        );
+    }
+
+    public final TimeValue clusterManagerNodeTimeout() {
+        return this.clusterManagerNodeTimeout;
+    }
+
+    /** @deprecated As of 2.1, because supporting inclusive language, replaced by {@link #clusterManagerNodeTimeout()} */
+    @Deprecated
+    public final TimeValue masterNodeTimeout() {
+        return clusterManagerNodeTimeout();
+    }
+
+    @Override
+    public ActionRequestValidationException validate() {
+        return null;
+    }
+    @Override
+    public TimeValue ackTimeout() {
+        return this.timeout;
+    }
+}