forked from opensearch-project/OpenSearch
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add resource usage trackers and resource usage collector service (ope…
…nsearch-project#9890) --------- Signed-off-by: Bharathwaj G <[email protected]>
- Loading branch information
1 parent
afe4c55
commit 27472b9
Showing
23 changed files
with
1,210 additions
and
7 deletions.
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
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
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
81 changes: 81 additions & 0 deletions
81
server/src/main/java/org/opensearch/node/NodeResourceUsageStats.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,81 @@ | ||
| /* | ||
| * 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.node; | ||
|
|
||
| import org.opensearch.core.common.io.stream.StreamInput; | ||
| import org.opensearch.core.common.io.stream.StreamOutput; | ||
| import org.opensearch.core.common.io.stream.Writeable; | ||
|
|
||
| import java.io.IOException; | ||
| import java.util.Locale; | ||
|
|
||
| /** | ||
| * This represents the resource usage stats of a node along with the timestamp at which the stats object was created | ||
| * in the respective node | ||
| */ | ||
| public class NodeResourceUsageStats implements Writeable { | ||
| final String nodeId; | ||
| long timestamp; | ||
| double cpuUtilizationPercent; | ||
| double memoryUtilizationPercent; | ||
|
|
||
| public NodeResourceUsageStats(String nodeId, long timestamp, double memoryUtilizationPercent, double cpuUtilizationPercent) { | ||
| this.nodeId = nodeId; | ||
| this.timestamp = timestamp; | ||
| this.cpuUtilizationPercent = cpuUtilizationPercent; | ||
| this.memoryUtilizationPercent = memoryUtilizationPercent; | ||
| } | ||
|
|
||
| public NodeResourceUsageStats(StreamInput in) throws IOException { | ||
| this.nodeId = in.readString(); | ||
| this.timestamp = in.readLong(); | ||
| this.cpuUtilizationPercent = in.readDouble(); | ||
| this.memoryUtilizationPercent = in.readDouble(); | ||
| } | ||
|
|
||
| @Override | ||
| public void writeTo(StreamOutput out) throws IOException { | ||
| out.writeString(this.nodeId); | ||
| out.writeLong(this.timestamp); | ||
| out.writeDouble(this.cpuUtilizationPercent); | ||
| out.writeDouble(this.memoryUtilizationPercent); | ||
| } | ||
|
|
||
| @Override | ||
| public String toString() { | ||
| StringBuilder sb = new StringBuilder("NodeResourceUsageStats["); | ||
| sb.append(nodeId).append("]("); | ||
| sb.append("Timestamp: ").append(timestamp); | ||
| sb.append(", CPU utilization percent: ").append(String.format(Locale.ROOT, "%.1f", cpuUtilizationPercent)); | ||
| sb.append(", Memory utilization percent: ").append(String.format(Locale.ROOT, "%.1f", memoryUtilizationPercent)); | ||
| sb.append(")"); | ||
| return sb.toString(); | ||
| } | ||
|
|
||
| NodeResourceUsageStats(NodeResourceUsageStats nodeResourceUsageStats) { | ||
| this( | ||
| nodeResourceUsageStats.nodeId, | ||
| nodeResourceUsageStats.timestamp, | ||
| nodeResourceUsageStats.memoryUtilizationPercent, | ||
| nodeResourceUsageStats.cpuUtilizationPercent | ||
| ); | ||
| } | ||
|
|
||
| public double getMemoryUtilizationPercent() { | ||
| return memoryUtilizationPercent; | ||
| } | ||
|
|
||
| public double getCpuUtilizationPercent() { | ||
| return cpuUtilizationPercent; | ||
| } | ||
|
|
||
| public long getTimestamp() { | ||
| return timestamp; | ||
| } | ||
| } |
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
Oops, something went wrong.