Versions in this module Expand all Collapse all v1 v1.5.4 Oct 26, 2023 Changes in this version + type Config struct + MaxQueuingTime *time.Duration + func (c *Config) SetDefault() + func (c *Config) Verify() error + type LeakyBucket struct + func (l *LeakyBucket) GetAmountInfos() []ratelimiter.AmountInfo + func (l *LeakyBucket) GetQuota(curTimeMs int64, token uint32) *model.QuotaResponse + func (l *LeakyBucket) GetQuotaUsed(curTimeMilli int64) ratelimiter.UsageInfo + func (l *LeakyBucket) OnRemoteUpdate(remoteQuota ratelimiter.RemoteQuotaResult) + func (l *LeakyBucket) Release() + type RateLimiterUniformRate struct + func (g *RateLimiterUniformRate) Destroy() error + func (g *RateLimiterUniformRate) Init(ctx *plugin.InitContext) error + func (g *RateLimiterUniformRate) InitQuota(criteria *ratelimiter.InitCriteria) ratelimiter.QuotaBucket + func (g *RateLimiterUniformRate) IsEnable(cfg config.Configuration) bool + func (g *RateLimiterUniformRate) Name() string + func (g *RateLimiterUniformRate) Type() common.Type