ratelimiter

Nov 11, 2024

Changes in this version

+ type DistributedRateLimiter interface

+ TokenBucket func(ctx context.Context, capacity int64, per time.Duration) *limiters.TokenBucket

+ func NewDistributedRateLimiter(rdb redis.UniversalClient, key string) DistributedRateLimiter

+ type JobRateLimiter interface

+ Serve func()

+ Stop func()

+ TakeByClusterID func(ctx context.Context, clusterID uint, tokens int64) (time.Duration, error)

+ TakeByClusterIDs func(ctx context.Context, clusterIDs []uint, tokens int64) (time.Duration, error)

+ func NewJobRateLimiter(database *database.Database) (JobRateLimiter, error)