mq

package

v0.3.2 Latest Latest Go to latest Published: Aug 6, 2023 License: MIT Imports: 7 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"`
	Host          string       `json:"host"`
	Port          string       `json:"port"`
	Debug         bool         `json:"debug"`
	DashboardHost string       `json:"dashboard_host"`
	DashboardPort string       `json:"dashboard_port"`
	MaxOpenConn   int          `json:"max_open_conn"` // 允许的最大连接数, 即 生产者+消费者最多有 MaxOpenConn 个
	BufferSize    int          `json:"buffer_size"`   // 生产者消息历史记录最大数量
	Crypto        proto.Crypto `json:"-"`             // 加密器
	Token         string       `json:"-"`             // 注册认证密钥
}

func DefaultConf ¶

func DefaultConf() Config

type CoreEventHandler ¶ added in v0.3.2

type CoreEventHandler struct{}

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, _ *tcp.Remote)

func (CoreEventHandler) OnNotImplementMessageType ¶ added in v0.3.2

func (e CoreEventHandler) OnNotImplementMessageType(frame *proto.TransferFrame, r *tcp.Remote) (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) 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