ratelimiter

May 5, 2022

Changes in this version

type TtlRateLimiter

+ IsBlockedContext func(ctx context.Context, blockKey string) *Result

+ ShouldBlock2Context func(ctx context.Context, key string, blockKey string, msg string) *Result

+ ShouldBlockContext func(ctx context.Context, key string, msg string) *Result

Mar 4, 2022

Changes in this version

type TtlRateLimiter

+ func NewRedisTtlRateLimiterCluster(redisClient *redis.Client, params TtlRateLimiterParams, hashTag string) TtlRateLimiter

Jun 2, 2021

Changes in this version

type TtlRateLimiter

+ IsBlocked func(blockKey string) *Result

Nov 25, 2020

Changes in this version

+ func LoadScript(redisClient *redis.Client)

+ type Result struct

+ Block bool

+ Msg string

+ Triggered bool

+ Ttl int

+ type TtlRateLimiter interface

+ GetCapacity func() int

+ GetTimeoutSeconds func() int

+ GetWindowSizeSeconds func() int

+ ShouldBlock func(key string, msg string) *Result

+ ShouldBlock2 func(key string, blockKey string, msg string) *Result

+ func NewRedisTtlRateLimiter(redisClient *redis.Client, params TtlRateLimiterParams) TtlRateLimiter

+ type TtlRateLimiterParams interface

+ GetCapacity func() int

+ GetTimeoutSeconds func() int

+ GetWindowSizeSeconds func() int

+ func NewFixedTtlRateLimiterParams(capacity, windowsSizeSec, timeoutSec int) TtlRateLimiterParams

Apr 21, 2020

Changes in this version

+ type Interface interface

+ Acquire func() (acquired bool)

+ Capacity func() int

Apr 17, 2020

Changes in this version

+ type AtomicTokenBucket struct

+ func (t *AtomicTokenBucket) Acquire() bool

+ func (t *AtomicTokenBucket) Capacity() int

+ type FixedWindow interface

+ WindowSize func() time.Duration

+ type RateLimiter interface

+ Acquire func() (acquired bool)

+ Capacity func() int

+ type SlidingWindow interface

+ WindowSize func() time.Duration

+ type SyncFixedWindow struct

+ func NewSyncFixedWindow(capacity int, windowSize time.Duration) *SyncFixedWindow

+ func (s *SyncFixedWindow) Acquire() bool

+ func (s *SyncFixedWindow) Capacity() int

+ func (s *SyncFixedWindow) WindowSize() time.Duration

+ type SyncSlidingWindow struct

+ func NewSyncSlidingWindow(capacity int, windowSize time.Duration) *SyncSlidingWindow

+ func (s *SyncSlidingWindow) Acquire() bool

+ func (s *SyncSlidingWindow) Capacity() int

+ func (s *SyncSlidingWindow) WindowSize() time.Duration

+ type SyncTokenBucket struct

+ func (t *SyncTokenBucket) Acquire() bool

+ func (t *SyncTokenBucket) Capacity() int

+ type TokenBucket interface

+ func NewAtomicTokenBucket(capacity, issueRatePerSecond int) TokenBucket

+ func NewSyncTokenBucket(capacity, issueRatePerSecond int) TokenBucket