summaryrefslogtreecommitdiff
path: root/src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerTest.java')
-rw-r--r--src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerTest.java44
1 files changed, 40 insertions, 4 deletions
diff --git a/src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerTest.java b/src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerTest.java
index a7b0b03..079cfb5 100644
--- a/src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerTest.java
+++ b/src/test/java/com/zaxxer/hikari/metrics/prometheus/PrometheusMetricsTrackerTest.java
@@ -33,6 +33,7 @@ import com.zaxxer.hikari.HikariDataSource;
import io.prometheus.client.CollectorRegistry;
public class PrometheusMetricsTrackerTest {
+
@Test
public void recordConnectionTimeout() throws Exception {
HikariConfig config = newHikariConfig();
@@ -40,13 +41,13 @@ public class PrometheusMetricsTrackerTest {
config.setJdbcUrl("jdbc:h2:mem:");
config.setMaximumPoolSize(2);
config.setConnectionTimeout(250);
-
+
String[] labelNames = {"pool"};
String[] labelValues = {config.getPoolName()};
try (HikariDataSource hikariDataSource = new HikariDataSource(config)) {
try (Connection connection1 = hikariDataSource.getConnection();
- Connection connection2 = hikariDataSource.getConnection()) {
+ Connection connection2 = hikariDataSource.getConnection()) {
try (Connection connection3 = hikariDataSource.getConnection()) {
}
catch (SQLTransientConnectionException ignored) {
@@ -54,13 +55,13 @@ public class PrometheusMetricsTrackerTest {
}
assertThat(CollectorRegistry.defaultRegistry.getSampleValue(
- "hikaricp_connection_timeout_count",
+ "hikaricp_connection_timeout_total",
labelNames,
labelValues), is(1.0));
assertThat(CollectorRegistry.defaultRegistry.getSampleValue(
"hikaricp_connection_acquired_nanos_count",
labelNames,
- labelValues), is(equalTo(2.0)));
+ labelValues), is(equalTo(3.0)));
assertTrue(CollectorRegistry.defaultRegistry.getSampleValue(
"hikaricp_connection_acquired_nanos_sum",
labelNames,
@@ -75,4 +76,39 @@ public class PrometheusMetricsTrackerTest {
labelValues) > 0.0);
}
}
+
+ @Test
+ public void testMultiplePoolName() throws Exception {
+ String[] labelNames = {"pool"};
+
+ HikariConfig config = newHikariConfig();
+ config.setMetricsTrackerFactory(new PrometheusMetricsTrackerFactory());
+ config.setPoolName("first");
+ config.setJdbcUrl("jdbc:h2:mem:");
+ config.setMaximumPoolSize(2);
+ config.setConnectionTimeout(250);
+ String[] labelValues1 = {config.getPoolName()};
+
+ try (HikariDataSource ignored = new HikariDataSource(config)) {
+ assertThat(CollectorRegistry.defaultRegistry.getSampleValue(
+ "hikaricp_connection_timeout_total",
+ labelNames,
+ labelValues1), is(0.0));
+
+ HikariConfig config2 = newHikariConfig();
+ config2.setMetricsTrackerFactory(new PrometheusMetricsTrackerFactory());
+ config2.setPoolName("second");
+ config2.setJdbcUrl("jdbc:h2:mem:");
+ config2.setMaximumPoolSize(4);
+ config2.setConnectionTimeout(250);
+ String[] labelValues2 = {config2.getPoolName()};
+
+ try (HikariDataSource ignored2 = new HikariDataSource(config2)) {
+ assertThat(CollectorRegistry.defaultRegistry.getSampleValue(
+ "hikaricp_connection_timeout_total",
+ labelNames,
+ labelValues2), is(0.0));
+ }
+ }
+ }
}