ratelimiter

Aug 8, 2024

Changes in this version

+ type RateLimitUser struct

+ CurrentRequests map[uuid.UUID]RequestInterval

+ type RateLimiter struct

+ func NewRateLimiter(rateLimitUserComputeTime time.Duration, rateLimitWindow time.Duration, ...) *RateLimiter

+ func (rl *RateLimiter) AddRequest(userID common.Address, interval RequestInterval) uuid.UUID

+ func (rl *RateLimiter) Allow(userID common.Address) (bool, uuid.UUID)

+ func (rl *RateLimiter) CountOpenRequests(userID common.Address) int

+ func (rl *RateLimiter) GetMaxConcurrentRequest() uint32

+ func (rl *RateLimiter) GetUserComputeTime() time.Duration

+ func (rl *RateLimiter) IncrementRateLimitedRequests()

+ func (rl *RateLimiter) IncrementTotalRequests()

+ func (rl *RateLimiter) PruneRequests()

+ func (rl *RateLimiter) SetRequestEnd(userID common.Address, id uuid.UUID)

+ func (rl *RateLimiter) SumComputeTime(userID common.Address) time.Duration

+ type RequestInterval struct

+ End *time.Time

+ Start time.Time