ratelimit

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

type AdaptiveLimiterOptions struct {
	// 初始QPS限制
	InitialRate float64
	// 最小QPS限制
	MinRate float64
	// 最大QPS限制
	MaxRate float64
	// CPU使用率阈值 (0-1)，超过此值将降低限制
	HighLoadThreshold float64
	// CPU使用率阈值 (0-1)，低于此值将提高限制
	LowLoadThreshold float64
	// 降低系数，当负载过高时QPS限制的降低系数
	DecreaseFactorOnHeavyLoad float64
	// 增加系数，当负载过低时QPS限制的增加系数
	IncreaseFactorOnLightLoad float64
	// 响应时间阈值，超过此值将视为系统负载较高
	ResponseTimeThreshold time.Duration
	// 响应时间采样窗口大小
	ResponseTimeSampleSize int
	// 采样间隔，多久检查一次系统负载
	SamplingInterval time.Duration
	// 是否在过载时直接拒绝请求而不是延迟
	RejectOnOverload bool
	// 采样窗口大小
	WindowSize int
}

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

type FixWindowLimiterOptions func(l *FixWindowLimiter)

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

type LeakyBucketLimiterOptions func(l *LeakyBucketLimiter)

type LimiterStats struct {
	AllowedRequests  uint64
	RejectedRequests uint64
	CurrentRate      float64
}

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

type RedisFixWindowLimiterOptions func(l *RedisFixWindowLimiter)

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

type RedisSlideWindowLimiterOptions func(l *RedisSlideWindowLimiter)

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

type SlideWindowLimiterOptions func(l *SlideWindowLimiter)

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

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

type TokenBucketLimiterOptions func(l *TokenBucketLimiter)

type TokenBucketOptions struct {
	// 每秒生成的令牌数
	Rate float64
	// 桶的容量
	BucketSize float64
}