ctxext

Documentation

Overview

Package ctxext ctx扩展

Index

• Variables
• func LimitByGroup(ctx *rei.Ctx) *rate.Limiter
• func LimitByUser(ctx *rei.Ctx) *rate.Limiter
• func MustMessageNotNil(ctx *rei.Ctx) bool
• func SetDefaultLimiterManagerParam(interval time.Duration, burst int)
• type LimiterManager
  • func NewLimiterManager(interval time.Duration, burst int) (m LimiterManager)
  • func (m LimiterManager) LimitByGroup(ctx *rei.Ctx) *rate.Limiter
  • func (m LimiterManager) LimitByUser(ctx *rei.Ctx) *rate.Limiter

Variables

var DefaultSingle = rei.NewSingle(
	rei.WithKeyFn(func(ctx *rei.Ctx) int64 {
		switch msg := ctx.Value.(type) {
		case *tgba.Message:
			return msg.From.ID
		case *tgba.CallbackQuery:
			return msg.From.ID
		}
		return 0
	}),
	rei.WithPostFn[int64](func(ctx *rei.Ctx) {
		_, _ = ctx.SendPlainMessage(false, "您有操作正在执行, 请稍后再试!")
	}),
)

DefaultSingle 默认反并发处理

按 发送者 反并发
并发时返回 "您有操作正在执行, 请稍后再试!"

Functions

func LimitByGroup

func LimitByGroup(ctx *rei.Ctx) *rate.Limiter

LimitByGroup 默认限速器 每 10s 5次触发

按群号限制

func LimitByUser

func LimitByUser(ctx *rei.Ctx) *rate.Limiter

LimitByUser 默认限速器 每 10s 5次触发

按 发送者 限制

func MustMessageNotNil

func MustMessageNotNil(ctx *rei.Ctx) bool

func SetDefaultLimiterManagerParam

func SetDefaultLimiterManagerParam(interval time.Duration, burst int)

SetDefaultLimiterManagerParam 设置默认限速器参数

每 interval 时间 burst 次触发

Types

type LimiterManager

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

LimiterManager 自定义限速器管理

func NewLimiterManager

func NewLimiterManager(interval time.Duration, burst int) (m LimiterManager)

NewLimiterManager 新限速器管理

func (LimiterManager) LimitByGroup

func (m LimiterManager) LimitByGroup(ctx *rei.Ctx) *rate.Limiter

LimitByGroup 自定义限速器

按群号限制

func (LimiterManager) LimitByUser

func (m LimiterManager) LimitByUser(ctx *rei.Ctx) *rate.Limiter

LimitByUser 自定义限速器

按 发送者 限制