ctxext

Documentation

Overview

Package ctxext zb context 扩展

Index

• Variables
• func FakeSenderForwardNode(ctx *zero.Ctx, msgs ...message.MessageSegment) message.MessageSegment
• func LimitByGroup(ctx *zero.Ctx) *rate.Limiter
• func LimitByUser(ctx *zero.Ctx) *rate.Limiter
• func SetDefaultLimiterManagerParam(interval time.Duration, burst int)
• type LimiterManager
  • func NewLimiterManager(interval time.Duration, burst int) (m LimiterManager)
  • func (m LimiterManager) LimitByGroup(ctx *zero.Ctx) *rate.Limiter
  • func (m LimiterManager) LimitByUser(ctx *zero.Ctx) *rate.Limiter
• type NoCtxGetMsg
  • func GetFirstMessageInForward(ctx *zero.Ctx) NoCtxGetMsg
  • func GetMessage(ctx *zero.Ctx) NoCtxGetMsg
• type NoCtxSendMsg
  • func Send(ctx *zero.Ctx) NoCtxSendMsg
  • func SendFakeForwardToGroup(ctx *zero.Ctx, msgs ...message.MessageSegment) NoCtxSendMsg
  • func SendTo(ctx *zero.Ctx, user int64) NoCtxSendMsg
  • func SendToSelf(ctx *zero.Ctx) NoCtxSendMsg

Variables

var DefaultSingle = single.New(
	single.WithKeyFn(func(ctx *zero.Ctx) int64 {
		return ctx.Event.UserID
	}),
	single.WithPostFn[int64](func(ctx *zero.Ctx) {
		ctx.Send("您有操作正在执行, 请稍后再试!")
	}),
)

DefaultSingle 默认反并发处理

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

Functions

func FakeSenderForwardNode

func FakeSenderForwardNode(ctx *zero.Ctx, msgs ...message.MessageSegment) message.MessageSegment

FakeSenderForwardNode ...

func LimitByGroup

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

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

按群号限制

func LimitByUser

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

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

按 qq 号限制

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 *zero.Ctx) *rate.Limiter

LimitByGroup 自定义限速器

按群号限制

func (LimiterManager) LimitByUser

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

LimitByUser 自定义限速器

按 qq 号限制

type NoCtxGetMsg

type NoCtxGetMsg func(int64) zero.Message

func GetFirstMessageInForward

func GetFirstMessageInForward(ctx *zero.Ctx) NoCtxGetMsg

GetFirstMessageInForward ...

func GetMessage

func GetMessage(ctx *zero.Ctx) NoCtxGetMsg

GetMessage ...

type NoCtxSendMsg

type NoCtxSendMsg func(any) int64

func Send

func Send(ctx *zero.Ctx) NoCtxSendMsg

Send ...

func SendFakeForwardToGroup

func SendFakeForwardToGroup(ctx *zero.Ctx, msgs ...message.MessageSegment) NoCtxSendMsg

SendFakeForwardToGroup ...

func SendTo

func SendTo(ctx *zero.Ctx, user int64) NoCtxSendMsg

SendTo ...

func SendToSelf

func SendToSelf(ctx *zero.Ctx) NoCtxSendMsg

SendToSelf ...