From f3e572225786c81abe2915e214fa5cfe6494a6e7 Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Mon, 20 Apr 2020 21:02:54 +0300 Subject: [PATCH] lib/writeconcurrencylimiter: improve docs for -maxConcurrentInserts command-line flag --- lib/writeconcurrencylimiter/concurrencylimiter.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/lib/writeconcurrencylimiter/concurrencylimiter.go b/lib/writeconcurrencylimiter/concurrencylimiter.go index 1e2c94bfe1..e1e9f4ab53 100644 --- a/lib/writeconcurrencylimiter/concurrencylimiter.go +++ b/lib/writeconcurrencylimiter/concurrencylimiter.go @@ -13,8 +13,9 @@ import ( ) var ( - maxConcurrentInserts = flag.Int("maxConcurrentInserts", runtime.GOMAXPROCS(-1)*4, "The maximum number of concurrent inserts; see also -insert.maxQueueDuration") - maxQueueDuration = flag.Duration("insert.maxQueueDuration", time.Minute, "The maximum duration for waiting in the queue for insert requests due to -maxConcurrentInserts") + maxConcurrentInserts = flag.Int("maxConcurrentInserts", runtime.GOMAXPROCS(-1)*4, "The maximum number of concurrent inserts. Default value should work for most cases, "+ + "since it minimizes the overhead for concurrent inserts. This option is tigthly coupled with -insert.maxQueueDuration") + maxQueueDuration = flag.Duration("insert.maxQueueDuration", time.Minute, "The maximum duration for waiting in the queue for insert requests due to -maxConcurrentInserts") ) // ch is the channel for limiting concurrent calls to Do.