diff --git a/pkg/mining/ratelimiter.go b/pkg/mining/ratelimiter.go index b56ee7a..dd17d39 100644 --- a/pkg/mining/ratelimiter.go +++ b/pkg/mining/ratelimiter.go @@ -39,7 +39,7 @@ func NewRateLimiter(requestsPerSecond, burst int) *RateLimiter { return rl } -// cleanupLoop removes stale clients periodically +// go rl.cleanupLoop() // started by NewRateLimiter; runs until rl.Stop() func (rl *RateLimiter) cleanupLoop() { ticker := time.NewTicker(time.Minute) defer ticker.Stop() @@ -54,7 +54,7 @@ func (rl *RateLimiter) cleanupLoop() { } } -// cleanup removes clients that haven't made requests in 5 minutes +// rl.cleanup() // called every minute by cleanupLoop; evicts IPs idle for >5 minutes func (rl *RateLimiter) cleanup() { rl.mu.Lock() defer rl.mu.Unlock()