diff --git a/data-prepper-plugins/otel-apm-service-map-processor/README.md b/data-prepper-plugins/otel-apm-service-map-processor/README.md index d94444eaee..9ae39c9394 100644 --- a/data-prepper-plugins/otel-apm-service-map-processor/README.md +++ b/data-prepper-plugins/otel-apm-service-map-processor/README.md @@ -205,7 +205,7 @@ The processor generates time-series metrics as JacksonMetric events: | `request` | Sum (monotonic) | `1` | Number of requests | | `error` | Sum (monotonic) | `1` | Number of error requests (HTTP 4xx) | | `fault` | Sum (monotonic) | `1` | Number of fault requests (HTTP 5xx or ERROR status) | -| `latency_seconds` | Histogram | `s` | Request latency distribution | +| `latency` | Histogram | `s` | Request latency distribution | **Histogram Bucket Boundaries:** `[0.0, 0.005, 0.01, 0.025, 0.05, 0.075, 0.1, 0.25, 0.5, 0.75, 1.0, 2.5, 5.0, 7.5, 10.0]` diff --git a/data-prepper-plugins/otel-apm-service-map-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/otel_apm_service_map/utils/ApmServiceMapMetricsUtil.java b/data-prepper-plugins/otel-apm-service-map-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/otel_apm_service_map/utils/ApmServiceMapMetricsUtil.java index bb4f7f5042..ac4f4caec6 100644 --- a/data-prepper-plugins/otel-apm-service-map-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/otel_apm_service_map/utils/ApmServiceMapMetricsUtil.java +++ b/data-prepper-plugins/otel-apm-service-map-processor/src/main/java/org/opensearch/dataprepper/plugins/processor/otel_apm_service_map/utils/ApmServiceMapMetricsUtil.java @@ -196,7 +196,7 @@ public static List createMetricsFromAggregatedState(final Map metrics = ApmServiceMapMetricsUtil.createMetricsFromAggregatedState(metricsStateByKey); // Then - assertEquals(3, metrics.size()); // Only request, error, fault (no latency_seconds) + assertEquals(3, metrics.size()); // Only request, error, fault (no latency) } @Test @@ -521,7 +521,7 @@ void testCreateMetricsFromAggregatedState_Success() { List metrics = ApmServiceMapMetricsUtil.createMetricsFromAggregatedState(metricsStateByKey); // Then - assertEquals(4, metrics.size()); // request, error, fault, latency_seconds + assertEquals(4, metrics.size()); // request, error, fault, latency // Verify metric names List metricNames = metrics.stream() @@ -530,7 +530,7 @@ void testCreateMetricsFromAggregatedState_Success() { assertTrue(metricNames.contains("request")); assertTrue(metricNames.contains("error")); assertTrue(metricNames.contains("fault")); - assertTrue(metricNames.contains("latency_seconds")); + assertTrue(metricNames.contains("latency")); } @Test