limiter

Documentation

Index

• Variables
• func WithServerLimiterInterceptor() grpc.UnaryServerInterceptor
• type BBR
  • func NewBbrLimiter(opts ...Option) BBR
• type DoneFunc
• type Option
  • func WithBucketDuration(bucketDuration time.Duration) Option
  • func WithBucketNum(bucketSize int) Option
  • func WithCpuThreshold(cpuThreshold uint32) Option

Variables

var (
	LimiterDropError = errors.New("drop request")
)

Functions

func WithServerLimiterInterceptor

func WithServerLimiterInterceptor() grpc.UnaryServerInterceptor

Types

type BBR

type BBR interface {
	Allow() (DoneFunc, error)
}

func NewBbrLimiter

func NewBbrLimiter(opts ...Option) BBR

type DoneFunc

type DoneFunc func()

type Option

type Option func(*options)

func WithBucketDuration

func WithBucketDuration(bucketDuration time.Duration) Option

WithBucketDuration 修改 bucketDuration

func WithBucketNum

func WithBucketNum(bucketSize int) Option

WithBucketNum 修改 BucketNum

func WithCpuThreshold

func WithCpuThreshold(cpuThreshold uint32) Option

WithCpuThreshold 修改 cpuThreshold 参数