Skip to content

Commit ffc91d1

Browse files
committed
Convert 3-arg waitAndAssertMetrics to 2-arg form (opentelemetry-api + misc)
Part 2 of 3. Covers opentelemetry-api-1.10..1.38 MeterTest variants plus avaje-jex, dropwizard, javalin, spring-boot-actuator, and testing-common. Mechanical conversion: wherever the body was metrics -> metrics.anySatisfy(metric -> assertThat(metric).X) it becomes metric -> metric.hasName(NAME).X
1 parent b13eb10 commit ffc91d1

17 files changed

Lines changed: 1321 additions & 1490 deletions

File tree

  • instrumentation
    • avaje-jex-3.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/avaje/jex/v3_0
    • dropwizard/dropwizard-metrics-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/dropwizardmetrics/v4_0
    • javalin/testing/src/main/java/io/opentelemetry/instrumentation/javalin
    • opentelemetry-api
      • opentelemetry-api-1.10/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_10/metrics
      • opentelemetry-api-1.15/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_15/metrics
      • opentelemetry-api-1.31/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_31/metrics
      • opentelemetry-api-1.32/javaagent/src
        • incubatorTest/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_32/incubator/metrics
        • test/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_32/metrics
      • opentelemetry-api-1.37/javaagent/src
        • incubatorTest/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_37/incubator/metrics
        • oldAndNewIncubatorTest/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_37/incubator/metrics
        • test/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_37/metrics
      • opentelemetry-api-1.38/javaagent/src
        • incubatorTest/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_38/incubator/metrics
        • test/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_38/metrics
    • spring/spring-boot-actuator-autoconfigure-2.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/spring/actuator/v2_0
  • testing-common/src/main/java/io/opentelemetry/instrumentation/testing/junit/http

instrumentation/avaje-jex-3.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/avaje/jex/v3_0/JexTest.java

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -121,14 +121,12 @@ void testHttpRouteMetricWithPathParamResponseSuccessful() {
121121
assertThat(response.status().code()).isEqualTo(200);
122122
testing.waitAndAssertMetrics(
123123
instrumentation,
124-
"http.server.request.duration",
125-
metrics ->
126-
metrics.anySatisfy(
127-
metric ->
128-
assertThat(metric)
129-
.hasHistogramSatisfying(
130-
histogram ->
131-
histogram.hasPointsSatisfying(
132-
point -> point.hasAttribute(HTTP_ROUTE, "/test/param/{id}")))));
124+
metric ->
125+
metric
126+
.hasName("http.server.request.duration")
127+
.hasHistogramSatisfying(
128+
histogram ->
129+
histogram.hasPointsSatisfying(
130+
point -> point.hasAttribute(HTTP_ROUTE, "/test/param/{id}"))));
133131
}
134132
}

instrumentation/dropwizard/dropwizard-metrics-4.0/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/dropwizardmetrics/v4_0/DropwizardMetricsTest.java

Lines changed: 28 additions & 45 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55

66
package io.opentelemetry.javaagent.instrumentation.dropwizardmetrics.v4_0;
77

8-
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.assertThat;
98
import static java.util.concurrent.TimeUnit.MILLISECONDS;
109
import static java.util.concurrent.TimeUnit.NANOSECONDS;
1110
import static java.util.concurrent.TimeUnit.SECONDS;
@@ -42,13 +41,10 @@ void gauge() throws InterruptedException {
4241
// then
4342
testing.waitAndAssertMetrics(
4443
INSTRUMENTATION_NAME,
45-
"testgauge",
46-
metrics ->
47-
metrics.anySatisfy(
48-
metric ->
49-
assertThat(metric)
50-
.hasDoubleGaugeSatisfying(
51-
g -> g.hasPointsSatisfying(point -> point.hasValue(42)))));
44+
metric ->
45+
metric
46+
.hasName("testgauge")
47+
.hasDoubleGaugeSatisfying(g -> g.hasPointsSatisfying(point -> point.hasValue(42))));
5248

5349
// when
5450
metricRegistry.remove("test'gauge");
@@ -75,15 +71,11 @@ void counter() throws InterruptedException {
7571
// then
7672
testing.waitAndAssertMetrics(
7773
INSTRUMENTATION_NAME,
78-
"testcounter",
79-
metrics ->
80-
metrics.anySatisfy(
81-
metric ->
82-
assertThat(metric)
83-
.hasLongSumSatisfying(
84-
sum ->
85-
sum.isNotMonotonic()
86-
.hasPointsSatisfying(point -> point.hasValue(7)))));
74+
metric ->
75+
metric
76+
.hasName("testcounter")
77+
.hasLongSumSatisfying(
78+
sum -> sum.isNotMonotonic().hasPointsSatisfying(point -> point.hasValue(7))));
8779
testing.clearData();
8880

8981
// when
@@ -109,15 +101,13 @@ void histogram() throws InterruptedException {
109101
// then
110102
testing.waitAndAssertMetrics(
111103
INSTRUMENTATION_NAME,
112-
"testhistogram",
113-
metrics ->
114-
metrics.anySatisfy(
115-
metric ->
116-
assertThat(metric)
117-
.hasHistogramSatisfying(
118-
histogramMetric ->
119-
histogramMetric.hasPointsSatisfying(
120-
point -> point.hasSum(42).hasCount(2)))));
104+
metric ->
105+
metric
106+
.hasName("testhistogram")
107+
.hasHistogramSatisfying(
108+
histogramMetric ->
109+
histogramMetric.hasPointsSatisfying(
110+
point -> point.hasSum(42).hasCount(2))));
121111
testing.clearData();
122112

123113
// when
@@ -143,15 +133,11 @@ void meter() throws InterruptedException {
143133
// then
144134
testing.waitAndAssertMetrics(
145135
INSTRUMENTATION_NAME,
146-
"testmeter",
147-
metrics ->
148-
metrics.anySatisfy(
149-
metric ->
150-
assertThat(metric)
151-
.hasLongSumSatisfying(
152-
sum ->
153-
sum.isMonotonic()
154-
.hasPointsSatisfying(point -> point.hasValue(12)))));
136+
metric ->
137+
metric
138+
.hasName("testmeter")
139+
.hasLongSumSatisfying(
140+
sum -> sum.isMonotonic().hasPointsSatisfying(point -> point.hasValue(12))));
155141
testing.clearData();
156142

157143
// when
@@ -178,16 +164,13 @@ void timer() throws InterruptedException {
178164
// then
179165
testing.waitAndAssertMetrics(
180166
INSTRUMENTATION_NAME,
181-
"testtimer",
182-
metrics ->
183-
metrics.anySatisfy(
184-
metric ->
185-
assertThat(metric)
186-
.hasUnit("ms")
187-
.hasHistogramSatisfying(
188-
histogram ->
189-
histogram.hasPointsSatisfying(
190-
point -> point.hasSum(1.234).hasCount(2)))));
167+
metric ->
168+
metric
169+
.hasName("testtimer")
170+
.hasUnit("ms")
171+
.hasHistogramSatisfying(
172+
histogram ->
173+
histogram.hasPointsSatisfying(point -> point.hasSum(1.234).hasCount(2))));
191174
testing.clearData();
192175

193176
// when

instrumentation/javalin/testing/src/main/java/io/opentelemetry/instrumentation/javalin/AbstractJavalinTest.java

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -161,14 +161,12 @@ void testHttpRouteMetricWithPathParamResponseSuccessful() {
161161
testing()
162162
.waitAndAssertMetrics(
163163
getJettyInstrumentation(),
164-
"http.server.request.duration",
165-
metrics ->
166-
metrics.anySatisfy(
167-
metric ->
168-
assertThat(metric)
169-
.hasHistogramSatisfying(
170-
histogram ->
171-
histogram.hasPointsSatisfying(
172-
point -> point.hasAttribute(HTTP_ROUTE, "/param/{id}")))));
164+
metric ->
165+
metric
166+
.hasName("http.server.request.duration")
167+
.hasHistogramSatisfying(
168+
histogram ->
169+
histogram.hasPointsSatisfying(
170+
point -> point.hasAttribute(HTTP_ROUTE, "/param/{id}"))));
173171
}
174172
}

instrumentation/opentelemetry-api/opentelemetry-api-1.10/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/opentelemetryapi/v1_10/metrics/CallbackGcCloseTest.java

Lines changed: 10 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -83,13 +83,11 @@ void instrumentClosedWhenClassLoaderCollected() throws Exception {
8383
// 3. Verify the gauge is producing metrics.
8484
testing.waitAndAssertMetrics(
8585
instrumentationName,
86-
"test.gc.close",
87-
metrics ->
88-
metrics.anySatisfy(
89-
metric ->
90-
assertThat(metric)
91-
.hasLongGaugeSatisfying(
92-
gauge -> gauge.hasPointsSatisfying(point -> point.hasValue(42)))));
86+
metric ->
87+
metric
88+
.hasName("test.gc.close")
89+
.hasLongGaugeSatisfying(
90+
gauge -> gauge.hasPointsSatisfying(point -> point.hasValue(42))));
9391

9492
// 4. Release the classloader — simulates app undeploy.
9593
WeakReference<ClassLoader> clRef = new WeakReference<>(childCl);
@@ -125,13 +123,11 @@ void instrumentContinuesWhileCallbackAnchored() {
125123

126124
testing.waitAndAssertMetrics(
127125
instrumentationName,
128-
"test.gc.alive",
129-
metrics ->
130-
metrics.anySatisfy(
131-
metric ->
132-
assertThat(metric)
133-
.hasLongGaugeSatisfying(
134-
gauge -> gauge.hasPointsSatisfying(point -> point.hasValue(99)))));
126+
metric ->
127+
metric
128+
.hasName("test.gc.alive")
129+
.hasLongGaugeSatisfying(
130+
gauge -> gauge.hasPointsSatisfying(point -> point.hasValue(99))));
135131

136132
// prevent callback from being collected during the test
137133
assertThat(callback).isNotNull();

0 commit comments

Comments
 (0)