limiter

Apr 14, 2021

Changes in this version

+ var Defaultopt = Options

+ var ErrLimiterMaxSizeMustLargerThanWaringSize = errors.New("limiter的最大容量必须大于警戒容量")

+ type Hook func(res *redis_cell.RedisCellStatus) error

+ type Limiter struct

+ func New(cell *redis_cell.RedisCell, opts ...Option) (*Limiter, error)

+ func (c *Limiter) Capacity() int64

+ func (c *Limiter) Flood(ctx context.Context, value int64) (bool, error)

+ func (c *Limiter) IsFull(ctx context.Context) (bool, error)

+ func (c *Limiter) Reset(ctx context.Context) error

+ func (c *Limiter) WaterLevel(ctx context.Context) (int64, error)

+ type Option interface

+ Apply func(*Options)

+ func WithAsyncHooks() Option

+ func WithFullHook(hook Hook) Option

+ func WithWarningHook(hook Hook) Option

+ func WithWarningSize(warningSize int64) Option

+ type Options struct

+ AsyncHooks bool

+ FullHooks []Hook

+ WarningHooks []Hook

+ WarningSize int64