Various cleanups in instrumentation-jvm (#1016)

* Various cleanups in instrumentation-jvm

Signed-off-by: Mickael Maison <[email protected]>

* Add comment in ProcessMetricsTest.testGoodCase

Signed-off-by: Mickael Maison <[email protected]>

---------

Signed-off-by: Mickael Maison <[email protected]>
Co-authored-by: Gregor Zeitlinger <[email protected]>

Author: mimaison

prometheus-metrics-instrumentation-jvm/src/main/java/io/prometheus/metrics/instrumentation/jvm/JvmMemoryPoolAllocationMetrics.java

@@ -49,13 +49,11 @@ public class JvmMemoryPoolAllocationMetrics {
   private static final String JVM_MEMORY_POOL_ALLOCATED_BYTES_TOTAL =
       "jvm_memory_pool_allocated_bytes_total";
 
-  private final PrometheusProperties config;
   private final List<GarbageCollectorMXBean> garbageCollectorBeans;
 
   private JvmMemoryPoolAllocationMetrics(
       List<GarbageCollectorMXBean> garbageCollectorBeans, PrometheusProperties config) {
     this.garbageCollectorBeans = garbageCollectorBeans;
-    this.config = config;
   }
 
   private void register(PrometheusRegistry registry) {
@@ -80,7 +78,7 @@ private void register(PrometheusRegistry registry) {
 
   static class AllocationCountingNotificationListener implements NotificationListener {
 
-    private final Map<String, Long> lastMemoryUsage = new HashMap<String, Long>();
+    private final Map<String, Long> lastMemoryUsage = new HashMap<>();
     private final Counter counter;
 
     AllocationCountingNotificationListener(Counter counter) {

prometheus-metrics-instrumentation-jvm/src/main/java/io/prometheus/metrics/instrumentation/jvm/JvmNativeMemoryMetrics.java

@@ -134,12 +134,8 @@ private Consumer<GaugeWithCallback.Callback> makeCallback(Boolean reserved) {
         Matcher matcher = pattern.matcher(summary);
         while (matcher.find()) {
           String category = matcher.group(1);
-          long value;
-          if (reserved) {
-            value = Long.parseLong(matcher.group(2));
-          } else {
-            value = Long.parseLong(matcher.group(3));
-          }
+          long value =
+              reserved ? Long.parseLong(matcher.group(2)) : Long.parseLong(matcher.group(3));
           callback.call(value, category);
         }
       }

prometheus-metrics-instrumentation-jvm/src/main/java/io/prometheus/metrics/instrumentation/jvm/JvmThreadsMetrics.java

@@ -155,7 +155,7 @@ private Map<String, Integer> getThreadStateCountMap(ThreadMXBean threadBean) {
     ThreadInfo[] allThreads = threadBean.getThreadInfo(threadIds, 0);
 
     // Initialize the map with all thread states
-    HashMap<String, Integer> threadCounts = new HashMap<String, Integer>();
+    Map<String, Integer> threadCounts = new HashMap<>();
     for (Thread.State state : Thread.State.values()) {
       threadCounts.put(state.name(), 0);
     }

prometheus-metrics-instrumentation-jvm/src/main/java/io/prometheus/metrics/instrumentation/jvm/ProcessMetrics.java

@@ -72,7 +72,7 @@ public class ProcessMetrics {
   private static final String PROCESS_VIRTUAL_MEMORY_BYTES = "process_virtual_memory_bytes";
   private static final String PROCESS_RESIDENT_MEMORY_BYTES = "process_resident_memory_bytes";
 
-  private static final File PROC_SELF_STATUS = new File("/proc/self/status");
+  static final File PROC_SELF_STATUS = new File("/proc/self/status");
 
   private final PrometheusProperties config;
   private final OperatingSystemMXBean osBean;

prometheus-metrics-instrumentation-jvm/src/test/java/io/prometheus/metrics/instrumentation/jvm/JvmBufferPoolMetricsTest.java

@@ -1,6 +1,7 @@
 package io.prometheus.metrics.instrumentation.jvm;
 
 import static io.prometheus.metrics.instrumentation.jvm.TestUtil.convertToOpenMetricsFormat;
+import static org.junit.Assert.assertEquals;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
@@ -11,7 +12,6 @@
 import java.io.IOException;
 import java.lang.management.BufferPoolMXBean;
 import java.util.Arrays;
-import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 import org.mockito.Mockito;
@@ -59,7 +59,7 @@ public void testGoodCase() throws IOException {
             + "jvm_buffer_pool_used_bytes{pool=\"mapped\"} 2345.0\n"
             + "# EOF\n";
 
-    Assert.assertEquals(expected, convertToOpenMetricsFormat(snapshots));
+    assertEquals(expected, convertToOpenMetricsFormat(snapshots));
   }
 
   @Test

prometheus-metrics-instrumentation-jvm/src/test/java/io/prometheus/metrics/instrumentation/jvm/JvmClassLoadingMetricsTest.java

@@ -1,6 +1,7 @@
 package io.prometheus.metrics.instrumentation.jvm;
 
 import static io.prometheus.metrics.instrumentation.jvm.TestUtil.convertToOpenMetricsFormat;
+import static org.junit.Assert.assertEquals;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
@@ -10,14 +11,13 @@
 import io.prometheus.metrics.model.snapshots.MetricSnapshots;
 import java.io.IOException;
 import java.lang.management.ClassLoadingMXBean;
-import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 import org.mockito.Mockito;
 
 public class JvmClassLoadingMetricsTest {
 
-  private ClassLoadingMXBean mockClassLoadingBean = Mockito.mock(ClassLoadingMXBean.class);
+  private final ClassLoadingMXBean mockClassLoadingBean = Mockito.mock(ClassLoadingMXBean.class);
 
   @Before
   public void setUp() {
@@ -45,7 +45,7 @@ public void testGoodCase() throws IOException {
             + "jvm_classes_unloaded_total 500.0\n"
             + "# EOF\n";
 
-    Assert.assertEquals(expected, convertToOpenMetricsFormat(snapshots));
+    assertEquals(expected, convertToOpenMetricsFormat(snapshots));
   }
 
   @Test

prometheus-metrics-instrumentation-jvm/src/test/java/io/prometheus/metrics/instrumentation/jvm/JvmCompilationMetricsTest.java

@@ -1,6 +1,7 @@
 package io.prometheus.metrics.instrumentation.jvm;
 
 import static io.prometheus.metrics.instrumentation.jvm.TestUtil.convertToOpenMetricsFormat;
+import static org.junit.Assert.assertEquals;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
 import static org.mockito.internal.verification.VerificationModeFactory.times;
@@ -10,18 +11,17 @@
 import io.prometheus.metrics.model.snapshots.MetricSnapshots;
 import java.io.IOException;
 import java.lang.management.CompilationMXBean;
-import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 import org.mockito.Mockito;
 
 public class JvmCompilationMetricsTest {
 
-  private CompilationMXBean mockCompilationBean = Mockito.mock(CompilationMXBean.class);
+  private final CompilationMXBean mockCompilationBean = Mockito.mock(CompilationMXBean.class);
 
   @Before
   public void setUp() {
-    when(mockCompilationBean.getTotalCompilationTime()).thenReturn(10000l);
+    when(mockCompilationBean.getTotalCompilationTime()).thenReturn(10000L);
     when(mockCompilationBean.isCompilationTimeMonitoringSupported()).thenReturn(true);
   }
 
@@ -39,7 +39,7 @@ public void testGoodCase() throws IOException {
             + "jvm_compilation_time_seconds_total 10.0\n"
             + "# EOF\n";
 
-    Assert.assertEquals(expected, convertToOpenMetricsFormat(snapshots));
+    assertEquals(expected, convertToOpenMetricsFormat(snapshots));
   }
 
   @Test
@@ -54,6 +54,6 @@ public void testIgnoredMetricNotScraped() {
     MetricSnapshots snapshots = registry.scrape(filter);
 
     verify(mockCompilationBean, times(0)).getTotalCompilationTime();
-    Assert.assertEquals(0, snapshots.size());
+    assertEquals(0, snapshots.size());
   }
 }

prometheus-metrics-instrumentation-jvm/src/test/java/io/prometheus/metrics/instrumentation/jvm/JvmGarbageCollectorMetricsTest.java

@@ -1,6 +1,7 @@
 package io.prometheus.metrics.instrumentation.jvm;
 
 import static io.prometheus.metrics.instrumentation.jvm.TestUtil.convertToOpenMetricsFormat;
+import static org.junit.Assert.assertEquals;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
@@ -12,15 +13,14 @@
 import java.lang.management.GarbageCollectorMXBean;
 import java.util.Arrays;
 import java.util.concurrent.TimeUnit;
-import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 import org.mockito.Mockito;
 
 public class JvmGarbageCollectorMetricsTest {
 
-  private GarbageCollectorMXBean mockGcBean1 = Mockito.mock(GarbageCollectorMXBean.class);
-  private GarbageCollectorMXBean mockGcBean2 = Mockito.mock(GarbageCollectorMXBean.class);
+  private final GarbageCollectorMXBean mockGcBean1 = Mockito.mock(GarbageCollectorMXBean.class);
+  private final GarbageCollectorMXBean mockGcBean2 = Mockito.mock(GarbageCollectorMXBean.class);
 
   @Before
   public void setUp() {
@@ -51,7 +51,7 @@ public void testGoodCase() throws IOException {
             + "jvm_gc_collection_seconds_sum{gc=\"MyGC2\"} 20.0\n"
             + "# EOF\n";
 
-    Assert.assertEquals(expected, convertToOpenMetricsFormat(snapshots));
+    assertEquals(expected, convertToOpenMetricsFormat(snapshots));
   }
 
   @Test
@@ -67,6 +67,6 @@ public void testIgnoredMetricNotScraped() {
 
     verify(mockGcBean1, times(0)).getCollectionTime();
     verify(mockGcBean1, times(0)).getCollectionCount();
-    Assert.assertEquals(0, snapshots.size());
+    assertEquals(0, snapshots.size());
   }
 }

prometheus-metrics-instrumentation-jvm/src/test/java/io/prometheus/metrics/instrumentation/jvm/JvmMemoryMetricsTest.java

@@ -1,6 +1,7 @@
 package io.prometheus.metrics.instrumentation.jvm;
 
 import static io.prometheus.metrics.instrumentation.jvm.TestUtil.convertToOpenMetricsFormat;
+import static org.junit.Assert.assertEquals;
 import static org.mockito.Mockito.times;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
@@ -13,22 +14,21 @@
 import java.lang.management.MemoryPoolMXBean;
 import java.lang.management.MemoryUsage;
 import java.util.Arrays;
-import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
 import org.mockito.Mockito;
 
 public class JvmMemoryMetricsTest {
 
-  private MemoryMXBean mockMemoryBean = Mockito.mock(MemoryMXBean.class);
-  private MemoryPoolMXBean mockPoolsBeanEdenSpace = Mockito.mock(MemoryPoolMXBean.class);
-  private MemoryPoolMXBean mockPoolsBeanOldGen = Mockito.mock(MemoryPoolMXBean.class);
-  private MemoryUsage memoryUsageHeap = Mockito.mock(MemoryUsage.class);
-  private MemoryUsage memoryUsageNonHeap = Mockito.mock(MemoryUsage.class);
-  private MemoryUsage memoryUsagePoolEdenSpace = Mockito.mock(MemoryUsage.class);
-  private MemoryUsage memoryUsagePoolOldGen = Mockito.mock(MemoryUsage.class);
-  private MemoryUsage memoryUsagePoolCollectionEdenSpace = Mockito.mock(MemoryUsage.class);
-  private MemoryUsage memoryUsagePoolCollectionOldGen = Mockito.mock(MemoryUsage.class);
+  private final MemoryMXBean mockMemoryBean = Mockito.mock(MemoryMXBean.class);
+  private final MemoryPoolMXBean mockPoolsBeanEdenSpace = Mockito.mock(MemoryPoolMXBean.class);
+  private final MemoryPoolMXBean mockPoolsBeanOldGen = Mockito.mock(MemoryPoolMXBean.class);
+  private final MemoryUsage memoryUsageHeap = Mockito.mock(MemoryUsage.class);
+  private final MemoryUsage memoryUsageNonHeap = Mockito.mock(MemoryUsage.class);
+  private final MemoryUsage memoryUsagePoolEdenSpace = Mockito.mock(MemoryUsage.class);
+  private final MemoryUsage memoryUsagePoolOldGen = Mockito.mock(MemoryUsage.class);
+  private final MemoryUsage memoryUsagePoolCollectionEdenSpace = Mockito.mock(MemoryUsage.class);
+  private final MemoryUsage memoryUsagePoolCollectionOldGen = Mockito.mock(MemoryUsage.class);
 
   @Before
   public void setUp() {
@@ -154,7 +154,7 @@ public void testGoodCase() throws IOException {
             + "jvm_memory_used_bytes{area=\"nonheap\"} 6.0\n"
             + "# EOF\n";
 
-    Assert.assertEquals(expected, convertToOpenMetricsFormat(snapshots));
+    assertEquals(expected, convertToOpenMetricsFormat(snapshots));
   }
 
   @Test

prometheus-metrics-instrumentation-jvm/src/test/java/io/prometheus/metrics/instrumentation/jvm/JvmMemoryPoolAllocationMetricsTest.java

@@ -1,14 +1,14 @@
 package io.prometheus.metrics.instrumentation.jvm;
 
 import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.fail;
 
 import io.prometheus.metrics.core.metrics.Counter;
 import io.prometheus.metrics.instrumentation.jvm.JvmMemoryPoolAllocationMetrics.AllocationCountingNotificationListener;
 import io.prometheus.metrics.model.registry.PrometheusRegistry;
 import io.prometheus.metrics.model.snapshots.CounterSnapshot;
 import io.prometheus.metrics.model.snapshots.MetricSnapshot;
 import io.prometheus.metrics.model.snapshots.MetricSnapshots;
-import org.junit.Assert;
 import org.junit.Test;
 
 public class JvmMemoryPoolAllocationMetricsTest {
@@ -60,7 +60,7 @@ private double getCountByPool(String metricName, String poolName, MetricSnapshot
         }
       }
     }
-    Assert.fail("pool " + poolName + " not found.");
+    fail("pool " + poolName + " not found.");
     return 0.0;
   }
 }