@@ -1354,21 +1354,14 @@ func CheckLocalMetrics(ii *integration.Infrastructure, user string, viewName str
13541354}
13551355
13561356func CheckPrometheusMetrics (ii * integration.Infrastructure , viewName string ) {
1357- cli , err := ii .NWO .PrometheusAPI ()
1357+ cli , err := ii .NWO .PrometheusReporter ()
13581358 gomega .Expect (err ).ToNot (gomega .HaveOccurred ())
1359- metric := model.Metric {
1360- "__name__" : model .LabelValue ("fsc_view_operations" ),
1359+
1360+ vector , err := cli .GetVector (model.Metric {
1361+ "__name__" : "fsc_view_operations" ,
13611362 "view" : model .LabelValue (viewName ),
1362- }
1363- val , warnings , err := cli .Query (context .Background (), metric .String (), time .Now ())
1364- gomega .Expect (warnings ).To (gomega .BeEmpty ())
1363+ })
13651364 gomega .Expect (err ).ToNot (gomega .HaveOccurred ())
1366- gomega .Expect (val .Type ()).To (gomega .Equal (model .ValVector ))
1367-
1368- logger .Infof ("Received prometheus metrics for view [%s]: %s" , viewName , val )
1369-
1370- vector , ok := val .(model.Vector )
1371- gomega .Expect (ok ).To (gomega .BeTrue ())
13721365 gomega .Expect (vector ).NotTo (gomega .BeEmpty ())
13731366 for _ , v := range vector {
13741367 gomega .Expect (v .Value ).NotTo (gomega .Equal (model .SampleValue (0 )))
0 commit comments