diff --git a/internal/e2e/metric_stability_test.go b/internal/e2e/metric_stability_test.go index e6b884c0a848..8cbf46e9a89a 100644 --- a/internal/e2e/metric_stability_test.go +++ b/internal/e2e/metric_stability_test.go @@ -16,6 +16,7 @@ import ( "time" "github.com/prometheus/common/expfmt" + "github.com/prometheus/common/model" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" @@ -51,7 +52,7 @@ func assertMetrics(t *testing.T, metricsAddr string, expectedMetrics map[string] defer resp.Body.Close() reader := bufio.NewReader(resp.Body) - var parser expfmt.TextParser + parser := expfmt.NewTextParser(model.UTF8Validation) parsed, err := parser.TextToMetricFamilies(reader) if err != nil { return false diff --git a/service/service_test.go b/service/service_test.go index 8d0000db75e1..4e74ebfd541b 100644 --- a/service/service_test.go +++ b/service/service_test.go @@ -16,6 +16,7 @@ import ( "time" "github.com/prometheus/common/expfmt" + "github.com/prometheus/common/model" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" config "go.opentelemetry.io/contrib/otelconf/v0.3.0" @@ -699,7 +700,7 @@ func assertMetrics(t *testing.T, metricsAddr string, expectedLabels map[string]l }) reader := bufio.NewReader(resp.Body) - var parser expfmt.TextParser + parser := expfmt.NewTextParser(model.UTF8Validation) parsed, err := parser.TextToMetricFamilies(reader) require.NoError(t, err) diff --git a/service/telemetry/otelconftelemetry/metrics_test.go b/service/telemetry/otelconftelemetry/metrics_test.go index 55ba81ee40d5..1712c455f6f7 100644 --- a/service/telemetry/otelconftelemetry/metrics_test.go +++ b/service/telemetry/otelconftelemetry/metrics_test.go @@ -12,6 +12,7 @@ import ( io_prometheus_client "github.com/prometheus/client_model/go" "github.com/prometheus/common/expfmt" + "github.com/prometheus/common/model" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" config "go.opentelemetry.io/contrib/otelconf/v0.3.0" @@ -183,7 +184,7 @@ func getMetricsFromPrometheus(t *testing.T, endpoint string) map[string]*io_prom require.Equal(t, http.StatusOK, rr.StatusCode, "unexpected status code after %d attempts", maxRetries) defer rr.Body.Close() - var parser expfmt.TextParser + parser := expfmt.NewTextParser(model.UTF8Validation) parsed, err := parser.TextToMetricFamilies(rr.Body) require.NoError(t, err)