small upd
This commit is contained in:
parent
6421d0bfe8
commit
8da176ffba
@ -2,17 +2,9 @@ linters:
|
|||||||
fast: true
|
fast: true
|
||||||
presets:
|
presets:
|
||||||
- bugs
|
- bugs
|
||||||
- comment
|
|
||||||
- complexity
|
|
||||||
- error
|
- error
|
||||||
- format
|
|
||||||
- import
|
|
||||||
- metalinter
|
- metalinter
|
||||||
- module
|
|
||||||
- performance
|
- performance
|
||||||
- sql
|
- sql
|
||||||
- style
|
|
||||||
- test
|
- test
|
||||||
- unused
|
- unused
|
||||||
disable:
|
|
||||||
- wsl
|
|
||||||
|
|||||||
@ -70,7 +70,7 @@ func main() {
|
|||||||
log.Panicf("redis ping: %v", err)
|
log.Panicf("redis ping: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
perDomainLimiter, err := redisleaky.New(
|
perDomainLimiter := redisleaky.New(
|
||||||
rate.Every(time.Duration(float64(time.Second)*cfg.PerDomainRateLimitEvery)),
|
rate.Every(time.Duration(float64(time.Second)*cfg.PerDomainRateLimitEvery)),
|
||||||
int64(cfg.PerDomainRateLimitCapacity),
|
int64(cfg.PerDomainRateLimitCapacity),
|
||||||
redisClient,
|
redisClient,
|
||||||
|
|||||||
@ -28,7 +28,7 @@ func New(
|
|||||||
capacity int64,
|
capacity int64,
|
||||||
redisClient *redis.Client,
|
redisClient *redis.Client,
|
||||||
prefix string,
|
prefix string,
|
||||||
) (*Limiter, error) {
|
) *Limiter {
|
||||||
l := Limiter{
|
l := Limiter{
|
||||||
rate: time.Duration(float64(time.Second) / float64(rateLimit)),
|
rate: time.Duration(float64(time.Second) / float64(rateLimit)),
|
||||||
capacity: capacity,
|
capacity: capacity,
|
||||||
@ -36,7 +36,7 @@ func New(
|
|||||||
redisPool: rsgoredis.NewPool(redisClient),
|
redisPool: rsgoredis.NewPool(redisClient),
|
||||||
prefix: prefix,
|
prefix: prefix,
|
||||||
}
|
}
|
||||||
return &l, nil
|
return &l
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *Limiter) Limit(ctx context.Context, key string) (time.Duration, error) {
|
func (l *Limiter) Limit(ctx context.Context, key string) (time.Duration, error) {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user