Skip to content

Commit 8ebfb42

Browse files
bogdandrutubogdandrutu
authored
tests: move obsreport tests fixture to file (#6473)
2 parents 2ed4121 + 7ec186d commit 8ebfb42

File tree

2 files changed

+56
-44
lines changed

2 files changed

+56
-44
lines changed

‎obsreport/obsreporttest/otelprometheuschecker_test.go

Lines changed: 17 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -16,64 +16,37 @@ package obsreporttest // import "go.opentelemetry.io/collector/obsreport/obsrepo
1616

1717
import (
1818
"net/http"
19+
"os"
20+
"path/filepath"
21+
"strings"
1922
"testing"
2023

2124
"github.com/stretchr/testify/assert"
25+
"github.com/stretchr/testify/require"
2226
"go.opentelemetry.io/otel/attribute"
2327

2428
"go.opentelemetry.io/collector/config"
2529
)
2630

27-
func newStubPromChecker() prometheusChecker {
31+
func newStubPromChecker() (prometheusChecker, error) {
32+
promBytes, err := os.ReadFile(filepath.Join("testdata", "prometheus_response"))
33+
if err != nil {
34+
return prometheusChecker{}, err
35+
}
36+
37+
promResponse := strings.ReplaceAll(string(promBytes), "\r\n", "\n")
38+
2839
return prometheusChecker{
2940
promHandler: http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
30-
_, _ = w.Write([]byte(`
31-
# HELP exporter_send_failed_spans Number of spans in failed attempts to send to destination.
32-
# TYPE exporter_send_failed_spans counter
33-
exporter_send_failed_spans{exporter="fakeExporter"} 14
34-
# HELP exporter_sent_spans Number of spans successfully sent to destination.
35-
# TYPE exporter_sent_spans counter
36-
exporter_sent_spans{exporter="fakeExporter"} 43
37-
# HELP exporter_send_failed_metric_points Number of metrics in failed attempts to send to destination.
38-
# TYPE exporter_send_failed_metric_points counter
39-
exporter_send_failed_metric_points{exporter="fakeExporter"} 42
40-
# HELP exporter_sent_metric_points Number of metrics successfully sent to destination.
41-
# TYPE exporter_sent_metric_points counter
42-
exporter_sent_metric_points{exporter="fakeExporter"} 8
43-
# HELP exporter_send_failed_log_records Number of logs in failed attempts to send to destination.
44-
# TYPE exporter_send_failed_log_records counter
45-
exporter_send_failed_log_records{exporter="fakeExporter"} 36
46-
# HELP exporter_sent_log_records Number of logs successfully sent to destination.
47-
# TYPE exporter_sent_log_records counter
48-
exporter_sent_log_records{exporter="fakeExporter"} 103
49-
# HELP receiver_accepted_log_records Number of log records successfully pushed into the pipeline.
50-
# TYPE receiver_accepted_log_records counter
51-
receiver_accepted_log_records{receiver="fakeReceiver",transport="fakeTransport"} 102
52-
# HELP receiver_accepted_metric_points Number of metric points successfully pushed into the pipeline.
53-
# TYPE receiver_accepted_metric_points counter
54-
receiver_accepted_metric_points{receiver="fakeReceiver",transport="fakeTransport"} 7
55-
# HELP receiver_accepted_spans Number of spans successfully pushed into the pipeline.
56-
# TYPE receiver_accepted_spans counter
57-
receiver_accepted_spans{receiver="fakeReceiver",transport="fakeTransport"} 42
58-
# HELP receiver_refused_log_records Number of log records that could not be pushed into the pipeline.
59-
# TYPE receiver_refused_log_records counter
60-
receiver_refused_log_records{receiver="fakeReceiver",transport="fakeTransport"} 35
61-
# HELP receiver_refused_metric_points Number of metric points that could not be pushed into the pipeline.
62-
# TYPE receiver_refused_metric_points counter
63-
receiver_refused_metric_points{receiver="fakeReceiver",transport="fakeTransport"} 41
64-
# HELP receiver_refused_spans Number of spans that could not be pushed into the pipeline.
65-
# TYPE receiver_refused_spans counter
66-
receiver_refused_spans{receiver="fakeReceiver",transport="fakeTransport"} 13
67-
# HELP gauge_metric A simple gauge metric
68-
# TYPE gauge_metric gauge
69-
gauge_metric 49
70-
`))
41+
_, _ = w.Write([]byte(promResponse))
7142
}),
72-
}
43+
}, nil
7344
}
7445

7546
func TestPromChecker(t *testing.T) {
76-
pc := newStubPromChecker()
47+
pc, err := newStubPromChecker()
48+
require.NoError(t, err)
49+
7750
receiver := config.NewComponentID("fakeReceiver")
7851
exporter := config.NewComponentID("fakeExporter")
7952
transport := "fakeTransport"

‎obsreport/obsreporttest/testdata/prometheus_response

Lines changed: 39 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,39 @@
1+
# HELP exporter_send_failed_spans Number of spans in failed attempts to send to destination.
2+
# TYPE exporter_send_failed_spans counter
3+
exporter_send_failed_spans{exporter="fakeExporter"} 14
4+
# HELP exporter_sent_spans Number of spans successfully sent to destination.
5+
# TYPE exporter_sent_spans counter
6+
exporter_sent_spans{exporter="fakeExporter"} 43
7+
# HELP exporter_send_failed_metric_points Number of metrics in failed attempts to send to destination.
8+
# TYPE exporter_send_failed_metric_points counter
9+
exporter_send_failed_metric_points{exporter="fakeExporter"} 42
10+
# HELP exporter_sent_metric_points Number of metrics successfully sent to destination.
11+
# TYPE exporter_sent_metric_points counter
12+
exporter_sent_metric_points{exporter="fakeExporter"} 8
13+
# HELP exporter_send_failed_log_records Number of logs in failed attempts to send to destination.
14+
# TYPE exporter_send_failed_log_records counter
15+
exporter_send_failed_log_records{exporter="fakeExporter"} 36
16+
# HELP exporter_sent_log_records Number of logs successfully sent to destination.
17+
# TYPE exporter_sent_log_records counter
18+
exporter_sent_log_records{exporter="fakeExporter"} 103
19+
# HELP receiver_accepted_log_records Number of log records successfully pushed into the pipeline.
20+
# TYPE receiver_accepted_log_records counter
21+
receiver_accepted_log_records{receiver="fakeReceiver",transport="fakeTransport"} 102
22+
# HELP receiver_accepted_metric_points Number of metric points successfully pushed into the pipeline.
23+
# TYPE receiver_accepted_metric_points counter
24+
receiver_accepted_metric_points{receiver="fakeReceiver",transport="fakeTransport"} 7
25+
# HELP receiver_accepted_spans Number of spans successfully pushed into the pipeline.
26+
# TYPE receiver_accepted_spans counter
27+
receiver_accepted_spans{receiver="fakeReceiver",transport="fakeTransport"} 42
28+
# HELP receiver_refused_log_records Number of log records that could not be pushed into the pipeline.
29+
# TYPE receiver_refused_log_records counter
30+
receiver_refused_log_records{receiver="fakeReceiver",transport="fakeTransport"} 35
31+
# HELP receiver_refused_metric_points Number of metric points that could not be pushed into the pipeline.
32+
# TYPE receiver_refused_metric_points counter
33+
receiver_refused_metric_points{receiver="fakeReceiver",transport="fakeTransport"} 41
34+
# HELP receiver_refused_spans Number of spans that could not be pushed into the pipeline.
35+
# TYPE receiver_refused_spans counter
36+
receiver_refused_spans{receiver="fakeReceiver",transport="fakeTransport"} 13
37+
# HELP gauge_metric A simple gauge metric
38+
# TYPE gauge_metric gauge
39+
gauge_metric 49

0 commit comments

Comments
 (0)