mq

package

v0.3.5 Latest Latest Go to latest Published: Oct 8, 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"`
	EdgeHttpHost string         `json:"edge_http_host"` // http api 接口服务
	EdgeHttpPort string         `json:"edge_http_port"` //
	EdgeEnabled  bool           `json:"edge_enabled"`   // 是否开启基于Http的消息publisher功能
	Broker       *engine.Config `json:"broker"`         //
	Debug        bool           `json:"debug"`          // 调试模式开关
	// contains filtered or unexported fields
}

func DefaultConf ¶

func DefaultConf() Config

type CoreEventHandler ¶ added in v0.3.2

type CoreEventHandler struct {
	engine.DefaultEventHandler
}

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) 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) SetCrypto ¶ added in v0.3.4

func (m *MQ) SetCrypto(crypto proto.Crypto) *MQ

func (*MQ) SetCryptoPlan ¶ added in v0.3.4

func (m *MQ) SetCryptoPlan(option string, key ...string) *MQ

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