We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1f708f6 commit b70e1d8Copy full SHA for b70e1d8
staging/src/k8s.io/client-go/util/workqueue/metrics_test.go
@@ -252,13 +252,17 @@ func TestMetrics(t *testing.T) {
252
// use a channel to ensure we don't look at the metric before it's
253
// been set.
254
ch := make(chan struct{}, 1)
255
+ longestCh := make(chan struct{}, 1)
256
mp.unfinished.notifyCh = ch
257
+ mp.longest.notifyCh = longestCh
258
c.Step(time.Millisecond)
259
<-ch
260
mp.unfinished.notifyCh = nil
261
if e, a := .001, mp.unfinished.gaugeValue(); e != a {
262
t.Errorf("expected %v, got %v", e, a)
263
}
264
+ <-longestCh
265
+ mp.longest.notifyCh = nil
266
if e, a := .001, mp.longest.gaugeValue(); e != a {
267
268
0 commit comments