mirror/Hangar
2
0
Fork 0
mirror of https://github.com/HangarMC/Hangar.git synced 2025-03-07 15:31:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(backend): add actuator endpoint for cache stats

Browse Source
This commit is contained in:
MiniDigger | Martin 2023-01-08 17:57:58 +01:00
parent 4964228b1a
commit d45a16339f
1 changed files with 37 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
backend/src/main/java/io/papermc/hangar/observability/CacheObservationEndpoint.java Normal file
View File

@ -0,0 +1,37 @@
package io.papermc.hangar.observability;
import com.github.benmanes.caffeine.cache.Cache;
import com.github.benmanes.caffeine.cache.stats.CacheStats;
import java.util.HashMap;
import java.util.Map;
import org.springframework.boot.actuate.endpoint.annotation.Endpoint;
import org.springframework.boot.actuate.endpoint.annotation.ReadOperation;
import org.springframework.cache.CacheManager;
import org.springframework.stereotype.Component;
@Component
@Endpoint(id = "cache-info")
public class CacheObservationEndpoint {
private final CacheManager cacheManager;
public CacheObservationEndpoint(final CacheManager cacheManager) {
this.cacheManager = cacheManager;
}
@ReadOperation
public Map<String, Stats> getData() {
final Map<String, Stats> stats = new HashMap<>();
for (final String cacheName : this.cacheManager.getCacheNames()) {
final org.springframework.cache.Cache wrapper = this.cacheManager.getCache(cacheName);
if (wrapper.getNativeCache() instanceof Cache<?, ?> cache) {
final CacheStats stat = cache.stats();
stats.put(cacheName, new Stats(cache.estimatedSize(), stat.hitCount(), stat.missCount(), stat.loadSuccessCount(), stat.loadFailureCount(), stat.totalLoadTime(),stat.evictionCount(), stat.evictionWeight()));
}
}
return stats;
}
record Stats(long size, long hitCount, long missCount, long loadSuccessCount, long loadFailureCount, long totalLoadTime, long evictionCount, long evictionWeight) {
}
}