Documentation
¶
Index ¶
- Constants
- type IMsg2Nats
- type MsgFormat
- type NatsHeader
- type NatsManager
- type NatsMessage
- func (msg *NatsMessage) CheckTopicExist() bool
- func (nm *NatsMessage) GetTopic() string
- func (m *NatsMessage) Ini()
- func (m *NatsMessage) IniData(data []byte)
- func (entity *NatsMessage) String() string
- func (entity *NatsMessage) ToString() string
- func (entity *NatsMessage) Unmarshal(body string) error
Constants ¶
View Source
const DEFAULT_VERSION = "V1"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NatsHeader ¶
type NatsHeader struct {
Topic, Version string
MsgId int64
TraceId int64
ParentId int64
SpanId int64
}
func (*NatsHeader) Ini ¶
func (h *NatsHeader) Ini()
func (*NatsHeader) String ¶
func (entity *NatsHeader) String() string
func (*NatsHeader) ToString ¶
func (entity *NatsHeader) ToString() string
type NatsManager ¶
type NatsManager struct {
Nc *nats.Conn
Mapnats map[string]func(m *nats.Msg)
// contains filtered or unexported fields
}
func (*NatsManager) Ini ¶
func (nm *NatsManager) Ini()
func (*NatsManager) Publish ¶
func (nm *NatsManager) Publish(msg NatsMessage) error
func (*NatsManager) PublishData ¶
func (nm *NatsManager) PublishData(msg NatsMessage, data []byte) error
func (*NatsManager) Register ¶
func (nm *NatsManager) Register(topic string, f func(m *nats.Msg))
func (*NatsManager) Subscribe ¶
func (nm *NatsManager) Subscribe(Topic string) error
type NatsMessage ¶
type NatsMessage struct {
Header NatsHeader
Code int32
Msg string
Format MsgFormat
Body *[]byte // 二进制
//JsonBody *string
CheckOk bool
}
func (*NatsMessage) CheckTopicExist ¶
func (msg *NatsMessage) CheckTopicExist() bool
func (*NatsMessage) GetTopic ¶
func (nm *NatsMessage) GetTopic() string
func (*NatsMessage) Ini ¶
func (m *NatsMessage) Ini()
func (*NatsMessage) IniData ¶
func (m *NatsMessage) IniData(data []byte)
func (*NatsMessage) String ¶
func (entity *NatsMessage) String() string
func (*NatsMessage) ToString ¶
func (entity *NatsMessage) ToString() string
func (*NatsMessage) Unmarshal ¶
func (entity *NatsMessage) Unmarshal(body string) error
Source Files
Click to show internal directories.
Click to hide internal directories.