Skip to content

Commit c4d01f7

Browse files
authored
Improve Vert.x SQL stable metric tests (#19010)
1 parent 74afd50 commit c4d01f7

2 files changed

Lines changed: 22 additions & 10 deletions

File tree

  • instrumentation/vertx/vertx-sql-client
    • vertx-sql-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/sqlclient/v4_0
    • vertx-sql-client-5.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/sqlclient/v5_0

instrumentation/vertx/vertx-sql-client/vertx-sql-client-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/sqlclient/v4_0/VertxSqlClientTest.java

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6,11 +6,14 @@
66
package io.opentelemetry.javaagent.instrumentation.vertx.sqlclient.v4_0;
77

88
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitStableDatabaseSemconv;
9+
import static io.opentelemetry.instrumentation.testing.junit.db.DbClientMetricsTestUtil.assertDurationMetric;
910
import static io.opentelemetry.instrumentation.testing.junit.db.SemconvStabilityUtil.maybeStable;
1011
import static io.opentelemetry.instrumentation.testing.junit.service.SemconvServiceStabilityUtil.maybeStablePeerService;
1112
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
1213
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.satisfies;
14+
import static io.opentelemetry.semconv.DbAttributes.DB_NAMESPACE;
1315
import static io.opentelemetry.semconv.DbAttributes.DB_QUERY_SUMMARY;
16+
import static io.opentelemetry.semconv.DbAttributes.DB_SYSTEM_NAME;
1417
import static io.opentelemetry.semconv.ErrorAttributes.ERROR_TYPE;
1518
import static io.opentelemetry.semconv.ExceptionAttributes.EXCEPTION_MESSAGE;
1619
import static io.opentelemetry.semconv.ExceptionAttributes.EXCEPTION_STACKTRACE;
@@ -236,11 +239,14 @@ void testPreparedSelect() throws Exception {
236239

237240
assertPreparedSelect();
238241

239-
if (emitStableDatabaseSemconv()) {
240-
testing.waitAndAssertMetrics(
241-
"io.opentelemetry.vertx-sql-client-4.0",
242-
metric -> metric.hasName("db.client.operation.duration"));
243-
}
242+
assertDurationMetric(
243+
testing,
244+
"io.opentelemetry.vertx-sql-client-4.0",
245+
DB_SYSTEM_NAME,
246+
DB_NAMESPACE,
247+
DB_QUERY_SUMMARY,
248+
SERVER_ADDRESS,
249+
SERVER_PORT);
244250
}
245251

246252
private static void assertPreparedSelect() {

instrumentation/vertx/vertx-sql-client/vertx-sql-client-5.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/vertx/sqlclient/v5_0/VertxSqlClientTest.java

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6,11 +6,14 @@
66
package io.opentelemetry.javaagent.instrumentation.vertx.sqlclient.v5_0;
77

88
import static io.opentelemetry.instrumentation.api.internal.SemconvStability.emitStableDatabaseSemconv;
9+
import static io.opentelemetry.instrumentation.testing.junit.db.DbClientMetricsTestUtil.assertDurationMetric;
910
import static io.opentelemetry.instrumentation.testing.junit.db.SemconvStabilityUtil.maybeStable;
1011
import static io.opentelemetry.instrumentation.testing.junit.service.SemconvServiceStabilityUtil.maybeStablePeerService;
1112
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
1213
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.satisfies;
14+
import static io.opentelemetry.semconv.DbAttributes.DB_NAMESPACE;
1315
import static io.opentelemetry.semconv.DbAttributes.DB_QUERY_SUMMARY;
16+
import static io.opentelemetry.semconv.DbAttributes.DB_SYSTEM_NAME;
1417
import static io.opentelemetry.semconv.ErrorAttributes.ERROR_TYPE;
1518
import static io.opentelemetry.semconv.ExceptionAttributes.EXCEPTION_MESSAGE;
1619
import static io.opentelemetry.semconv.ExceptionAttributes.EXCEPTION_STACKTRACE;
@@ -165,11 +168,14 @@ void testSimpleSelect() throws Exception {
165168
.hasKind(SpanKind.INTERNAL)
166169
.hasParent(trace.getSpan(0))));
167170

168-
if (emitStableDatabaseSemconv()) {
169-
testing.waitAndAssertMetrics(
170-
"io.opentelemetry.vertx-sql-client-5.0",
171-
metric -> metric.hasName("db.client.operation.duration"));
172-
}
171+
assertDurationMetric(
172+
testing,
173+
"io.opentelemetry.vertx-sql-client-5.0",
174+
DB_SYSTEM_NAME,
175+
DB_NAMESPACE,
176+
DB_QUERY_SUMMARY,
177+
SERVER_ADDRESS,
178+
SERVER_PORT);
173179
}
174180

175181
@Test

0 commit comments

Comments
 (0)