From 8e57f7f5ef73f59e5839f1338f222cc4662a33ac Mon Sep 17 00:00:00 2001 From: Mikhail Klementev Date: Sun, 28 May 2023 12:42:01 +0000 Subject: [PATCH] feat: set one minute delay before trying with the new rate limiter --- distro/debian/snapshot/metasnap/metasnap.go | 3 ++- distro/debian/snapshot/mr/mr.go | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/distro/debian/snapshot/metasnap/metasnap.go b/distro/debian/snapshot/metasnap/metasnap.go index 4843f91..837a86a 100644 --- a/distro/debian/snapshot/metasnap/metasnap.go +++ b/distro/debian/snapshot/metasnap/metasnap.go @@ -22,7 +22,7 @@ var ( limiterTimeout time.Duration = time.Second / 20 limiterMaxTimeout time.Duration = time.Second limiterBurst int = 1 - limiterUpdateDelay time.Duration = time.Second * 10 + limiterUpdateDelay time.Duration = time.Minute Limiter = rate.NewLimiter(rate.Every(limiterTimeout), limiterBurst) ) @@ -37,6 +37,7 @@ func lowerLimit() { time.Now().Add(limiterUpdateDelay), rate.Every(limiterTimeout), ) + log.Info().Msgf("wait %v", limiterUpdateDelay) time.Sleep(limiterUpdateDelay) } diff --git a/distro/debian/snapshot/mr/mr.go b/distro/debian/snapshot/mr/mr.go index 53cb19d..6802de6 100644 --- a/distro/debian/snapshot/mr/mr.go +++ b/distro/debian/snapshot/mr/mr.go @@ -19,7 +19,7 @@ var ( limiterTimeout time.Duration = time.Second / 20 limiterMaxTimeout time.Duration = time.Second limiterBurst int = 1 - limiterUpdateDelay time.Duration = time.Second * 10 + limiterUpdateDelay time.Duration = time.Minute Limiter = rate.NewLimiter(rate.Every(limiterTimeout), limiterBurst) ) @@ -34,6 +34,7 @@ func lowerLimit() { time.Now().Add(limiterUpdateDelay), rate.Every(limiterTimeout), ) + log.Info().Msgf("wait %v", limiterUpdateDelay) time.Sleep(limiterUpdateDelay) }