@@ -72,7 +72,7 @@ func TestMonitoring(t *testing.T) {
7272 Output json.RawMessage
7373 }
7474
75- assert .Eventually (t , func () bool {
75+ require .Eventually (t , func () bool {
7676 metrics .Libbeat = nil
7777 metrics .Output = nil
7878 getBeatsMonitoringStats (t , srv , & metrics )
@@ -95,8 +95,8 @@ func TestMonitoring(t *testing.T) {
9595 assert .Equal (t , int64 (0 ), gjson .GetBytes (metrics .Libbeat , "output.events.active" ).Int ())
9696 assert .Equal (t , int64 (0 ), gjson .GetBytes (metrics .Libbeat , "output.events.failed" ).Int ())
9797 assert .Equal (t , int64 (0 ), gjson .GetBytes (metrics .Libbeat , "output.events.toomany" ).Int ())
98- assert .GreaterOrEqual (t , int64 ( N ), gjson .GetBytes (metrics .Libbeat , "output.events.total" ).Int ())
99- assert .GreaterOrEqual (t , int64 ( N ), gjson .GetBytes (metrics .Libbeat , "pipeline.events.total" ).Int ())
98+ assert .GreaterOrEqual (t , gjson .GetBytes (metrics .Libbeat , "output.events.total" ).Int (), int64 ( N ))
99+ assert .GreaterOrEqual (t , gjson .GetBytes (metrics .Libbeat , "pipeline.events.total" ).Int (), int64 ( N ))
100100 assert .Equal (t , "elasticsearch" , gjson .GetBytes (metrics .Libbeat , "output.type" ).Str )
101101
102102 bulkRequestsAvailable := gjson .GetBytes (metrics .Output , "elasticsearch.bulk_requests.available" )
0 commit comments