rate_limit

README

rate_limit

基于各种中间件实现的流控

Documentation

Overview

Package rate_limit ...

Description : rate_limit ...

Author : go_developer@163.com<白茶清欢>

Date : 2024-06-24 15:04

Package rate_limit ...

Description : rate_limit ...

Author : go_developer@163.com<白茶清欢>

Date : 2024-06-20 20:40

Package rate_limit ...

Description : rate_limit ...

Author : go_developer@163.com<白茶清欢>

Date : 2023-03-09 11:31

Index

• Variables
• type Default
  • func (d Default) AllowN(ctx context.Context, limitCfg *define.LimitConfig, tokenCnt int) (bool, error)
  • func (d Default) Reset(ctx context.Context, limitCfg *define.LimitConfig) error
• type Memory
  • func (m *Memory) AllowN(ctx context.Context, limitCfg *define.LimitConfig, tokenCnt int) (bool, error)
  • func (m *Memory) Reset(ctx context.Context, limitCfg *define.LimitConfig) error
• type Redis
  • func (r *Redis) AllowN(ctx context.Context, limitCfg *define.LimitConfig, tokenCnt int) (bool, error)
  • func (r *Redis) Reset(ctx context.Context, limitCfg *define.LimitConfig) error
  • func (r *Redis) SetRedisClient(client *redisInstance.Client)

Variables

var (
	DefaultClient = &Default{}
)

var (
	MemoryClient = &Memory{
		lock:         &sync.RWMutex{},
		limiterTable: make(map[string]*rate.Limiter),
	}
)

var (
	RedisClient = &Redis{}
)

Types

type Default

type Default struct {
}

func (Default) AllowN

func (d Default) AllowN(ctx context.Context, limitCfg *define.LimitConfig, tokenCnt int) (bool, error)

func (Default) Reset

func (d Default) Reset(ctx context.Context, limitCfg *define.LimitConfig) error

type Memory

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

Memory ...

Author : go_developer@163.com<白茶清欢>

Date : 20:40 2024/6/20

func (*Memory) AllowN

func (m *Memory) AllowN(ctx context.Context, limitCfg *define.LimitConfig, tokenCnt int) (bool, error)

func (*Memory) Reset

func (m *Memory) Reset(ctx context.Context, limitCfg *define.LimitConfig) error

type Redis

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

Redis ...

Author : go_developer@163.com<白茶清欢>

Date : 11:44 2024/6/20

func (*Redis) AllowN

func (r *Redis) AllowN(ctx context.Context, limitCfg *define.LimitConfig, tokenCnt int) (bool, error)

func (*Redis) Reset

func (r *Redis) Reset(ctx context.Context, limitCfg *define.LimitConfig) error

func (*Redis) SetRedisClient

func (r *Redis) SetRedisClient(client *redisInstance.Client)