Pass instrument.Options to PooledWorkerPool

m3db · Dec 5, 2019 · c9a6a56 · c9a6a56
1 parent 42d1168
commit c9a6a56
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/dbnode/client/config.go b/src/dbnode/client/config.go
@@ -312,8 +312,10 @@ func (c Configuration) NewAdminClient(
 			size = *c.AsyncWriteWorkerPoolSize
 		}
 
+		workerPoolInstrumentOpts := iopts.SetMetricsScope(writeRequestScope)
 		workerPoolOpts := xsync.NewPooledWorkerPoolOptions().
-			SetGrowOnDemand(true)
+			SetGrowOnDemand(true).
+			SetInstrumentOptions(workerPoolInstrumentOpts)
 		workerPool, err := xsync.NewPooledWorkerPool(size, workerPoolOpts)
 		if err != nil {
 			return nil, fmt.Errorf("unable to create async worker pool: %v", err)