message

Documentation

Index

• type Message
  • func FromNatsMsg(msg *nats.Msg) (*Message, error)
  • func FromNatsRequest(req micro.Request) (*Message, error)
  • func (m *Message) JSON() []byte
  • func (m *Message) ToNatsMsg() (*nats.Msg, error)

Types

type Message

type Message struct {
	Timestamp       int64               `json:"timestamp,omitempty"`
	MsgId           string              `json:"msg_id,omitempty"`
	ResponseChannel string              `json:"response_channel,omitempty"`
	Channel         string              `json:"channel,omitempty"`
	Route           string              `json:"route,omitempty"`
	From            string              `json:"from,omitempty"`
	To              string              `json:"to,omitempty"`
	Payload         interface{}         `json:"payload,omitempty"`
	Err             error               `json:"err,omitempty"`
	Meta            map[string][]string `json:"meta,omitempty"`
}

func FromNatsMsg

func FromNatsMsg(msg *nats.Msg) (*Message, error)

func FromNatsRequest

func FromNatsRequest(req micro.Request) (*Message, error)

func (*Message) JSON

func (m *Message) JSON() []byte

func (*Message) ToNatsMsg

func (m *Message) ToNatsMsg() (*nats.Msg, error)