limiter

package

v0.2.6 Latest Latest Go to latest Published: Mar 16, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func RateLimitInterceptor(limiter RateLimiter) grpc.UnaryServerInterceptor

RateLimitInterceptor 创建限流拦截器

type RateLimiter interface {
	Allow() bool
	Wait(ctx context.Context) error
}

RateLimiter 限流器接口

type TokenBucketLimiter struct {
	// contains filtered or unexported fields
}

TokenBucketLimiter 令牌桶限流器

func NewTokenBucketLimiter(tokenRate float64, bucketSize int) *TokenBucketLimiter

NewTokenBucketLimiter 创建新的令牌桶限流器 @params tokenRate 令牌产生速率（每秒产生的令牌数） @params bucketSize 令牌桶容量（最大可存储的令牌数）

func (l *TokenBucketLimiter) Allow() bool

func (l *TokenBucketLimiter) Wait(ctx context.Context) error