msg2nats

Documentation

Index

• Constants
• type IMsg2Nats
• type MsgFormat
• type NatsHeader
  • func (h *NatsHeader) Ini()
  • func (entity *NatsHeader) String() string
  • func (entity *NatsHeader) ToString() string
• type NatsManager
  • func (nm *NatsManager) Ini()
  • func (nm *NatsManager) Publish(msg NatsMessage) error
  • func (nm *NatsManager) PublishData(msg NatsMessage, data []byte) error
  • func (nm *NatsManager) Register(topic string, f func(m *nats.Msg))
  • func (nm *NatsManager) Subscribe(Topic string) error
• 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

const DEFAULT_VERSION = "V1"

Types

type IMsg2Nats

type IMsg2Nats interface {
	String() string
	Ini()
}

type MsgFormat

type MsgFormat int32

const (
	MSG_FORMAT_JSON MsgFormat = iota
	MSG_FORMAT_PB   MsgFormat = iota + 1
)

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