Skip to content

Commit 8200964

Browse files
bogdandrutubogdandrutu
authored
Deprecated componenttest.TestTelemetry in favor of Telemetry (#12419)
Signed-off-by: Bogdan Drutu <[email protected]>
1 parent 139d2ce commit 8200964

File tree

8 files changed

+122
-125
lines changed

8 files changed

+122
-125
lines changed

‎.chloggen/dep-test-telemetry.yaml‎

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
# Use this changelog template to create an entry for release notes.
2+
3+
# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
4+
change_type: deprecation
5+
6+
# The name of the component, or a single word describing the area of concern, (e.g. otlpreceiver)
7+
component: componenttest
8+
9+
# A brief description of the change. Surround your text with quotes ("") if it needs to start with a backtick (`).
10+
note: Deprecated componenttest.TestTelemetry in favor of componenttest.Telemetry
11+
12+
# One or more tracking issues or pull requests related to the change
13+
issues: [12419]
14+
15+
# (Optional) One or more lines of additional information to render under the primary note.
16+
# These lines will be padded with 2 spaces and then inserted directly into the document.
17+
# Use pipe (|) for multiline entries.
18+
subtext:
19+
20+
# Optional: The change log or logs in which this entry should be included.
21+
# e.g. '[user]' or '[user, api]'
22+
# Include 'user' if the change is relevant to end users.
23+
# Include 'api' if there is a change to a library API.
24+
# Default: '[user]'
25+
change_logs: [api]

‎component/componenttest/obsreporttest.go‎

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,10 @@ const (
1919
// that are used to monitor the Collector in production deployments.
2020
// DO NOT SWITCH THE VARIABLES BELOW TO SIMILAR ONES DEFINED ON THE PACKAGE.
2121
receiverTag = "receiver"
22-
scraperTag = "scraper"
2322
transportTag = "transport"
24-
exporterTag = "exporter"
2523
)
2624

25+
// Deprecated: [v0.121.0] use the componenttest.Telemetry instead.
2726
type TestTelemetry struct {
2827
*Telemetry
2928
id component.ID
@@ -41,14 +40,12 @@ func (tts *TestTelemetry) CheckReceiverMetrics(protocol string, acceptedMetricPo
4140
return checkReceiver(tts.Telemetry, tts.id, "metric_points", protocol, acceptedMetricPoints, droppedMetricPoints)
4241
}
4342

44-
// TelemetrySettings returns the TestTelemetry's TelemetrySettings
43+
// Deprecated: [v0.121.0] use the NewTelemetrySettings from componenttest.Telemetry.
4544
func (tts *TestTelemetry) TelemetrySettings() component.TelemetrySettings {
4645
return tts.NewTelemetrySettings()
4746
}
4847

49-
// SetupTelemetry sets up the testing environment to check the metrics recorded by receivers, producers, or exporters.
50-
// The caller must pass the ID of the component being tested. The ID will be used by the CreateSettings and Check methods.
51-
// The caller must defer a call to `Shutdown` on the returned TestTelemetry.
48+
// Deprecated: [v0.121.0] use the componenttest.NewTelemetry instead.
5249
func SetupTelemetry(id component.ID) (TestTelemetry, error) {
5350
return TestTelemetry{
5451
Telemetry: NewTelemetry(

‎exporter/exporterhelper/internal/obs_report_sender_test.go‎

Lines changed: 15 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -30,15 +30,14 @@ var (
3030
)
3131

3232
func TestExportTraceDataOp(t *testing.T) {
33-
tt, err := componenttest.SetupTelemetry(exporterID)
34-
require.NoError(t, err)
33+
tt := componenttest.NewTelemetry()
3534
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
3635

37-
parentCtx, parentSpan := tt.TelemetrySettings().TracerProvider.Tracer("test").Start(context.Background(), t.Name())
36+
parentCtx, parentSpan := tt.NewTelemetrySettings().TracerProvider.Tracer("test").Start(context.Background(), t.Name())
3837
defer parentSpan.End()
3938

4039
obsrep, err := newObsReportSender(
41-
exporter.Settings{ID: exporterID, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
40+
exporter.Settings{ID: exporterID, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
4241
pipeline.SignalTraces,
4342
newNoopExportSender(),
4443
)
@@ -75,7 +74,7 @@ func TestExportTraceDataOp(t *testing.T) {
7574
}
7675
}
7776

78-
metadatatest.AssertEqualExporterSentSpans(t, tt.Telemetry,
77+
metadatatest.AssertEqualExporterSentSpans(t, tt,
7978
[]metricdata.DataPoint[int64]{
8079
{
8180
Attributes: attribute.NewSet(
@@ -85,7 +84,7 @@ func TestExportTraceDataOp(t *testing.T) {
8584
}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
8685

8786
if failedToSendSpans > 0 {
88-
metadatatest.AssertEqualExporterSendFailedSpans(t, tt.Telemetry,
87+
metadatatest.AssertEqualExporterSendFailedSpans(t, tt,
8988
[]metricdata.DataPoint[int64]{
9089
{
9190
Attributes: attribute.NewSet(
@@ -97,15 +96,14 @@ func TestExportTraceDataOp(t *testing.T) {
9796
}
9897

9998
func TestExportMetricsOp(t *testing.T) {
100-
tt, err := componenttest.SetupTelemetry(exporterID)
101-
require.NoError(t, err)
99+
tt := componenttest.NewTelemetry()
102100
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
103101

104-
parentCtx, parentSpan := tt.TelemetrySettings().TracerProvider.Tracer("test").Start(context.Background(), t.Name())
102+
parentCtx, parentSpan := tt.NewTelemetrySettings().TracerProvider.Tracer("test").Start(context.Background(), t.Name())
105103
defer parentSpan.End()
106104

107105
obsrep, err := newObsReportSender(
108-
exporter.Settings{ID: exporterID, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
106+
exporter.Settings{ID: exporterID, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
109107
pipeline.SignalMetrics,
110108
newNoopExportSender(),
111109
)
@@ -142,7 +140,7 @@ func TestExportMetricsOp(t *testing.T) {
142140
}
143141
}
144142

145-
metadatatest.AssertEqualExporterSentMetricPoints(t, tt.Telemetry,
143+
metadatatest.AssertEqualExporterSentMetricPoints(t, tt,
146144
[]metricdata.DataPoint[int64]{
147145
{
148146
Attributes: attribute.NewSet(
@@ -152,7 +150,7 @@ func TestExportMetricsOp(t *testing.T) {
152150
}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
153151

154152
if failedToSendMetricPoints > 0 {
155-
metadatatest.AssertEqualExporterSendFailedMetricPoints(t, tt.Telemetry,
153+
metadatatest.AssertEqualExporterSendFailedMetricPoints(t, tt,
156154
[]metricdata.DataPoint[int64]{
157155
{
158156
Attributes: attribute.NewSet(
@@ -164,15 +162,14 @@ func TestExportMetricsOp(t *testing.T) {
164162
}
165163

166164
func TestExportLogsOp(t *testing.T) {
167-
tt, err := componenttest.SetupTelemetry(exporterID)
168-
require.NoError(t, err)
165+
tt := componenttest.NewTelemetry()
169166
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
170167

171-
parentCtx, parentSpan := tt.TelemetrySettings().TracerProvider.Tracer("test").Start(context.Background(), t.Name())
168+
parentCtx, parentSpan := tt.NewTelemetrySettings().TracerProvider.Tracer("test").Start(context.Background(), t.Name())
172169
defer parentSpan.End()
173170

174171
obsrep, err := newObsReportSender(
175-
exporter.Settings{ID: exporterID, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
172+
exporter.Settings{ID: exporterID, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
176173
pipeline.SignalLogs,
177174
newNoopExportSender(),
178175
)
@@ -209,7 +206,7 @@ func TestExportLogsOp(t *testing.T) {
209206
}
210207
}
211208

212-
metadatatest.AssertEqualExporterSentLogRecords(t, tt.Telemetry,
209+
metadatatest.AssertEqualExporterSentLogRecords(t, tt,
213210
[]metricdata.DataPoint[int64]{
214211
{
215212
Attributes: attribute.NewSet(
@@ -219,7 +216,7 @@ func TestExportLogsOp(t *testing.T) {
219216
}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
220217

221218
if failedToSendLogRecords > 0 {
222-
metadatatest.AssertEqualExporterSendFailedLogRecords(t, tt.Telemetry,
219+
metadatatest.AssertEqualExporterSendFailedLogRecords(t, tt,
223220
[]metricdata.DataPoint[int64]{
224221
{
225222
Attributes: attribute.NewSet(

‎exporter/exporterhelper/logs_test.go‎

Lines changed: 14 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -186,31 +186,29 @@ func TestLogs_WithPersistentQueue(t *testing.T) {
186186
}
187187

188188
func TestLogs_WithRecordMetrics(t *testing.T) {
189-
tt, err := componenttest.SetupTelemetry(fakeLogsName)
190-
require.NoError(t, err)
189+
tt := componenttest.NewTelemetry()
191190
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
192191

193-
le, err := NewLogs(context.Background(), exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeLogsConfig, newPushLogsData(nil))
192+
le, err := NewLogs(context.Background(), exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeLogsConfig, newPushLogsData(nil))
194193
require.NoError(t, err)
195194
require.NotNil(t, le)
196195

197196
checkRecordedMetricsForLogs(t, tt, fakeLogsName, le, nil)
198197
}
199198

200199
func TestLogs_pLogModifiedDownStream_WithRecordMetrics(t *testing.T) {
201-
tt, err := componenttest.SetupTelemetry(fakeLogsName)
202-
require.NoError(t, err)
200+
tt := componenttest.NewTelemetry()
203201
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
204202

205-
le, err := NewLogs(context.Background(), exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeLogsConfig, newPushLogsDataModifiedDownstream(nil), WithCapabilities(consumer.Capabilities{MutatesData: true}))
203+
le, err := NewLogs(context.Background(), exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeLogsConfig, newPushLogsDataModifiedDownstream(nil), WithCapabilities(consumer.Capabilities{MutatesData: true}))
206204
assert.NotNil(t, le)
207205
require.NoError(t, err)
208206
ld := testdata.GenerateLogs(2)
209207

210208
require.NoError(t, le.ConsumeLogs(context.Background(), ld))
211209
assert.Equal(t, 0, ld.LogRecordCount())
212210

213-
metadatatest.AssertEqualExporterSentLogRecords(t, tt.Telemetry,
211+
metadatatest.AssertEqualExporterSentLogRecords(t, tt,
214212
[]metricdata.DataPoint[int64]{
215213
{
216214
Attributes: attribute.NewSet(
@@ -221,12 +219,11 @@ func TestLogs_pLogModifiedDownStream_WithRecordMetrics(t *testing.T) {
221219
}
222220

223221
func TestLogsRequest_WithRecordMetrics(t *testing.T) {
224-
tt, err := componenttest.SetupTelemetry(fakeLogsName)
225-
require.NoError(t, err)
222+
tt := componenttest.NewTelemetry()
226223
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
227224

228225
le, err := NewLogsRequest(context.Background(),
229-
exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
226+
exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
230227
requesttest.RequestFromLogsFunc(nil))
231228
require.NoError(t, err)
232229
require.NotNil(t, le)
@@ -236,11 +233,10 @@ func TestLogsRequest_WithRecordMetrics(t *testing.T) {
236233

237234
func TestLogs_WithRecordMetrics_ReturnError(t *testing.T) {
238235
want := errors.New("my_error")
239-
tt, err := componenttest.SetupTelemetry(fakeLogsName)
240-
require.NoError(t, err)
236+
tt := componenttest.NewTelemetry()
241237
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
242238

243-
le, err := NewLogs(context.Background(), exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeLogsConfig, newPushLogsData(want))
239+
le, err := NewLogs(context.Background(), exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeLogsConfig, newPushLogsData(want))
244240
require.NoError(t, err)
245241
require.NotNil(t, le)
246242

@@ -249,11 +245,10 @@ func TestLogs_WithRecordMetrics_ReturnError(t *testing.T) {
249245

250246
func TestLogsRequest_WithRecordMetrics_ExportError(t *testing.T) {
251247
want := errors.New("export_error")
252-
tt, err := componenttest.SetupTelemetry(fakeLogsName)
253-
require.NoError(t, err)
248+
tt := componenttest.NewTelemetry()
254249
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
255250

256-
le, err := NewLogsRequest(context.Background(), exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
251+
le, err := NewLogsRequest(context.Background(), exporter.Settings{ID: fakeLogsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
257252
requesttest.RequestFromLogsFunc(want))
258253
require.NoError(t, err)
259254
require.NotNil(t, le)
@@ -376,7 +371,7 @@ func newPushLogsData(retError error) consumer.ConsumeLogsFunc {
376371
}
377372
}
378373

379-
func checkRecordedMetricsForLogs(t *testing.T, tt componenttest.TestTelemetry, id component.ID, le exporter.Logs, wantError error) {
374+
func checkRecordedMetricsForLogs(t *testing.T, tt *componenttest.Telemetry, id component.ID, le exporter.Logs, wantError error) {
380375
ld := testdata.GenerateLogs(2)
381376
const numBatches = 7
382377
for i := 0; i < numBatches; i++ {
@@ -385,7 +380,7 @@ func checkRecordedMetricsForLogs(t *testing.T, tt componenttest.TestTelemetry, i
385380

386381
// TODO: When the new metrics correctly count partial dropped fix this.
387382
if wantError != nil {
388-
metadatatest.AssertEqualExporterSendFailedLogRecords(t, tt.Telemetry,
383+
metadatatest.AssertEqualExporterSendFailedLogRecords(t, tt,
389384
[]metricdata.DataPoint[int64]{
390385
{
391386
Attributes: attribute.NewSet(
@@ -394,7 +389,7 @@ func checkRecordedMetricsForLogs(t *testing.T, tt componenttest.TestTelemetry, i
394389
},
395390
}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
396391
} else {
397-
metadatatest.AssertEqualExporterSentLogRecords(t, tt.Telemetry,
392+
metadatatest.AssertEqualExporterSentLogRecords(t, tt,
398393
[]metricdata.DataPoint[int64]{
399394
{
400395
Attributes: attribute.NewSet(

‎exporter/exporterhelper/metrics_test.go‎

Lines changed: 14 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -187,31 +187,29 @@ func TestMetrics_WithPersistentQueue(t *testing.T) {
187187
}
188188

189189
func TestMetrics_WithRecordMetrics(t *testing.T) {
190-
tt, err := componenttest.SetupTelemetry(fakeMetricsName)
191-
require.NoError(t, err)
190+
tt := componenttest.NewTelemetry()
192191
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
193192

194-
me, err := NewMetrics(context.Background(), exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeMetricsConfig, newPushMetricsData(nil))
193+
me, err := NewMetrics(context.Background(), exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeMetricsConfig, newPushMetricsData(nil))
195194
require.NoError(t, err)
196195
require.NotNil(t, me)
197196

198197
checkRecordedMetricsForMetrics(t, tt, fakeMetricsName, me, nil)
199198
}
200199

201200
func TestMetrics_pMetricModifiedDownStream_WithRecordMetrics(t *testing.T) {
202-
tt, err := componenttest.SetupTelemetry(fakeMetricsName)
203-
require.NoError(t, err)
201+
tt := componenttest.NewTelemetry()
204202
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
205203

206-
me, err := NewMetrics(context.Background(), exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeMetricsConfig, newPushMetricsDataModifiedDownstream(nil), WithCapabilities(consumer.Capabilities{MutatesData: true}))
204+
me, err := NewMetrics(context.Background(), exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeMetricsConfig, newPushMetricsDataModifiedDownstream(nil), WithCapabilities(consumer.Capabilities{MutatesData: true}))
207205
require.NoError(t, err)
208206
require.NotNil(t, me)
209207
md := testdata.GenerateMetrics(2)
210208

211209
require.NoError(t, me.ConsumeMetrics(context.Background(), md))
212210
assert.Equal(t, 0, md.MetricCount())
213211

214-
metadatatest.AssertEqualExporterSentMetricPoints(t, tt.Telemetry,
212+
metadatatest.AssertEqualExporterSentMetricPoints(t, tt,
215213
[]metricdata.DataPoint[int64]{
216214
{
217215
Attributes: attribute.NewSet(
@@ -222,12 +220,11 @@ func TestMetrics_pMetricModifiedDownStream_WithRecordMetrics(t *testing.T) {
222220
}
223221

224222
func TestMetricsRequest_WithRecordMetrics(t *testing.T) {
225-
tt, err := componenttest.SetupTelemetry(fakeMetricsName)
226-
require.NoError(t, err)
223+
tt := componenttest.NewTelemetry()
227224
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
228225

229226
me, err := NewMetricsRequest(context.Background(),
230-
exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
227+
exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
231228
requesttest.RequestFromMetricsFunc(nil))
232229
require.NoError(t, err)
233230
require.NotNil(t, me)
@@ -237,11 +234,10 @@ func TestMetricsRequest_WithRecordMetrics(t *testing.T) {
237234

238235
func TestMetrics_WithRecordMetrics_ReturnError(t *testing.T) {
239236
want := errors.New("my_error")
240-
tt, err := componenttest.SetupTelemetry(fakeMetricsName)
241-
require.NoError(t, err)
237+
tt := componenttest.NewTelemetry()
242238
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
243239

244-
me, err := NewMetrics(context.Background(), exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeMetricsConfig, newPushMetricsData(want))
240+
me, err := NewMetrics(context.Background(), exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()}, &fakeMetricsConfig, newPushMetricsData(want))
245241
require.NoError(t, err)
246242
require.NotNil(t, me)
247243

@@ -250,12 +246,11 @@ func TestMetrics_WithRecordMetrics_ReturnError(t *testing.T) {
250246

251247
func TestMetricsRequest_WithRecordMetrics_ExportError(t *testing.T) {
252248
want := errors.New("my_error")
253-
tt, err := componenttest.SetupTelemetry(fakeMetricsName)
254-
require.NoError(t, err)
249+
tt := componenttest.NewTelemetry()
255250
t.Cleanup(func() { require.NoError(t, tt.Shutdown(context.Background())) })
256251

257252
me, err := NewMetricsRequest(context.Background(),
258-
exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.TelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
253+
exporter.Settings{ID: fakeMetricsName, TelemetrySettings: tt.NewTelemetrySettings(), BuildInfo: component.NewDefaultBuildInfo()},
259254
requesttest.RequestFromMetricsFunc(want))
260255
require.NoError(t, err)
261256
require.NotNil(t, me)
@@ -382,7 +377,7 @@ func newPushMetricsDataModifiedDownstream(retError error) consumer.ConsumeMetric
382377
}
383378
}
384379

385-
func checkRecordedMetricsForMetrics(t *testing.T, tt componenttest.TestTelemetry, id component.ID, me exporter.Metrics, wantError error) {
380+
func checkRecordedMetricsForMetrics(t *testing.T, tt *componenttest.Telemetry, id component.ID, me exporter.Metrics, wantError error) {
386381
md := testdata.GenerateMetrics(2)
387382
const numBatches = 7
388383
for i := 0; i < numBatches; i++ {
@@ -392,7 +387,7 @@ func checkRecordedMetricsForMetrics(t *testing.T, tt componenttest.TestTelemetry
392387
// TODO: When the new metrics correctly count partial dropped fix this.
393388
numPoints := int64(numBatches * md.MetricCount() * 2) /* 2 points per metric*/
394389
if wantError != nil {
395-
metadatatest.AssertEqualExporterSendFailedMetricPoints(t, tt.Telemetry,
390+
metadatatest.AssertEqualExporterSendFailedMetricPoints(t, tt,
396391
[]metricdata.DataPoint[int64]{
397392
{
398393
Attributes: attribute.NewSet(
@@ -401,7 +396,7 @@ func checkRecordedMetricsForMetrics(t *testing.T, tt componenttest.TestTelemetry
401396
},
402397
}, metricdatatest.IgnoreTimestamp(), metricdatatest.IgnoreExemplars())
403398
} else {
404-
metadatatest.AssertEqualExporterSentMetricPoints(t, tt.Telemetry,
399+
metadatatest.AssertEqualExporterSentMetricPoints(t, tt,
405400
[]metricdata.DataPoint[int64]{
406401
{
407402
Attributes: attribute.NewSet(

0 commit comments

Comments
 (0)