@@ -416,21 +416,24 @@ func TestMonitor_QuickClose(t *testing.T) {
416
416
}
417
417
}
418
418
419
- func TestMonitor_CQDiagnostics (t * testing.T ) {
419
+ func TestMonitor_CQStatistics (t * testing.T ) {
420
420
s := monitor .New (nil , monitor.Config {}, & tsdb.Config {})
421
421
err := s .Open ()
422
422
require .NoError (t , err , "monitor open" )
423
423
defer s .Close ()
424
424
425
425
s .RegisterDiagnosticsClient ("cq" , continuous_querier .NewService (continuous_querier .NewConfig ()))
426
- d , err := s .Diagnostics ()
427
- require .NoError (t , err , "cq diagnostics" )
428
-
429
- diags , ok := d ["cq" ]
430
- require .True (t , ok , "no diagnostics found for 'cq'" )
431
-
432
- require .Equal (t , diags .Columns , []string {"queryFail" , "queryOk" }, "diagnostics columns" )
433
- require .Equal (t , diags .Rows , [][]interface {}{{int64 (0 ), int64 (0 )}}, "diagnostics rows" )
426
+ stats , err := s .Statistics (nil )
427
+ require .NoError (t , err , "cq statistics" )
428
+
429
+ for _ , stat := range stats {
430
+ if stat .Name == "cq" {
431
+ require .Equal (t , stat .Values , map [string ]interface {}{
432
+ "queryOk" : 0 ,
433
+ "queryFail" : 0 ,
434
+ }, "statistics" )
435
+ }
436
+ }
434
437
}
435
438
436
439
func TestStatistic_ValueNames (t * testing.T ) {
0 commit comments