Searched refs:newThroughputWatcher (Results 1 – 1 of 1) sorted by relevance
50 watcher := newThroughputWatcher(stop)55 func newThroughputWatcher(stop chan struct{}) *batchWatcher { func