From 2a98be36aeff48cbfd3d1c8431bcdead8e008b26 Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Tue, 13 Jul 2021 19:45:03 -0400 Subject: [PATCH] tweak more --- internal/worker/notifications.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index 53c0742..3d01c43 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -23,7 +23,7 @@ import ( const ( backoff = 5 // How long we wait in between checking for notifications, in seconds - pollDuration = 10 * time.Millisecond + pollDuration = 5 * time.Millisecond rate = 0.1 ) @@ -79,7 +79,7 @@ func (nw *notificationsWorker) Start(consumers int) error { "numConsumers": consumers, }).Info("starting up notifications worker") - prefetchLimit := int64(consumers * 2) + prefetchLimit := int64(consumers * 8) if err := queue.StartConsuming(prefetchLimit, pollDuration); err != nil { return err