ratelimit

package

v0.0.0-...-dde7ba0 Latest Latest Go to latest Published: Oct 1, 2024 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func NewDefaultLimiter(reqPerSec float64, burst int) limiter.Limiter

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

func NewGoRedis(rdb *redis.Client, rps float64, burst int) *GoRedis

func (d *GoRedis) Allow(key string) (bool, error)

func (d *GoRedis) AllowN(key string, n int) (bool, error)

type Mutex struct {
	M map[string]limiter.Limiter
	R float64
	B int
	// contains filtered or unexported fields
}

func NewMutex(constuctor NewLimiterFn, reqPerSec float64, burst int) *Mutex

func (d *Mutex) Allow(key string) (bool, error)

type NewLimiterFn = func(rate float64, burst int) limiter.Limiter

type RWMutex struct {
	M map[string]limiter.Limiter
	R float64
	B int
	// contains filtered or unexported fields
}

func NewRWMutex(constructor NewLimiterFn, reqPerSec float64, burst int) *RWMutex

func (d *RWMutex) Allow(key string) (bool, error)

type Ratelimiter interface {
	Allow(string) (bool, error)
}

func NewDefaultRatelimiter(reqPerSec float64, burst int) Ratelimiter

type SyncMapLoadOrStore struct {
	R float64
	B int
	// contains filtered or unexported fields
}

func NewSyncMapLoadOrStore(constructor NewLimiterFn, reqPerSec float64, burst int) *SyncMapLoadOrStore

func (d *SyncMapLoadOrStore) Allow(key string) (bool, error)

type SyncMapLoadThenLoadOrStore struct {
	R float64
	B int
	// contains filtered or unexported fields
}

func NewSyncMapLoadThenLoadOrStore(constructor NewLimiterFn, reqPerSec float64, burst int) *SyncMapLoadThenLoadOrStore

func (d *SyncMapLoadThenLoadOrStore) Allow(key string) (bool, error)

type SyncMapLoadThenStore struct {
	R float64
	B int
	// contains filtered or unexported fields
}

func NewSyncMapLoadThenStore(constructor NewLimiterFn, reqPerSec float64, burst int) *SyncMapLoadThenStore

func (d *SyncMapLoadThenStore) Allow(key string) (bool, error)