limit

Documentation

Index

• Constants
• type LimitEngine
  • func NewLimitEngine(ruleConfig *model.RuleConfig) (*LimitEngine, error)
  • func (engine *LimitEngine) OverLimit() bool
• type Limiter
• type QPSLimiter
  • func NewQPSLimiter(maxAllows int64, periodMs int64) (*QPSLimiter, error)
  • func (l *QPSLimiter) TryAcquire() bool
• type RateLimiter
  • func NewRateLimiter(maxAllows int64, periodMs int64, MaxBurstRatio float64) (*RateLimiter, error)
  • func (l *RateLimiter) TryAcquire() bool

Constants

const (
	QPSStrategy         = "QPS"
	RateLimiterStrategy = "RateLimiter"
)

limit strategy

Types

type LimitEngine

type LimitEngine struct {
	RuleConfig *model.RuleConfig
	// contains filtered or unexported fields
}

LimitEngine limit

func NewLimitEngine

func NewLimitEngine(ruleConfig *model.RuleConfig) (*LimitEngine, error)

NewLimitEngine limit

func (*LimitEngine) OverLimit

func (engine *LimitEngine) OverLimit() bool

OverLimit check limit

type Limiter

type Limiter interface {
	TryAcquire() bool
}

Limiter limit

type QPSLimiter

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

QPSLimiter limiter

func NewQPSLimiter

func NewQPSLimiter(maxAllows int64, periodMs int64) (*QPSLimiter, error)

NewQPSLimiter new

func (*QPSLimiter) TryAcquire

func (l *QPSLimiter) TryAcquire() bool

TryAcquire limit

type RateLimiter

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

RateLimiter limit

func NewRateLimiter

func NewRateLimiter(maxAllows int64, periodMs int64, MaxBurstRatio float64) (*RateLimiter, error)

NewRateLimiter new

func (*RateLimiter) TryAcquire

func (l *RateLimiter) TryAcquire() bool

TryAcquire limit