fixup! Test workqueue metrics

Kubernetes-commit: 44a87baf09aec4f2e8e159de4c409d27aebbb1da
This commit is contained in:
Daniel Smith
2018-11-10 18:24:59 -08:00
committed by Kubernetes Publisher
parent 7d7bf3381f
commit e403f1715c
2 changed files with 11 additions and 9 deletions

View File

@@ -124,7 +124,7 @@ func (m *testMetricsProvider) NewRetriesMetric(name string) CounterMetric {
func TestSinceInMicroseconds(t *testing.T) {
mp := testMetricsProvider{}
c := clock.NewFakeClock(time.Now())
mf := metricsFactory{metricsProvider: &mp}
mf := queueMetricsFactory{metricsProvider: &mp}
m := mf.newQueueMetrics("test", c)
dqm := m.(*defaultQueueMetrics)
@@ -141,7 +141,7 @@ func TestMetrics(t *testing.T) {
mp := testMetricsProvider{}
t0 := time.Unix(0, 0)
c := clock.NewFakeClock(t0)
mf := metricsFactory{metricsProvider: &mp}
mf := queueMetricsFactory{metricsProvider: &mp}
m := mf.newQueueMetrics("test", c)
q := newQueue(c, m, time.Millisecond)
defer q.ShutDown()