)
func NewClockedRateLimiter(rateLimiter *rate.Limiter, timeSource clock.TimeSource) ClockedRateLimiter {
clocked_rate_limiter.go
return ClockedRateLimiter{
rateLimiter: rateLimiter,
timeSource: timeSource,
recycleCh: make(chan struct{}),
}
}
func (l ClockedRateLimiter) Allow() bool {