Skip to content

Commit 0685dd6

Browse files
committed
wip
Signed-off-by: Attila Mészáros <a_meszaros@apple.com>
1 parent 5a44c3c commit 0685dd6

1 file changed

Lines changed: 8 additions & 3 deletions

File tree

  • sample-operators/metrics-processing/src/test/java/io/javaoperatorsdk/operator/sample/metrics

sample-operators/metrics-processing/src/test/java/io/javaoperatorsdk/operator/sample/metrics/MetricsHandlingE2E.java

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -227,14 +227,18 @@ private void verifyPrometheusMetrics() {
227227
"reconciliations_execution_duration_milliseconds_count",
228228
Duration.ofSeconds(30));
229229

230+
// First verify events_received_total exists at all (from ResourceEvents)
231+
assertMetricPresent(prometheusUrl, "events_received_total", Duration.ofSeconds(30));
232+
230233
// Verify timer event source events are recorded with "no_namespace" tag
231-
// Timer events are not ResourceEvents so they have no namespace
234+
// Timer events are not ResourceEvents so they have no namespace.
235+
// exported_namespace is needed because of otel collector.
232236
assertMetricPresent(
233237
prometheusUrl,
234-
"events_received_total{namespace=\"no_namespace\"}",
238+
"events_received_total{namespace=\"exported_namespace\"}",
235239
Duration.ofSeconds(30),
236240
"events_received_total",
237-
"no_namespace");
241+
"exported_namespace");
238242

239243
log.info("All metrics verified successfully in Prometheus");
240244
}
@@ -254,6 +258,7 @@ private void assertMetricPresent(
254258
log.info("{}: {}", query, result);
255259
assertThat(result).contains("\"status\":\"success\"");
256260
for (String expected : expectedSubstrings) {
261+
log.info("Checking if result: {} contains expected: {}", result, expected);
257262
assertThat(result).contains(expected);
258263
}
259264
});

0 commit comments

Comments
 (0)