sopdelay

Documentation

Index

• func InitNodeDelayConsumer()
• func Serve() error
• func Shutdown() error
• type INodeDelayer
  • func NewNodeDelayer(ctx context.Context) INodeDelayer

Functions

func InitNodeDelayConsumer

func InitNodeDelayConsumer()

InitNodeDelayConsumer 延迟消费

func Serve

func Serve() error

Serve 启动服务 @title 账户服务(mk-plan-center) @version 1.0 @description 示例服务 @host mk-dev.dustess.com @BasePath /mk_plan_center

func Shutdown

func Shutdown() error

Shutdown 关闭服务

Types

type INodeDelayer

type INodeDelayer interface {
	ProducerOne(data model.NodeDelay) error
}

INodeDelayer 延迟异步服务

func NewNodeDelayer

func NewNodeDelayer(ctx context.Context) INodeDelayer

NewNodeDelayer 创建延迟异步服务