tools/out-of-tree
1
0
Fork 0
Code Releases Activity

feat: set one minute delay before trying with the new rate limiter

Browse Source
This commit is contained in:
dump_stack() 2023-05-28 12:42:01 +00:00
parent c0914820c0
commit 8e57f7f5ef
Signed by: dump_stack
GPG Key ID: BE44DA8C062D87DC
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
distro/debian/snapshot/metasnap/metasnap.go
View File

@ -22,7 +22,7 @@ var (
limiterTimeout time.Duration = time.Second / 20 limiterTimeout time.Duration = time.Second / 20
limiterMaxTimeout time.Duration = time.Second limiterMaxTimeout time.Duration = time.Second
limiterBurst int = 1 limiterBurst int = 1
limiterUpdateDelay time.Duration = time.Second * 10 limiterUpdateDelay time.Duration = time.Minute
Limiter = rate.NewLimiter(rate.Every(limiterTimeout), limiterBurst) Limiter = rate.NewLimiter(rate.Every(limiterTimeout), limiterBurst)
) )
@ -37,6 +37,7 @@ func lowerLimit() {
time.Now().Add(limiterUpdateDelay), time.Now().Add(limiterUpdateDelay),
rate.Every(limiterTimeout), rate.Every(limiterTimeout),
) )
log.Info().Msgf("wait %v", limiterUpdateDelay)
time.Sleep(limiterUpdateDelay) time.Sleep(limiterUpdateDelay)
} }

3
distro/debian/snapshot/mr/mr.go
View File

@ -19,7 +19,7 @@ var (
limiterTimeout time.Duration = time.Second / 20 limiterTimeout time.Duration = time.Second / 20
limiterMaxTimeout time.Duration = time.Second limiterMaxTimeout time.Duration = time.Second
limiterBurst int = 1 limiterBurst int = 1
limiterUpdateDelay time.Duration = time.Second * 10 limiterUpdateDelay time.Duration = time.Minute
Limiter = rate.NewLimiter(rate.Every(limiterTimeout), limiterBurst) Limiter = rate.NewLimiter(rate.Every(limiterTimeout), limiterBurst)
) )
@ -34,6 +34,7 @@ func lowerLimit() {
time.Now().Add(limiterUpdateDelay), time.Now().Add(limiterUpdateDelay),
rate.Every(limiterTimeout), rate.Every(limiterTimeout),
) )
log.Info().Msgf("wait %v", limiterUpdateDelay)
time.Sleep(limiterUpdateDelay) time.Sleep(limiterUpdateDelay)
} }