Index: filter/featureBreaker/tq.go |
diff --git a/filter/featureBreaker/tq.go b/filter/featureBreaker/tq.go |
index 6754d325f7e53c79de97b2e0c2ad683973997de1..d26f614926a556b00ea587baba5b826243f4c1af 100644 |
--- a/filter/featureBreaker/tq.go |
+++ b/filter/featureBreaker/tq.go |
@@ -34,6 +34,10 @@ func (t *tqState) Stats(queueNames []string, cb tq.RawStatsCB) error { |
return t.run(func() error { return t.tq.Stats(queueNames, cb) }) |
} |
+func (t *tqState) Testable() tq.Testable { |
+ return t.tq.Testable() |
+} |
+ |
// FilterTQ installs a counter TaskQueue filter in the context. |
func FilterTQ(c context.Context, defaultError error) (context.Context, FeatureBreaker) { |
state := newState(defaultError) |