forked from opensearch-project/OpenSearch
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathGetAllPitNodesRequest.java
41 lines (34 loc) · 1.11 KB
/
GetAllPitNodesRequest.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
/*
* 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.
*/
package org.opensearch.action.search;
import org.opensearch.action.support.nodes.BaseNodesRequest;
import org.opensearch.cluster.node.DiscoveryNode;
import org.opensearch.common.annotation.PublicApi;
import org.opensearch.common.inject.Inject;
import org.opensearch.core.common.io.stream.StreamInput;
import org.opensearch.core.common.io.stream.StreamOutput;
import java.io.IOException;
/**
* Request to get all active PIT IDs from all nodes of cluster
*
* @opensearch.api
*/
@PublicApi(since = "2.3.0")
public class GetAllPitNodesRequest extends BaseNodesRequest<GetAllPitNodesRequest> {
@Inject
public GetAllPitNodesRequest(DiscoveryNode... concreteNodes) {
super(false, concreteNodes);
}
public GetAllPitNodesRequest(StreamInput in) throws IOException {
super(in);
}
@Override
public void writeTo(StreamOutput out) throws IOException {
super.writeTo(out);
}
}