rate

package

v1.3.90 Latest Latest Go to latest Published: Jun 24, 2025 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type LimitLevel int

const (
	EnumLevelGlobal LimitLevel = iota
	EnumLevelUser
	EnumLevelClientId
	EnumLevelClientIp
)

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

func NewQpsLimiter(opts ...QpsOption) *QpsLimiter

Server ratelimiter middleware

func (l *QpsLimiter) ClientIdAllow(deviceId string) *QpsLimiter

func (l *QpsLimiter) ClientIpAllow(deviceIp string) *QpsLimiter

func (l *QpsLimiter) GetOk() bool

func (l *QpsLimiter) GlobalAllow() *QpsLimiter

func (l *QpsLimiter) OK() bool

func (l *QpsLimiter) SetOk(ok bool)

func (l *QpsLimiter) UserAllow(user string) *QpsLimiter

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

type QpsOption func(*QpsLimiter)

func QpsLimitOpt(level LimitLevel, qps float64, burst int) QpsOption

WithWindow with window size.

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

func GetTpsLimiter(opts ...TpsOption) (*TpsLimiter, error)

func (tl *TpsLimiter) Release(n int) int

func (tl *TpsLimiter) TryAcquire(n int) bool

type TpsOption func(*TpsLimiter)

func WithParal(paral int) TpsOption

func WithTag(tag string) TpsOption

WithWindow with window size.