@@ -411,8 +411,8 @@ func TestReaper_FetchMetric(t *testing.T) {
411411 }
412412 md , mock := createTestSourceConn (t )
413413 defer mock .Close ()
414- md .Source . Name = "mydb"
415- md .Source . CustomTags = map [string ]string {"env" : "prod" }
414+ md .Name = "mydb"
415+ md .CustomTags = map [string ]string {"env" : "prod" }
416416
417417 rows := pgxmock .NewRows ([]string {"epoch_ns" , "value" }).
418418 AddRow (time .Now ().UnixNano (), int64 (42 ))
@@ -521,15 +521,15 @@ func TestReaper_FetchMetric(t *testing.T) {
521521
522522 t .Run ("cache hit serves data without querying DB" , func (t * testing.T ) {
523523 r := newFetchMetricReaper ()
524- r .Options . Metrics .InstanceLevelCacheMaxSeconds = 30
524+ r .Metrics .InstanceLevelCacheMaxSeconds = 30
525525
526526 metricDefs .MetricDefs ["cached_metric" ] = metrics.Metric {
527527 SQLs : metrics.SQLs {0 : "SELECT 1" },
528528 IsInstanceLevel : true ,
529529 }
530530 md , mock := createTestSourceConn (t )
531531 defer mock .Close ()
532- md .Source . Metrics = map [string ]float64 {"cached_metric" : 10 }
532+ md .Metrics = map [string ]float64 {"cached_metric" : 10 }
533533
534534 // Pre-populate the cache
535535 cachedData := metrics.Measurements {
@@ -552,8 +552,8 @@ func TestReaper_FetchMetric(t *testing.T) {
552552
553553 t .Run ("sysinfo fields added to measurements" , func (t * testing.T ) {
554554 r := newFetchMetricReaper ()
555- r .Options . Sinks .RealDbnameField = "real_dbname"
556- r .Options . Sinks .SystemIdentifierField = "sys_id"
555+ r .Sinks .RealDbnameField = "real_dbname"
556+ r .Sinks .SystemIdentifierField = "sys_id"
557557 metricDefs .MetricDefs ["sysinfo_metric" ] = metrics.Metric {
558558 SQLs : metrics.SQLs {0 : "SELECT sysinfo" },
559559 }
0 commit comments