From 4df45d8ab165054a2242353ff5877657a8c23910 Mon Sep 17 00:00:00 2001 From: "lancer.hong" Date: Fri, 22 Apr 2022 14:51:53 +0800 Subject: [PATCH] Add api resource stat --- .../main/java/we/controller/CacheCheckController.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/fizz-core/src/main/java/we/controller/CacheCheckController.java b/fizz-core/src/main/java/we/controller/CacheCheckController.java index 8cda69d..4f0aa71 100644 --- a/fizz-core/src/main/java/we/controller/CacheCheckController.java +++ b/fizz-core/src/main/java/we/controller/CacheCheckController.java @@ -120,7 +120,7 @@ public class CacheCheckController { @GetMapping("/resourceStats") public Mono resourceStats(ServerWebExchange exchange) { Map map = new HashMap<>(); - int nodeCnt = 0, serviceDefaultCnt = 0, serviceCnt = 0, appDefaultCnt = 0, appCnt = 0, ipCnt = 0, hostCnt = 0; + int nodeCnt = 0, serviceDefaultCnt = 0, serviceCnt = 0, servicePathCnt = 0, appDefaultCnt = 0, appCnt = 0, ipCnt = 0, hostCnt = 0; ConcurrentMap resourceStats = flowStat.resourceStats; Set> entrySet = resourceStats.entrySet(); for (Map.Entry entry : entrySet) { @@ -169,7 +169,9 @@ public class CacheCheckController { appCnt++; } else if (t == ResourceRateLimitConfig.Type.IP) { ipCnt++; - } else { + } else if (t == ResourceRateLimitConfig.Type.API) { + servicePathCnt++; + } else { hostCnt++; } } @@ -182,6 +184,9 @@ public class CacheCheckController { map.put("app", appCnt); map.put("ip", ipCnt); map.put("host", hostCnt); + map.put("servicePathCnt", servicePathCnt); + int totalResources = appCnt + appDefaultCnt + ipCnt + nodeCnt + hostCnt + serviceCnt + serviceDefaultCnt + servicePathCnt; + map.put("totalResources", totalResources); long size = GraphLayout.parseInstance(resourceStats).totalSize(); BigDecimal bigDecimalSize = new BigDecimal(size);