single

Documentation

Index

• type Option
  • func WithKeyFn[K comparable](fn func(ctx *zero.Ctx) K) Option[K]
  • func WithPostFn[K comparable](fn func(ctx *zero.Ctx)) Option[K]
• type Single
  • func New[K comparable](op ...Option[K]) *Single[K]
  • func (s *Single[K]) Apply(engine *zero.Engine)

Types

type Option

type Option[K comparable] func(*Single[K])

Option 配置项

func WithKeyFn

func WithKeyFn[K comparable](fn func(ctx *zero.Ctx) K) Option[K]

WithKeyFn 指定反并发的 Key

func WithPostFn

func WithPostFn[K comparable](fn func(ctx *zero.Ctx)) Option[K]

WithPostFn 指定反并发拦截后的操作

type Single

type Single[K comparable] struct {
	// contains filtered or unexported fields
}

Single 反并发

func New

func New[K comparable](op ...Option[K]) *Single[K]

New 创建反并发中间件

func (*Single[K]) Apply

func (s *Single[K]) Apply(engine *zero.Engine)

Apply 为指定 Engine 添加反并发功能