mq

package
v0.3.8-pre2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 29, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ErrorLog added in v0.3.11 

func ErrorLog(c *fastapi.Context)

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功能
	Debug             bool           `json:"debug"`              // 调试模式开关
	SwaggerDisabled   bool           `json:"swagger_disabled"`   // 禁用调试文档
	StatisticDisabled bool           `json:"statistic_disabled"` // 禁用统计功能
	Broker            *engine.Config `json:"broker"`             //
	// contains filtered or unexported fields
}

func DefaultConf 

func DefaultConf() Config

type ConsumerStatistic added in v0.3.7 

type ConsumerStatistic struct {
	Addr   string   `json:"addr" description:"连接地址"`
	Topics []string `json:"topics" description:"订阅的主题名列表"`
}

func (*ConsumerStatistic) SchemaDesc added in v0.3.7 

func (m *ConsumerStatistic) SchemaDesc() string

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 EdgeRouter added in v0.3.7 

type EdgeRouter struct {
	fastapi.BaseGroupRouter
}

func (*EdgeRouter) Description added in v0.3.11 

func (r *EdgeRouter) Description() map[string]string

func (*EdgeRouter) Path added in v0.3.11 

func (r *EdgeRouter) Path() map[string]string

func (*EdgeRouter) PathSchema added in v0.3.11 

func (r *EdgeRouter) PathSchema() pathschema.RoutePathSchema

func (*EdgeRouter) PostProduct added in v0.3.11 

func (r *EdgeRouter) PostProduct(c *fastapi.Context, form *ProducerForm) (*ProductResponse, error)

PostProduct 发送一个生产者消息

func (*EdgeRouter) PostProductAsync added in v0.3.11 

func (r *EdgeRouter) PostProductAsync(c *fastapi.Context, form *ProducerForm) (*ProductResponse, error)

PostProductAsync 异步发送一个生产者消息

func (*EdgeRouter) Prefix added in v0.3.11 

func (r *EdgeRouter) Prefix() string

func (*EdgeRouter) Summary added in v0.3.11 

func (r *EdgeRouter) Summary() map[string]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

Ctx 获取根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

SetCrypto 设置加解密器

func (*MQ) SetCryptoPlan added in v0.3.4 

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

SetCryptoPlan 修改加密方案

func (*MQ) SetLogger added in v0.3.1 

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

func (*MQ) Stat added in v0.3.7 

func (m *MQ) Stat() *engine.Statistic

Stat 获取统计信息类

func (*MQ) Stop 

func (m *MQ) Stop()

type ProducerForm added in v0.3.7 

type ProducerForm struct {
	Token string `json:"token,omitempty" description:"认证密钥"`
	Topic string `json:"topic" description:"消息主题"`
	Key   string `json:"key" description:"消息键"`
	Value string `json:"value" description:"base64编码后的消息体"`
}

func (*ProducerForm) IsEncrypt added in v0.3.7 

func (m *ProducerForm) IsEncrypt() bool

func (*ProducerForm) SchemaDesc added in v0.3.7 

func (m *ProducerForm) SchemaDesc() string

func (*ProducerForm) String added in v0.3.7 

func (m *ProducerForm) String() string

type ProductResponse added in v0.3.7 

type ProductResponse struct {
	Status       string `` /* 126-byte string literal not displayed */
	Offset       uint64 `json:"offset" description:"消息偏移量"`
	ResponseTime int64  `json:"response_time" description:"服务端返回消息时的时间戳"`
	Message      string `json:"message" description:"额外的消息描述"`
}

func (*ProductResponse) SchemaDesc added in v0.3.7 

func (m *ProductResponse) SchemaDesc() string

func (*ProductResponse) String added in v0.3.7 

func (m *ProductResponse) String() string

type StatRouter added in v0.3.7 

type StatRouter struct {
	fastapi.BaseGroupRouter
}

func (*StatRouter) Description added in v0.3.11 

func (r *StatRouter) Description() map[string]string

func (*StatRouter) GetConsumers added in v0.3.11 

func (r *StatRouter) GetConsumers(c *fastapi.Context) ([]*ConsumerStatistic, error)

GetConsumers 获取Broker内的消费者连接

func (*StatRouter) GetProducers added in v0.3.11 

func (r *StatRouter) GetProducers(c *fastapi.Context) ([]string, error)

GetProducers 获取Broker内的生产者连接

func (*StatRouter) GetTopic added in v0.3.11 

func (r *StatRouter) GetTopic(c *fastapi.Context) ([]string, error)

GetTopic 获取Broker内的topic名称

func (*StatRouter) GetTopicConsumers added in v0.3.11 

func (r *StatRouter) GetTopicConsumers(c *fastapi.Context) ([]*TopicConsumerStatistic, error)

GetTopicConsumers 获取主题内部的消费者连接

func (*StatRouter) GetTopicOffset added in v0.3.11 

func (r *StatRouter) GetTopicOffset(c *fastapi.Context) ([]*TopicOffsetStatistic, error)

GetTopicOffset 获取Broker内的topic名称及其最新的消息计数

func (*StatRouter) GetTopicRecord added in v0.3.11 

func (r *StatRouter) GetTopicRecord(c *fastapi.Context) ([]*TopicRecordStatistic, error)

GetTopicRecord 获取主题内部的最新消息记录

func (*StatRouter) PathSchema added in v0.3.11 

func (r *StatRouter) PathSchema() pathschema.RoutePathSchema

func (*StatRouter) Prefix added in v0.3.11 

func (r *StatRouter) Prefix() string

func (*StatRouter) Summary added in v0.3.11 

func (r *StatRouter) Summary() map[string]string

type TopicConsumerStatistic added in v0.3.7 

type TopicConsumerStatistic struct {
	Topic     string   `json:"topic" description:"名称"`
	Consumers []string `json:"consumers" description:"消费者连接"`
}

type TopicOffsetStatistic added in v0.3.7 

type TopicOffsetStatistic struct {
	Topic  string `json:"topic" description:"名称"`
	Offset uint64 `json:"offset" description:"最新的消息偏移量"`
}

func (*TopicOffsetStatistic) SchemaDesc added in v0.3.7 

func (m *TopicOffsetStatistic) SchemaDesc() string

type TopicRecordStatistic added in v0.3.7 

type TopicRecordStatistic struct {
	Topic       string `json:"topic" description:"名称"`
	Key         string `json:"key"`
	Value       string `json:"value" description:"base64编码后的消息体明文"`
	Offset      uint64 `json:"offset" description:"消息偏移量"`
	ProductTime int64  `json:"product_time" description:"消息接收时间戳"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.