From 557776bfb7433d30f22fcc318c3a083386c347fd Mon Sep 17 00:00:00 2001 From: ViacheslavKlimov Date: Fri, 11 Apr 2025 12:02:00 +0300 Subject: [PATCH] Minor refactoring for EdqsStatsService --- .../server/edqs/stats/DefaultEdqsStatsService.java | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/common/edqs/src/main/java/org/thingsboard/server/edqs/stats/DefaultEdqsStatsService.java b/common/edqs/src/main/java/org/thingsboard/server/edqs/stats/DefaultEdqsStatsService.java index 4853920c44..435c7f0884 100644 --- a/common/edqs/src/main/java/org/thingsboard/server/edqs/stats/DefaultEdqsStatsService.java +++ b/common/edqs/src/main/java/org/thingsboard/server/edqs/stats/DefaultEdqsStatsService.java @@ -53,13 +53,12 @@ public class DefaultEdqsStatsService implements EdqsStatsService { private final ConcurrentMap objectCounters = new ConcurrentHashMap<>(); private final ConcurrentMap timers = new ConcurrentHashMap<>(); private final ConcurrentMap counters = new ConcurrentHashMap<>(); - private final ConcurrentMap gauges = new ConcurrentHashMap<>(); @PostConstruct private void init() { - statsFactory.createGauge("edqsGauges", "stringPoolSize", TbStringPool.getPool(), Map::size); - statsFactory.createGauge("edqsGauges", "bytePoolSize", TbBytePool.getPool(), Map::size); - statsFactory.createGauge("edqsGauges", "tenantReposSize", DefaultEdqsRepository.getRepos(), Map::size); + statsFactory.createGauge("edqsMapGauges", "stringPoolSize", TbStringPool.getPool(), Map::size); + statsFactory.createGauge("edqsMapGauges", "bytePoolSize", TbBytePool.getPool(), Map::size); + statsFactory.createGauge("edqsMapGauges", "tenantReposSize", DefaultEdqsRepository.getRepos(), Map::size); } @Override @@ -124,10 +123,6 @@ public class DefaultEdqsStatsService implements EdqsStatsService { return counters.computeIfAbsent(name, __ -> statsFactory.createStatsCounter("edqsCounters", name)); } - private AtomicInteger getGauge(String name) { - return gauges.computeIfAbsent(name, __ -> statsFactory.createGauge("edqsGauges", name, new AtomicInteger())); - } - private AtomicInteger getObjectGauge(ObjectType objectType) { return objectCounters.computeIfAbsent(objectType, type -> statsFactory.createGauge("edqsGauges", "objectsCount", new AtomicInteger(), "objectType", type.name()));