MetricsInspector.groovy 653 B

123456789101112131415161718192021222324
  1. /*
  2. * Copyright The OpenTelemetry Authors
  3. * SPDX-License-Identifier: Apache-2.0
  4. */
  5. package io.opentelemetry.smoketest
  6. import io.opentelemetry.proto.collector.metrics.v1.ExportMetricsServiceRequest
  7. class MetricsInspector {
  8. final Collection<ExportMetricsServiceRequest> requests
  9. MetricsInspector(Collection<ExportMetricsServiceRequest> requests) {
  10. this.requests = requests
  11. }
  12. boolean hasMetricsNamed(String metricName) {
  13. requests.stream()
  14. .flatMap({ it.resourceMetricsList.stream() })
  15. .flatMap({ it.scopeMetricsList.stream() })
  16. .flatMap({ it.metricsList.stream() })
  17. .anyMatch({ it.name == metricName })
  18. }
  19. }