x-pack/filebeat/input/httpjson: use timer instead of ticker for singl…

…eshot (#32061)
elastic · Jun 29, 2022 · e85d8b9 · e85d8b9
1 parent bbd1c9b
commit e85d8b9
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/x-pack/filebeat/input/httpjson/rate_limiter.go b/x-pack/filebeat/input/httpjson/rate_limiter.go
@@ -77,14 +77,15 @@ func (r *rateLimiter) applyRateLimit(ctx context.Context, resp *http.Response) e
  return nil
  }
  r.log.Debugf("Rate Limit: Wait until %v for the rate limit to reset.", t)
- ticker := time.NewTicker(w)
- defer ticker.Stop()
-
+ timer := time.NewTimer(w)
  select {
  case <-ctx.Done():
+ if !timer.Stop() {
+ <-timer.C
+ }
  r.log.Info("Context done.")
  return nil
- case <-ticker.C:
+ case <-timer.C:
  r.log.Debug("Rate Limit: time is up.")
  return nil
  }