Skip to content

Commit

Permalink
add byte of dashboard
Browse files Browse the repository at this point in the history
  • Loading branch information
@smartloli
smartloli committed Aug 18, 2023
1 parent b7633a7 commit 3e571da
Show file tree
Hide file tree
Showing 4 changed files with 50 additions and 953 deletions.
35 changes: 25 additions & 10 deletions efak-common/src/main/java/org/kafka/eagle/common/utils/StrUtils.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -84,24 +84,39 @@ public static JSONObject stringifyByObject(String byteNumber) {
public static JSONObject stringifyByObject(double byteNumber) {
JSONObject object = new JSONObject();
if (byteNumber / TB_IN_BYTES > 1) {
object.put("size", df.format(byteNumber / (double) TB_IN_BYTES));
object.put("type", "TB");
String size = df.format(byteNumber / (double) TB_IN_BYTES);
String type = "TB";
object.put("size", size);
object.put("type", type);
object.put("value", size + type);
return object;
} else if (byteNumber / GB_IN_BYTES > 1) {
object.put("size", df.format(byteNumber / (double) GB_IN_BYTES));
object.put("type", "GB");
String size = df.format(byteNumber / (double) GB_IN_BYTES);
String type = "GB";
object.put("size", size);
object.put("type", type);
object.put("value", size + type);
return object;
} else if (byteNumber / MB_IN_BYTES > 1) {
object.put("size", df.format(byteNumber / (double) MB_IN_BYTES));
object.put("type", "MB");
String size = df.format(byteNumber / (double) MB_IN_BYTES);
String type = "MB";
object.put("size", size);
object.put("type", type);
object.put("value", size + type);
return object;
} else if (byteNumber / KB_IN_BYTES > 1) {
object.put("size", df.format(byteNumber / (double) KB_IN_BYTES));
object.put("type", "KB");
String size = df.format(byteNumber / (double) KB_IN_BYTES);
String type = "KB";
object.put("size", size);
object.put("type", type);
object.put("value", size + type);
return object;
} else {
object.put("size", String.valueOf(byteNumber));
object.put("type", "B");
String size = String.valueOf(byteNumber);
String type = "B";
object.put("size", size);
object.put("type", type);
object.put("value", size + type);
return object;
}
}
Expand Down
37 changes: 25 additions & 12 deletions efak-web/src/main/java/org/kafka/eagle/web/service/impl/TopicRankDaoServiceImpl.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.kafka.eagle.common.utils.StrUtils;
import org.kafka.eagle.pojo.topic.TopicCapacityInfo;
import org.kafka.eagle.pojo.topic.TopicRankInfo;
import org.kafka.eagle.pojo.topic.TopicRankScatterInfo;
Expand Down Expand Up @@ -158,25 +159,37 @@ public List<TopicRankScatterInfo> pageTopicScatterOfTen(String clusterId, String
topicRankScatterInfo.setTopicName(topicRankInfo.getTopicName());
topicRankInfo.setTopicKey(topicRankInfo.getTopicKey());
if ("capacity".equals(topicKeyByOrder)) {
topicRankScatterInfo.setTopicCapacity(topicRankInfo.getTopicValue());
topicRankScatterInfo.setTopicByteIn(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_in").getTopicValue());
topicRankScatterInfo.setTopicByteOut(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_out").getTopicValue());
String capacity = StrUtils.stringifyByObject(topicRankInfo.getTopicValue()).getString("value");
topicRankScatterInfo.setTopicCapacity(capacity);
String byteIn = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_in").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicByteIn(byteIn);
String byteOut = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_out").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicByteOut(byteOut);
topicRankScatterInfo.setTopicLogSize(this.topic(clusterId, topicRankInfo.getTopicName(), "logsize").getTopicValue());
} else if ("logsize".equals(topicKeyByOrder)) {
topicRankScatterInfo.setTopicLogSize(topicRankInfo.getTopicValue());
topicRankScatterInfo.setTopicCapacity(this.topic(clusterId, topicRankInfo.getTopicName(), "capacity").getTopicValue());
topicRankScatterInfo.setTopicByteIn(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_in").getTopicValue());
topicRankScatterInfo.setTopicByteOut(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_out").getTopicValue());
String capacity = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "capacity").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicCapacity(capacity);
String byteIn = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_in").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicByteIn(byteIn);
String byteOut = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_out").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicByteOut(byteOut);
} else if ("byte_in".equals(topicKeyByOrder)) {
topicRankScatterInfo.setTopicByteIn(topicRankInfo.getTopicValue());
topicRankScatterInfo.setTopicCapacity(this.topic(clusterId, topicRankInfo.getTopicName(), "capacity").getTopicValue());
String byteIn = StrUtils.stringifyByObject(topicRankInfo.getTopicValue()).getString("value");
topicRankScatterInfo.setTopicByteIn(byteIn);
String capacity = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "capacity").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicCapacity(capacity);
topicRankScatterInfo.setTopicLogSize(this.topic(clusterId, topicRankInfo.getTopicName(), "logsize").getTopicValue());
topicRankScatterInfo.setTopicByteOut(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_out").getTopicValue());
String byteOut = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_out").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicByteOut(byteOut);
} else if ("byte_out".equals(topicKeyByOrder)) {
topicRankScatterInfo.setTopicByteOut(topicRankInfo.getTopicValue());
topicRankScatterInfo.setTopicCapacity(this.topic(clusterId, topicRankInfo.getTopicName(), "capacity").getTopicValue());
String byteOut = StrUtils.stringifyByObject(topicRankInfo.getTopicValue()).getString("value");
topicRankScatterInfo.setTopicByteOut(byteOut);
String capacity = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "capacity").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicCapacity(capacity);
topicRankScatterInfo.setTopicLogSize(this.topic(clusterId, topicRankInfo.getTopicName(), "logsize").getTopicValue());
topicRankScatterInfo.setTopicByteIn(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_in").getTopicValue());
String byteIn = StrUtils.stringifyByObject(this.topic(clusterId, topicRankInfo.getTopicName(), "byte_in").getTopicValue()).getString("value");
topicRankScatterInfo.setTopicByteIn(byteIn);
}
topicRankScatterInfos.add(topicRankScatterInfo);
}
Expand Down
Loading

0 comments on commit 3e571da

Please sign in to comment.