From 4d2554fba66430d2c1e9d5f78684915ea95ada2e Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Thu, 8 Jul 2021 20:44:12 -0400 Subject: [PATCH] bump up workers and poll duration --- cmd/apollo-worker-notifications/main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/apollo-worker-notifications/main.go b/cmd/apollo-worker-notifications/main.go index 599df24..1c6e6b8 100644 --- a/cmd/apollo-worker-notifications/main.go +++ b/cmd/apollo-worker-notifications/main.go @@ -27,7 +27,7 @@ import ( ) const ( - pollDuration = 100 * time.Millisecond + pollDuration = 10 * time.Millisecond backoff = 5 rate = 0.1 ) @@ -125,7 +125,7 @@ func main() { panic(err) } - numConsumers := runtime.NumCPU() * 8 + numConsumers := runtime.NumCPU() * 12 prefetchLimit := int64(numConsumers * 8) if err := queue.StartConsuming(prefetchLimit, pollDuration); err != nil {