rate_limit

Documentation

Index

• Constants
• type RateLimiter
• type TokenBucket
  • func NewTokenBucket(timeBucket time.Duration, callLimit int) *TokenBucket
  • func (t *TokenBucket) Allow(_ *http.Request) error
  • func (t *TokenBucket) Dec(_ *http.Request)
  • func (t *TokenBucket) Inc(_ *http.Request)
  • func (t *TokenBucket) Stop()

Constants

const (
	RequestLimitReachedErr = "request limit reached"
)

Types

type RateLimiter

type RateLimiter interface {
	Allow(req *http.Request) error
	Inc(req *http.Request)
	Dec(req *http.Request)
}

type TokenBucket

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

func NewTokenBucket

func NewTokenBucket(timeBucket time.Duration, callLimit int) *TokenBucket

func (*TokenBucket) Allow

func (t *TokenBucket) Allow(_ *http.Request) error

func (*TokenBucket) Dec

func (t *TokenBucket) Dec(_ *http.Request)

func (*TokenBucket) Inc

func (t *TokenBucket) Inc(_ *http.Request)

func (*TokenBucket) Stop

func (t *TokenBucket) Stop()