mq

package

v0.3.1-pre7 Latest Latest Go to latest Published: Aug 14, 2023 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Chendemo12/micromq

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
- func DefaultConf() Config
type CoreEventHandler
type MQ
- func New(cs ...Config) *MQ

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	AppName     string         `json:"app_name"`
	Version     string         `json:"version"`
	Debug       bool           `json:"debug"`        // 调试模式开关
	HttpHost    string         `json:"http_host"`    // http api 接口服务
	HttpPort    string         `json:"http_port"`    //
	EdgeEnabled bool           `json:"edge_enabled"` // 是否开启基于Http的消息publisher功能
	Broker      *engine.Config `json:"broker"`
}

func DefaultConf ¶

func DefaultConf() Config

type CoreEventHandler ¶ added in v0.3.2

type CoreEventHandler struct {
	engine.DefaultEventHandler
}

func (CoreEventHandler) OnCMConsumed ¶ added in v0.3.2

func (e CoreEventHandler) OnCMConsumed(record *engine.HistoryRecord)

func (CoreEventHandler) OnConsumerClosed ¶ added in v0.3.2

func (e CoreEventHandler) OnConsumerClosed(_ string)

func (CoreEventHandler) OnConsumerRegister ¶ added in v0.3.2

func (e CoreEventHandler) OnConsumerRegister(_ string)

func (CoreEventHandler) OnFrameParseError ¶ added in v0.3.2

func (e CoreEventHandler) OnFrameParseError(_ *proto.TransferFrame, _ transfer.Conn)

func (CoreEventHandler) OnNotImplementMessageType ¶ added in v0.3.2

func (e CoreEventHandler) OnNotImplementMessageType(frame *proto.TransferFrame, r transfer.Conn) (bool, error)

func (CoreEventHandler) OnProducerClosed ¶ added in v0.3.2

func (e CoreEventHandler) OnProducerClosed(_ string)

func (CoreEventHandler) OnProducerRegister ¶ added in v0.3.2

func (e CoreEventHandler) OnProducerRegister(_ string)

type MQ ¶

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

func New ¶

func New(cs ...Config) *MQ

func (*MQ) Config ¶ added in v0.3.3

func (m *MQ) Config() any

func (*MQ) Ctx ¶ added in v0.3.1

func (m *MQ) Ctx() context.Context

func (*MQ) Logger ¶ added in v0.3.1

func (m *MQ) Logger() logger.Iface

func (*MQ) Serve ¶ added in v0.3.1

func (m *MQ) Serve()

Serve 阻塞启动

func (*MQ) SetLogger ¶ added in v0.3.1

func (m *MQ) SetLogger(logger logger.Iface) *MQ

func (*MQ) Stop ¶

func (m *MQ) Stop()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL