gmq

Documentation

Index

• type GMQ
  • func NewGMQ() *GMQ
  • func (this *GMQ) Close()
  • func (this *GMQ) Publish(topic string, data any) error
  • func (this *GMQ) Run()
  • func (this *GMQ) Subscribe(topic string, handler Handler)
• type Handler
• type Payload

Types

type GMQ

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

消息中间件

func NewGMQ

func NewGMQ() *GMQ

新建GMQ

func (*GMQ) Close

func (this *GMQ) Close()

关闭

func (*GMQ) Publish

func (this *GMQ) Publish(topic string, data any) error

发布

func (*GMQ) Run

func (this *GMQ) Run()

运行

func (*GMQ) Subscribe

func (this *GMQ) Subscribe(topic string, handler Handler)

订阅

type Handler

type Handler func(value any)

处理业务

type Payload

type Payload struct {
	// 主题
	Topic string

	// 内容
	Value any
}

内容