-
Notifications
You must be signed in to change notification settings - Fork 1.9k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add API for clearing file cache on search nodes
Signed-off-by: Kunal Kotwani <kkotwani@amazon.com>
- Loading branch information
1 parent
d984f50
commit 8bd6288
Showing
16 changed files
with
529 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
19 changes: 19 additions & 0 deletions
19
rest-api-spec/src/main/resources/rest-api-spec/api/nodes.clear_filecache.json
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,19 @@ | ||
| { | ||
| "nodes.clear_filecache":{ | ||
| "documentation":{ | ||
| "url": "https://opensearch.org/docs/latest/opensearch/rest-api/filecache#clear", | ||
| "description":"Clears all file caches for one or more search capable nodes." | ||
| }, | ||
| "stability":"experimental", | ||
| "url":{ | ||
| "paths":[ | ||
| { | ||
| "path":"/_filecache/clear", | ||
| "methods":[ | ||
| "POST" | ||
| ] | ||
| } | ||
| ] | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
73 changes: 73 additions & 0 deletions
73
.../org/opensearch/action/admin/cluster/node/filecache/clear/ClearNodeFileCacheResponse.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,73 @@ | ||
| /* | ||
| * 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.admin.cluster.node.filecache.clear; | ||
|
|
||
| import org.opensearch.action.support.nodes.BaseNodeResponse; | ||
| import org.opensearch.cluster.node.DiscoveryNode; | ||
| import org.opensearch.cluster.node.DiscoveryNodeRole; | ||
| import org.opensearch.common.io.stream.StreamInput; | ||
| import org.opensearch.common.io.stream.StreamOutput; | ||
| import org.opensearch.core.xcontent.ToXContentFragment; | ||
| import org.opensearch.core.xcontent.XContentBuilder; | ||
|
|
||
| import java.io.IOException; | ||
|
|
||
| /** | ||
| * The response of a clear filecache action for a single node. | ||
| * | ||
| * @opensearch.internal | ||
| */ | ||
| public class ClearNodeFileCacheResponse extends BaseNodeResponse implements ToXContentFragment { | ||
|
|
||
| boolean cleared; | ||
|
|
||
| long count; | ||
|
|
||
| protected ClearNodeFileCacheResponse(StreamInput in) throws IOException { | ||
| super(in); | ||
| cleared = in.readBoolean(); | ||
| count = in.readLong(); | ||
| } | ||
|
|
||
| public ClearNodeFileCacheResponse(DiscoveryNode discoveryNode, boolean cleared, long count) { | ||
| super(discoveryNode); | ||
| this.cleared = cleared; | ||
| this.count = count; | ||
| } | ||
|
|
||
| public boolean isCleared() { | ||
| return cleared; | ||
| } | ||
|
|
||
| public long getCount() { | ||
| return count; | ||
| } | ||
|
|
||
| @Override | ||
| public void writeTo(StreamOutput out) throws IOException { | ||
| super.writeTo(out); | ||
| out.writeBoolean(cleared); | ||
| out.writeLong(count); | ||
| } | ||
|
|
||
| @Override | ||
| public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException { | ||
| builder.field("name", getNode().getName()); | ||
|
|
||
| builder.startArray("roles"); | ||
| for (DiscoveryNodeRole role : getNode().getRoles()) { | ||
| builder.value(role.roleName()); | ||
| } | ||
| builder.endArray(); | ||
|
|
||
| builder.field("cleared", cleared); | ||
| builder.field("item_count", count); | ||
| return builder; | ||
| } | ||
| } |
26 changes: 26 additions & 0 deletions
26
...a/org/opensearch/action/admin/cluster/node/filecache/clear/ClearNodesFileCacheAction.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,26 @@ | ||
| /* | ||
| * 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.admin.cluster.node.filecache.clear; | ||
|
|
||
| import org.opensearch.action.ActionType; | ||
|
|
||
| /** | ||
| * Transport action for clearing filecache on nodes | ||
| * | ||
| * @opensearch.internal | ||
| */ | ||
| public class ClearNodesFileCacheAction extends ActionType<ClearNodesFileCacheResponse> { | ||
|
|
||
| public static final ClearNodesFileCacheAction INSTANCE = new ClearNodesFileCacheAction(); | ||
| public static final String NAME = "cluster:admin/nodes/filecache/clear"; | ||
|
|
||
| private ClearNodesFileCacheAction() { | ||
| super(NAME, ClearNodesFileCacheResponse::new); | ||
| } | ||
| } |
36 changes: 36 additions & 0 deletions
36
.../org/opensearch/action/admin/cluster/node/filecache/clear/ClearNodesFileCacheRequest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,36 @@ | ||
| /* | ||
| * 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.admin.cluster.node.filecache.clear; | ||
|
|
||
| import org.opensearch.action.support.nodes.BaseNodesRequest; | ||
| import org.opensearch.common.io.stream.StreamInput; | ||
| import org.opensearch.common.io.stream.StreamOutput; | ||
|
|
||
| import java.io.IOException; | ||
|
|
||
| /** | ||
| * Request object for clearing filecache on nodes | ||
| * | ||
| * @opensearch.internal | ||
| */ | ||
| public class ClearNodesFileCacheRequest extends BaseNodesRequest<ClearNodesFileCacheRequest> { | ||
|
|
||
| public ClearNodesFileCacheRequest() { | ||
| super((String[]) null); | ||
| } | ||
|
|
||
| public ClearNodesFileCacheRequest(StreamInput in) throws IOException { | ||
| super(in); | ||
| } | ||
|
|
||
| @Override | ||
| public void writeTo(StreamOutput out) throws IOException { | ||
| super.writeTo(out); | ||
| } | ||
| } |
63 changes: 63 additions & 0 deletions
63
...org/opensearch/action/admin/cluster/node/filecache/clear/ClearNodesFileCacheResponse.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,63 @@ | ||
| /* | ||
| * 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.admin.cluster.node.filecache.clear; | ||
|
|
||
| import org.opensearch.action.FailedNodeException; | ||
| import org.opensearch.action.support.nodes.BaseNodesResponse; | ||
| import org.opensearch.cluster.ClusterName; | ||
| import org.opensearch.common.io.stream.StreamInput; | ||
| import org.opensearch.common.io.stream.StreamOutput; | ||
| import org.opensearch.core.xcontent.ToXContentFragment; | ||
| import org.opensearch.core.xcontent.XContentBuilder; | ||
|
|
||
| import java.io.IOException; | ||
| import java.util.List; | ||
|
|
||
| /** | ||
| * The response of a clear filecache action aggregated across nodes. | ||
| * | ||
| * @opensearch.internal | ||
| */ | ||
| public class ClearNodesFileCacheResponse extends BaseNodesResponse<ClearNodeFileCacheResponse> implements ToXContentFragment { | ||
|
|
||
| ClearNodesFileCacheResponse(StreamInput in) throws IOException { | ||
| super(in); | ||
| } | ||
|
|
||
| ClearNodesFileCacheResponse( | ||
| ClusterName clusterName, | ||
| List<ClearNodeFileCacheResponse> clearNodeFileCachResponses, | ||
| List<FailedNodeException> failures | ||
| ) { | ||
| super(clusterName, clearNodeFileCachResponses, failures); | ||
| } | ||
|
|
||
| @Override | ||
| protected List<ClearNodeFileCacheResponse> readNodesFrom(StreamInput in) throws IOException { | ||
| return in.readList(ClearNodeFileCacheResponse::new); | ||
| } | ||
|
|
||
| @Override | ||
| protected void writeNodesTo(StreamOutput out, List<ClearNodeFileCacheResponse> clearNodeFileCacheResponse) throws IOException { | ||
| out.writeList(clearNodeFileCacheResponse); | ||
| } | ||
|
|
||
| @Override | ||
| public XContentBuilder toXContent(XContentBuilder builder, Params params) throws IOException { | ||
| builder.startObject("nodes"); | ||
| for (ClearNodeFileCacheResponse clearNodeFileCacheResponse : getNodes()) { | ||
| builder.startObject(clearNodeFileCacheResponse.getNode().getId()); | ||
| clearNodeFileCacheResponse.toXContent(builder, params); | ||
| builder.endObject(); | ||
| } | ||
| builder.endObject(); | ||
|
|
||
| return builder; | ||
| } | ||
| } |
Oops, something went wrong.