ratelimiter

Feb 22, 2022

Changes in this version

+ var ErrTLSRateLimited = errors.New("too many connections, please retry later")

+ func TLSClientIPKey(info *tls.ClientHelloInfo) string

+ func TLSHostnameKey(info *tls.ClientHelloInfo) string

+ type GetCertificateFunc func(*tls.ClientHelloInfo) (*tls.Certificate, error)

type Option

+ func WithTLSKeyFunc(keyFunc TLSKeyFunc) Option

type RateLimiter

+ func (rl *RateLimiter) GetCertificateMiddleware(getCertificate GetCertificateFunc) GetCertificateFunc

+ type TLSKeyFunc func(*tls.ClientHelloInfo) string

Jan 12, 2022

Changes in this version

+ const DefaultDomainCacheSize

type Option

+ func WithEnforce(enforce bool) Option

+ func WithKeyFunc(f KeyFunc) Option

Dec 16, 2021

Changes in this version

+ const DefaultSourceIPCacheSize

+ type KeyFunc func(*http.Request) string

type Option

+ func WithBlockedCountMetric(m *prometheus.GaugeVec) Option

+ func WithBurstSize(burst int) Option

+ func WithCacheMaxSize(size int64) Option

+ func WithCachedEntriesMetric(m *prometheus.GaugeVec) Option

+ func WithCachedRequestsMetric(m *prometheus.CounterVec) Option

+ func WithLimitPerSecond(limit float64) Option

type RateLimiter

+ func (rl *RateLimiter) Middleware(handler http.Handler) http.Handler

+ func (rl *RateLimiter) RequestAllowed(r *http.Request) bool

Oct 14, 2021

Changes in this version

+ const DefaultSourceIPBurstSize

+ const DefaultSourceIPLimitPerSecond

+ type Option func(*RateLimiter)

+ func WithNow(now func() time.Time) Option

+ func WithSourceIPBurstSize(burst int) Option

+ func WithSourceIPLimitPerSecond(limit float64) Option

+ type RateLimiter struct

+ func New(blockCountMetric, cachedEntriesMetric *prometheus.GaugeVec, ...) *RateLimiter

+ func (rl *RateLimiter) SourceIPAllowed(sourceIP string) bool

+ func (rl *RateLimiter) SourceIPLimiter(handler http.Handler) http.Handler