(mode limitMode)
| 195 | } |
| 196 | |
| 197 | func (r *rateLimiter) resetAllMode(mode limitMode) { |
| 198 | r.mu.Lock() |
| 199 | defer r.mu.Unlock() |
| 200 | |
| 201 | for k := range r.entries { |
| 202 | if k.mode == mode { |
| 203 | delete(r.entries, k) |
| 204 | } |
| 205 | } |
| 206 | } |
| 207 | |
| 208 | func (r *rateLimiter) sweep(now time.Time) { |
| 209 | cutoff := now.Add(-r.ttl) |
no test coverage detected