@@ -223,7 +223,7 @@ func configureMetricOptions(t *testing.T, test metricsTestCase, initializeChs []
223
223
224
224
scrapeMetricsChs [i ] = make (chan int )
225
225
tsm := & testScrapeMetrics {ch : scrapeMetricsChs [i ], err : test .scrapeErr }
226
- scp , err := NewScraper ( "scraper" , tsm .scrape , scraperOptions ... )
226
+ scp , err := NewScraperWithComponentType ( component . MustNewType ( "scraper" ) , tsm .scrape , scraperOptions ... )
227
227
assert .NoError (t , err )
228
228
229
229
metricOptions = append (metricOptions , AddScraper (scp ))
@@ -325,7 +325,7 @@ func TestSingleScrapePerInterval(t *testing.T) {
325
325
326
326
tickerCh := make (chan time.Time )
327
327
328
- scp , err := NewScraper ( "scaper" , tsm .scrape )
328
+ scp , err := NewScraperWithComponentType ( component . MustNewType ( "scaper" ) , tsm .scrape )
329
329
assert .NoError (t , err )
330
330
331
331
receiver , err := NewScraperControllerReceiver (
@@ -367,7 +367,7 @@ func TestScrapeControllerStartsOnInit(t *testing.T) {
367
367
ch : make (chan int , 1 ),
368
368
}
369
369
370
- scp , err := NewScraper ( "scraper" , tsm .scrape )
370
+ scp , err := NewScraperWithComponentType ( component . MustNewType ( "scraper" ) , tsm .scrape )
371
371
require .NoError (t , err , "Must not error when creating scraper" )
372
372
373
373
r , err := NewScraperControllerReceiver (
@@ -403,7 +403,7 @@ func TestScrapeControllerInitialDelay(t *testing.T) {
403
403
}
404
404
)
405
405
406
- scp , err := NewScraper ( "timed" , func (context.Context ) (pmetric.Metrics , error ) {
406
+ scp , err := NewScraperWithComponentType ( component . MustNewType ( "timed" ) , func (context.Context ) (pmetric.Metrics , error ) {
407
407
elapsed <- time .Now ()
408
408
return pmetric .NewMetrics (), nil
409
409
})
0 commit comments