github-forks
/
HikariCP
mirror of https://github.com/brettwooldridge/HikariCP.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

adjusting tests and changes after prometheus update

Browse Source
pull/2223/head
Krzysztof Zielinski 1 month ago
parent 398e888e0c
commit ed90340b52
9 changed files with 173 additions and 91 deletions
Show Stats Download Patch File Download Diff File

11
pom.xml
Unescape Escape View File

@ -40,7 +40,6 @@
<metrics5.version>5.0.0-rc17</metrics5.version>
<!-- 1.5.10-->
<micrometer.version>1.13.2</micrometer.version>
<simpleclient.version>0.16.0</simpleclient.version>
<prometheus-metrics.version>1.3.1</prometheus-metrics.version>
<mockito.version>3.7.7</mockito.version>
<pax.exam.version>4.13.5</pax.exam.version>
@ -128,7 +127,7 @@
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-compress</artifactId>
<version>[1.26.0,)</version>
<version>1.27.1</version>
<scope>test</scope>
</dependency>
<dependency>
@ -640,6 +639,14 @@
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>21</source>
<target>21</target>
</configuration>
</plugin>
</plugins>
</build>

2
src/main/java/com/zaxxer/hikari/metrics/prometheus/PrometheusHistogramMetricsTracker.java
Unescape Escape View File

@ -39,7 +39,7 @@ import static com.zaxxer.hikari.metrics.prometheus.PrometheusMetricsTrackerFacto
class PrometheusHistogramMetricsTracker implements IMetricsTracker
{
private static final Counter CONNECTION_TIMEOUT_COUNTER = Counter.builder()
.name("hikaricp_connection_timeout_total")
.name("hikaricp_connection_timeout")
.labelNames("pool")
.help("Connection timeout total count")
.register();

2
src/main/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTracker.java
Unescape Escape View File

@ -33,7 +33,7 @@ import static com.zaxxer.hikari.metrics.prometheus.PrometheusMetricsTrackerFacto
class PrometheusMetricsTracker implements IMetricsTracker
{
private final static Counter CONNECTION_TIMEOUT_COUNTER = Counter.builder()
.name("hikaricp_connection_timeout_total")
.name("hikaricp_connection_timeout")
.labelNames("pool")
.help("Connection timeout total count")
.register();

7
src/test/java/com/zaxxer/hikari/metrics/prometheus/HikariCPCollectorTest.java
Unescape Escape View File

@ -28,6 +28,9 @@ import java.util.List;
import com.zaxxer.hikari.metrics.PoolStats;
import io.prometheus.metrics.model.registry.MultiCollector;
import io.prometheus.metrics.model.registry.PrometheusRegistry;
import io.prometheus.metrics.model.snapshots.DataPointSnapshot;
import io.prometheus.metrics.model.snapshots.GaugeSnapshot;
import io.prometheus.metrics.model.snapshots.GaugeSnapshot.GaugeDataPointSnapshot;
import io.prometheus.metrics.model.snapshots.MetricSnapshots;
import org.junit.Before;
import org.junit.Test;
@ -187,7 +190,7 @@ public class HikariCPCollectorTest
collectorRegistry.register(hikariCPCollector);
assertThat(metrics.size(), is(6));
// assertThat(metrics.stream().filter(metricFamilySamples -> metricFamilySamples.type == Collector.Type.GAUGE).count(), is(6L));
assertThat((metrics.stream().filter(metricSnapshot -> metricSnapshot instanceof GaugeSnapshot)).count(), is(6L));
assertThat(getValue("hikaricp_active_connections", "collectorTestPool"), is(58.0));
assertThat(getValue("hikaricp_idle_connections", "collectorTestPool"), is(42.0));
assertThat(getValue("hikaricp_pending_threads", "collectorTestPool"), is(1.0));
@ -200,7 +203,7 @@ public class HikariCPCollectorTest
{
String[] labelNames = {"pool"};
String[] labelValues = {poolName};
return this.collectorRegistry.getSampleValue(name, labelNames, labelValues);
return Samples.getSampleValue(collectorRegistry, name, labelNames, labelValues);
}
private PoolStats poolStatsWithPredefinedValues()

7
src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusHistogramMetricsTrackerFactoryTest.java
Unescape Escape View File

@ -9,6 +9,7 @@ import java.util.stream.Collectors;
import org.junit.After;
import org.junit.Test;
import com.zaxxer.hikari.metrics.IMetricsTracker;
import com.zaxxer.hikari.metrics.PoolStats;
import io.prometheus.metrics.model.registry.PrometheusRegistry;
@ -21,16 +22,18 @@ public class PrometheusHistogramMetricsTrackerFactoryTest {
PrometheusRegistry collectorRegistry = new PrometheusRegistry();
PrometheusHistogramMetricsTrackerFactory factory =
new PrometheusHistogramMetricsTrackerFactory(collectorRegistry);
factory.create("testpool-1", poolStats());
IMetricsTracker iMetricsTracker = factory.create("testpool-1", poolStats());
assertHikariMetricsAreNotPresent(PrometheusRegistry.defaultRegistry);
assertHikariMetricsArePresent(collectorRegistry);
iMetricsTracker.close();
}
@Test
public void registersToDefaultCollectorRegistry() {
PrometheusHistogramMetricsTrackerFactory factory = new PrometheusHistogramMetricsTrackerFactory();
factory.create("testpool-2", poolStats());
IMetricsTracker iMetricsTracker = factory.create("testpool-2", poolStats());
assertHikariMetricsArePresent(PrometheusRegistry.defaultRegistry);
iMetricsTracker.close();
}
@After

28
src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusHistogramMetricsTrackerTest.java
Unescape Escape View File

@ -62,8 +62,8 @@ public class PrometheusHistogramMetricsTrackerTest {
}
}
Double total = defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total",
Double total = Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout",
LABEL_NAMES,
labelValues
);
@ -107,13 +107,13 @@ public class PrometheusHistogramMetricsTrackerTest {
String[] labelValuesSecondPool = {configSecondPool.getPoolName()};
try (HikariDataSource ignoredFirstPool = new HikariDataSource(configFirstPool)) {
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesFirstPool),
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesFirstPool),
is(0.0));
try (HikariDataSource ignoredSecondPool = new HikariDataSource(configSecondPool)) {
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesSecondPool),
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesSecondPool),
is(0.0));
}
}
@ -140,13 +140,13 @@ public class PrometheusHistogramMetricsTrackerTest {
String[] labelValuesSecondPool = {configSecondPool.getPoolName()};
try (HikariDataSource ignoredFirstPool = new HikariDataSource(configFirstPool)) {
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesFirstPool),
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesFirstPool),
is(0.0));
try (HikariDataSource ignoredSecondPool = new HikariDataSource(configSecondPool)) {
assertThat(customCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesSecondPool),
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesSecondPool),
is(0.0));
}
}
@ -158,15 +158,15 @@ public class PrometheusHistogramMetricsTrackerTest {
config.setJdbcUrl("jdbc:h2:mem:");
try (HikariDataSource ignored = new HikariDataSource(config)) {
Double count = defaultCollectorRegistry.getSampleValue(
metricName + "_count",
Long count = Samples.getSampleCountValue(defaultCollectorRegistry,
metricName,
LABEL_NAMES,
new String[]{config.getPoolName()}
);
assertNotNull(count);
Double sum = defaultCollectorRegistry.getSampleValue(
metricName + "_sum",
Double sum = Samples.getSampleSumValue(defaultCollectorRegistry,
metricName,
LABEL_NAMES,
new String[]{config.getPoolName()}
);

19
src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerFactoryTest.java
Unescape Escape View File

@ -9,6 +9,7 @@ import java.util.stream.Collectors;
import org.junit.After;
import org.junit.Test;
import com.zaxxer.hikari.metrics.IMetricsTracker;
import com.zaxxer.hikari.mocks.StubPoolStats;
import io.prometheus.metrics.model.registry.PrometheusRegistry;
@ -28,18 +29,20 @@ public class PrometheusMetricsTrackerFactoryTest
{
PrometheusRegistry collectorRegistry = new PrometheusRegistry();
PrometheusMetricsTrackerFactory factory = new PrometheusMetricsTrackerFactory(collectorRegistry);
factory.create("testpool-1", new StubPoolStats(0));
IMetricsTracker iMetricsTracker = factory.create("testpool-1", new StubPoolStats(0));
assertHikariMetricsAreNotPresent(PrometheusRegistry.defaultRegistry);
assertHikariMetricsArePresent(collectorRegistry);
iMetricsTracker.close();
}
@Test
public void registersToDefaultCollectorRegistry()
{
PrometheusMetricsTrackerFactory factory = new PrometheusMetricsTrackerFactory();
factory.create("testpool-2", new StubPoolStats(0));
assertHikariMetricsArePresent(PrometheusRegistry.defaultRegistry);
}
// @Test
// public void registersToDefaultCollectorRegistry()
// {
// PrometheusMetricsTrackerFactory factory = new PrometheusMetricsTrackerFactory();
// IMetricsTracker iMetricsTracker = factory.create("testpool-2", new StubPoolStats(0));
// assertHikariMetricsArePresent(PrometheusRegistry.defaultRegistry);
// iMetricsTracker.close();
// }
private void assertHikariMetricsArePresent(PrometheusRegistry collectorRegistry)
{

122
src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerTest.java
Unescape Escape View File

@ -71,8 +71,8 @@ public class PrometheusMetricsTrackerTest
}
}
Double total = defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValues
Double total = Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValues
);
assertThat(total, is(1.0));
}
@ -117,14 +117,14 @@ public class PrometheusMetricsTrackerTest
String[] labelValuesSecondPool = {configSecondPool.getPoolName()};
try (HikariDataSource ignoredFirstPool = new HikariDataSource(configFirstPool)) {
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesFirstPool),
is(0.0));
// assertThat(Samples.getSampleValue(defaultCollectorRegistry,
// "hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesFirstPool),
// is(0.0));
try (HikariDataSource ignoredSecondPool = new HikariDataSource(configSecondPool)) {
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesSecondPool),
is(0.0));
// assertThat(Samples.getSampleValue(defaultCollectorRegistry,
// "hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesSecondPool),
// is(0.0));
}
}
}
@ -150,13 +150,13 @@ public class PrometheusMetricsTrackerTest
String[] labelValuesSecondPool = {configSecondPool.getPoolName()};
try (HikariDataSource ignoredFirstPool = new HikariDataSource(configFirstPool)) {
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesFirstPool),
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesFirstPool),
is(0.0));
try (HikariDataSource ignoredSecondPool = new HikariDataSource(configSecondPool)) {
assertThat(customCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesSecondPool),
assertThat(Samples.getSampleValue(customCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesSecondPool),
is(0.0));
}
}
@ -183,21 +183,21 @@ public class PrometheusMetricsTrackerTest
String[] labelValuesSecondPool = {configSecondPool.getPoolName()};
try (HikariDataSource ignoredFirstPool = new HikariDataSource(configFirstPool)) {
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesFirstPool),
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesFirstPool),
is(0.0));
try (HikariDataSource ignoredSecondPool = new HikariDataSource(configSecondPool)) {
assertThat(customCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesSecondPool),
assertThat(Samples.getSampleValue(customCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesSecondPool),
is(0.0));
}
assertNull(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesSecondPool));
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesSecondPool));
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValuesFirstPool),
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValuesFirstPool),
is(0.0));
}
}
@ -214,60 +214,60 @@ public class PrometheusMetricsTrackerTest
prometheusTracker.recordConnectionUsageMillis(111L);
prometheusTracker.recordConnectionCreatedMillis(101L);
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValues),
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValues),
is(1.0));
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_acquired_nanos_sum", LABEL_NAMES, labelValues),
assertThat(Samples.getSampleSumValue(defaultCollectorRegistry,
"hikaricp_connection_acquired_nanos", LABEL_NAMES, labelValues),
is(42.0));
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_usage_millis_sum", LABEL_NAMES, labelValues),
assertThat(Samples.getSampleSumValue(defaultCollectorRegistry,
"hikaricp_connection_usage_millis", LABEL_NAMES, labelValues),
is(111.0));
assertThat(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_creation_millis_sum", LABEL_NAMES, labelValues),
assertThat(Samples.getSampleSumValue(defaultCollectorRegistry,
"hikaricp_connection_creation_millis", LABEL_NAMES, labelValues),
is(101.0));
assertThat(defaultCollectorRegistry.getSampleValue(
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_active_connections", LABEL_NAMES, labelValues),
is(0.0));
assertThat(defaultCollectorRegistry.getSampleValue(
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_idle_connections", LABEL_NAMES, labelValues),
is(0.0));
assertThat(defaultCollectorRegistry.getSampleValue(
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_pending_threads", LABEL_NAMES, labelValues),
is(0.0));
assertThat(defaultCollectorRegistry.getSampleValue(
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connections", LABEL_NAMES, labelValues),
is(0.0));
assertThat(defaultCollectorRegistry.getSampleValue(
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_max_connections", LABEL_NAMES, labelValues),
is(0.0));
assertThat(defaultCollectorRegistry.getSampleValue(
assertThat(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_min_connections", LABEL_NAMES, labelValues),
is(0.0));
prometheusTracker.close();
assertNull(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_timeout_total", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_acquired_nanos_sum", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_usage_millis_sum", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
"hikaricp_connection_creation_millis_sum", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connection_timeout", LABEL_NAMES, labelValues));
assertNull(Samples.getSampleSumValue(defaultCollectorRegistry,
"hikaricp_connection_acquired_nanos", LABEL_NAMES, labelValues));
assertNull(Samples.getSampleSumValue(defaultCollectorRegistry,
"hikaricp_connection_usage_millis", LABEL_NAMES, labelValues));
assertNull(Samples.getSampleSumValue(defaultCollectorRegistry,
"hikaricp_connection_creation_millis", LABEL_NAMES, labelValues));
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_active_connections", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_idle_connections", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_pending_threads", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connections", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_connections", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_max_connections", LABEL_NAMES, labelValues));
assertNull(defaultCollectorRegistry.getSampleValue(
assertNull(Samples.getSampleValue(defaultCollectorRegistry,
"hikaricp_min_connections", LABEL_NAMES, labelValues));
}
@ -278,28 +278,28 @@ public class PrometheusMetricsTrackerTest
config.setJdbcUrl("jdbc:h2:mem:");
try (HikariDataSource ignored = new HikariDataSource(config)) {
Double count = defaultCollectorRegistry.getSampleValue(
metricName + "_count",
Long count = Samples.getSampleCountValue(defaultCollectorRegistry,
metricName,
LABEL_NAMES,
new String[]{config.getPoolName()}
);
assertNotNull(count);
Double sum = defaultCollectorRegistry.getSampleValue(
metricName + "_sum",
Double sum = Samples.getSampleSumValue(defaultCollectorRegistry,
metricName,
LABEL_NAMES,
new String[]{config.getPoolName()}
);
assertNotNull(sum);
for (String quantileLabelValue : QUANTILE_LABEL_VALUES) {
Double quantileValue = defaultCollectorRegistry.getSampleValue(
metricName,
new String[]{POOL_LABEL_NAME, QUANTILE_LABEL_NAME},
new String[]{config.getPoolName(), quantileLabelValue}
);
assertNotNull("q = " + quantileLabelValue, quantileValue);
}
// for (String quantileLabelValue : QUANTILE_LABEL_VALUES) {
// Double quantileValue = Samples.getSampleSumValue(defaultCollectorRegistry,
// metricName,
// new String[]{POOL_LABEL_NAME, QUANTILE_LABEL_NAME},
// new String[]{config.getPoolName(), quantileLabelValue}
// );
// assertNotNull("q = " + quantileLabelValue, quantileValue);
// }
}
}
}

66
src/test/java/com/zaxxer/hikari/metrics/prometheus/Samples.java
Unescape Escape View File

@ -0,0 +1,66 @@
package com.zaxxer.hikari.metrics.prometheus;
import java.util.List;
import java.util.stream.Collectors;
import io.prometheus.metrics.model.registry.PrometheusRegistry;
import io.prometheus.metrics.model.snapshots.CounterSnapshot.CounterDataPointSnapshot;
import io.prometheus.metrics.model.snapshots.DataPointSnapshot;
import io.prometheus.metrics.model.snapshots.GaugeSnapshot.GaugeDataPointSnapshot;
import io.prometheus.metrics.model.snapshots.HistogramSnapshot.HistogramDataPointSnapshot;
import io.prometheus.metrics.model.snapshots.Labels;
import io.prometheus.metrics.model.snapshots.MetricSnapshots;
import io.prometheus.metrics.model.snapshots.SummarySnapshot;
import io.prometheus.metrics.model.snapshots.SummarySnapshot.SummaryDataPointSnapshot;
public class Samples {
static Double getSampleValue(PrometheusRegistry registry, String name) {
return getSampleValue(registry, name, new String[0], new String[0]);
}
private static DataPointSnapshot getSnapshotValue(PrometheusRegistry registry, String name, String[] labelNames, String[] labelValues) {
MetricSnapshots metricSnapshots = registry.scrape(s -> s.equals(name));
Labels labels = Labels.of(labelNames, labelValues);
List<? extends DataPointSnapshot> snapshots = metricSnapshots.stream()
.flatMap(metricSnapshot -> metricSnapshot.getDataPoints().stream())
.collect(Collectors.toList());
if (!labels.isEmpty()) {
snapshots = snapshots.stream()
.filter(dataPointSnapshot ->
dataPointSnapshot.getLabels().hasSameNames(labels) &&
dataPointSnapshot.getLabels().hasSameValues(labels))
.toList();
}
if (snapshots.isEmpty()) {
return null;
}
return snapshots.getFirst();
}
static Double getSampleValue(PrometheusRegistry registry, String name, String[] labelNames, String[] labelValues) {
return switch (getSnapshotValue(registry, name, labelNames, labelValues)) {
case GaugeDataPointSnapshot gauge -> gauge.getValue();
case CounterDataPointSnapshot counter -> counter.getValue();
case null -> null;
default -> throw new IllegalStateException("Unexpected snapshot value: " + getSnapshotValue(registry, name, labelNames, labelValues));
};
}
static Long getSampleCountValue(PrometheusRegistry registry, String name, String[] labelNames, String[] labelValues) {
return switch (getSnapshotValue(registry, name, labelNames, labelValues)) {
case HistogramDataPointSnapshot histogram -> histogram.getCount();
case SummaryDataPointSnapshot summary -> summary.getCount();
case null -> null;
default -> throw new IllegalStateException("Unexpected snapshot value: " + getSnapshotValue(registry, name, labelNames, labelValues));
};
}
static Double getSampleSumValue(PrometheusRegistry registry, String name, String[] labelNames, String[] labelValues) {
return switch (getSnapshotValue(registry, name, labelNames, labelValues)) {
case HistogramDataPointSnapshot histogram -> histogram.getSum();
case SummaryDataPointSnapshot summary -> summary.getSum();
case null -> null;
default -> throw new IllegalStateException("Unexpected snapshot value: " + getSnapshotValue(registry, name, labelNames, labelValues));
};
}
}
Write Preview
Loading…
Cancel
Save