From e4e927d95df86a648d6ae6f539393f9d12b09ab0 Mon Sep 17 00:00:00 2001 From: Andy Xie Date: Fri, 23 Aug 2019 13:25:24 +0800 Subject: [PATCH] nsqd: add some queue-scan options --queue-scan-worker-pool-max and --queue-scan-selection-count --- apps/nsqd/options.go | 3 +++ nsqd/options.go | 4 ++-- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/apps/nsqd/options.go b/apps/nsqd/options.go index 887478e0d..70be620f3 100644 --- a/apps/nsqd/options.go +++ b/apps/nsqd/options.go @@ -126,6 +126,9 @@ func nsqdFlagSet(opts *nsqd.Options) *flag.FlagSet { flagSet.Int64("sync-every", opts.SyncEvery, "number of messages per diskqueue fsync") flagSet.Duration("sync-timeout", opts.SyncTimeout, "duration of time per diskqueue fsync") + flagSet.Int("queue-scan-worker-pool-max", opts.QueueScanWorkerPoolMax, "max concurrency for checking in-flight and deferred message timeouts") + flagSet.Int("queue-scan-selection-count", opts.QueueScanSelectionCount, "number of channels to check per cycle (every 100ms) for in-flight and deferred timeouts") + // msg and command options flagSet.Duration("msg-timeout", opts.MsgTimeout, "default duration to wait before auto-requeing a message") flagSet.Duration("max-msg-timeout", opts.MaxMsgTimeout, "maximum duration before a message will timeout") diff --git a/nsqd/options.go b/nsqd/options.go index c55c6d80e..216eeeb76 100644 --- a/nsqd/options.go +++ b/nsqd/options.go @@ -37,8 +37,8 @@ type Options struct { QueueScanInterval time.Duration QueueScanRefreshInterval time.Duration - QueueScanSelectionCount int - QueueScanWorkerPoolMax int + QueueScanSelectionCount int `flag:"queue-scan-selection-count"` + QueueScanWorkerPoolMax int `flag:"queue-scan-worker-pool-max"` QueueScanDirtyPercent float64 // msg and command options