Documentation
¶
Index ¶
- Variables
- func AsyncPostProducerMessage(c *fastapi.Context) *fastapi.Response
- func EdgeRouter() *fastapi.Router
- func PostProducerMessage(c *fastapi.Context) *fastapi.Response
- func StatRouter() *fastapi.Router
- type Config
- type ConsumerStatistic
- type CoreEventHandler
- type MQ
- func (m *MQ) Config() any
- func (m *MQ) Ctx() context.Context
- func (m *MQ) Logger() logger.Iface
- func (m *MQ) Serve()
- func (m *MQ) SetCrypto(crypto proto.Crypto) *MQ
- func (m *MQ) SetCryptoPlan(option string, key ...string) *MQ
- func (m *MQ) SetLogger(logger logger.Iface) *MQ
- func (m *MQ) Stat() *engine.Statistic
- func (m *MQ) Stop()
- type ProducerForm
- type ProductResponse
- type TopicConsumerStatistic
- type TopicOffsetStatistic
- type TopicRecordStatistic
Constants ¶
This section is empty.
Variables ¶
View Source
var List = fastapi.List
Functions ¶
func AsyncPostProducerMessage ¶ added in v0.3.7
AsyncPostProducerMessage 异步生产消息
func PostProducerMessage ¶ added in v0.3.7
PostProducerMessage 同步发送消息
func StatRouter ¶ added in v0.3.7
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 { fastapi.BaseModel 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 MQ ¶
type MQ struct {
// contains filtered or unexported fields
}
func (*MQ) SetCryptoPlan ¶ added in v0.3.4
SetCryptoPlan 修改加密方案
type ProducerForm ¶ added in v0.3.7
type ProducerForm struct { fastapi.BaseModel 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 { fastapi.BaseModel // 仅当 Accepted 时才认为服务器接受了请求并下方了有效的参数 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 TopicConsumerStatistic ¶ added in v0.3.7
type TopicOffsetStatistic ¶ added in v0.3.7
type TopicOffsetStatistic struct { fastapi.BaseModel 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
Click to show internal directories.
Click to hide internal directories.