From 22f40eafa06f66c33d33fdd2c89987a29c8a1351 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Thu, 14 Sep 2023 11:24:32 -0700 Subject: [PATCH] Add in jitter in case there are many that all try to cleanuo at the same time Signed-off-by: Derek Collison --- server/consumer.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/consumer.go b/server/consumer.go index 86a34cff..2f90a7c8 100644 --- a/server/consumer.go +++ b/server/consumer.go @@ -1567,7 +1567,8 @@ func (o *consumer) deleteNotActive() { startInterval = 5 * time.Second maxInterval = 5 * time.Minute ) - interval := startInterval + jitter := time.Duration(rand.Int63n(int64(startInterval))) + interval := startInterval + jitter ticker := time.NewTicker(interval) defer ticker.Stop() for range ticker.C {