gomsg

Documentation

Index

• Variables
• func InjectGonatsContext(s *GonatsContext)
• func InjectGonatsMsg(s *GonatsMsg)
• func InjectGonatsMsgresp(s *GonatsMsgresp)
• func InjectHeader(s *Header)
• func LoadGonatsContext() baseiface.ISingleton
• func LoadGonatsMsg() baseiface.ISingleton
• func LoadGonatsMsgresp() baseiface.ISingleton
• func LoadHeader() baseiface.ISingleton
• func NewSeqId() int64
• type GonatsContext
  • func FindBeanGonatsContext() *GonatsContext
  • func NewGonatsContext() *GonatsContext
  • func NewGonatsContextOption(opts ...GonatsContextOption) *GonatsContext
• type GonatsContextOption
  • func WithGonatsMsg(gonatsMsg *GonatsMsg) GonatsContextOption
  • func WithGonatsMsgresp(gonatsMsgresp *GonatsMsgresp) GonatsContextOption
• type GonatsMsg
  • func Default() *GonatsMsg
  • func FindBeanGonatsMsg() *GonatsMsg
  • func NewGonatsMsg() *GonatsMsg
  • func ToGonatsMsg(msg *nats.Msg) *GonatsMsg
  • func (self *GonatsMsg) Check() error
  • func (self *GonatsMsg) Decode() error
  • func (self *GonatsMsg) DecodeData(out interface{}) error
  • func (self *GonatsMsg) Encode() *GonatsMsg
  • func (self *GonatsMsg) Execute() *GonatsMsg
  • func (self *GonatsMsg) From(msg *nats.Msg) *GonatsMsg
  • func (self *GonatsMsg) FromReq(req *GonatsMsg) *GonatsMsg
  • func (self *GonatsMsg) Init()
  • func (self *GonatsMsg) IsMsgReq() bool
  • func (self *GonatsMsg) Parse2PageEsRequest()
  • func (self *GonatsMsg) Parse2PageRequest()
  • func (self *GonatsMsg) SetData(model interface{}) error
  • func (self *GonatsMsg) Shutdown()
  • func (self *GonatsMsg) To() *nats.Msg
  • func (self *GonatsMsg) ToNats() *nats.Msg
• type GonatsMsgresp
  • func EsErrorResp(msg *GonatsMsg, err error) *GonatsMsgresp
  • func EsNotAupport(msg *GonatsMsg) *GonatsMsgresp
  • func FindBeanGonatsMsgresp() *GonatsMsgresp
  • func NewGonatsMsgresp() *GonatsMsgresp
  • func NewResp(req *nats.Msg) *GonatsMsgresp
  • func NewRespMsg(req *GonatsMsg) *GonatsMsgresp
  • func (self *GonatsMsgresp) Decode() error
  • func (self *GonatsMsgresp) Parse2PageEsResult()
  • func (self *GonatsMsgresp) Parse2PageResult()
  • func (self *GonatsMsgresp) Parse2Result()
• type Header
  • func DefaultHeader() *Header
  • func FindBeanHeader() *Header
  • func NewGonatsHeader() *Header
  • func NewHeader(opts ...HeaderOption) *Header
  • func (self *Header) Check() error
  • func (self *Header) ChooseChannel() int
  • func (self *Header) From(msg *nats.Msg)
  • func (self *Header) To(msg *nats.Msg)
  • func (self *Header) ToNats(msg *nats.Msg)
  • func (self *Header) Topic2Pre() string
• type HeaderOption
  • func WithAction(action string) HeaderOption
  • func WithDomain(domain string) HeaderOption
  • func WithMsgId(msgId string) HeaderOption
  • func WithMsgReq(msgReq bool) HeaderOption
  • func WithObjectId(objectId string) HeaderOption
  • func WithObjectType(objectType string) HeaderOption
  • func WithSeqId(seqId int64) HeaderOption
  • func WithTopic(topic string) HeaderOption

Variables

var (
	ErrInvalidType = errors.New("invalid esbasemodel type")
	ErrJsonEncode  = errors.New("JSON encoding error")
	ErrJsonDecode  = errors.New("JSON decoding error")
)

定义错误常量

Functions

func InjectGonatsContext

func InjectGonatsContext(s *GonatsContext)

func InjectGonatsMsg

func InjectGonatsMsg(s *GonatsMsg)

func InjectGonatsMsgresp

func InjectGonatsMsgresp(s *GonatsMsgresp)

func InjectHeader

func InjectHeader(s *Header)

func LoadGonatsContext

func LoadGonatsContext() baseiface.ISingleton

func LoadGonatsMsg

func LoadGonatsMsg() baseiface.ISingleton

func LoadGonatsMsgresp

func LoadGonatsMsgresp() baseiface.ISingleton

func LoadHeader

func LoadHeader() baseiface.ISingleton

func NewSeqId

func NewSeqId() int64

Types

type GonatsContext

type GonatsContext struct {
	basedto.BaseEntity
	*nats.Msg

	*GonatsMsg
	*GonatsMsgresp
}

func FindBeanGonatsContext

func FindBeanGonatsContext() *GonatsContext

FindBeanGonatsContext

func NewGonatsContext

func NewGonatsContext() *GonatsContext

func NewGonatsContextOption

func NewGonatsContextOption(opts ...GonatsContextOption) *GonatsContext

type GonatsContextOption

type GonatsContextOption func(*GonatsContext)

func WithGonatsMsg

func WithGonatsMsg(gonatsMsg *GonatsMsg) GonatsContextOption

func WithGonatsMsgresp

func WithGonatsMsgresp(gonatsMsgresp *GonatsMsgresp) GonatsContextOption

type GonatsMsg

type GonatsMsg struct {
	basedto.BaseEntity `json:"-"`
	*Header            `godicmd: json:"header"`
	Data               []byte `json:"data"`
	//只为显示 ，不参与编码解码
	Body interface{} `json:"body,omitempty"`
}

func Default

func Default() *GonatsMsg

DefaultMsg 创建一个默认的GonatsMsg实例。

func FindBeanGonatsMsg

func FindBeanGonatsMsg() *GonatsMsg

FindBeanGonatsMsg

func NewGonatsMsg

func NewGonatsMsg() *GonatsMsg

NewGonatsMsg 创建一个新的GonatsMsg实例。

func ToGonatsMsg

func ToGonatsMsg(msg *nats.Msg) *GonatsMsg

ToGonatsMsg 将nats.Msg转换为GonatsMsg。

func (*GonatsMsg) Check

func (self *GonatsMsg) Check() error

Check 检查消息头是否有效。

func (*GonatsMsg) Decode

func (self *GonatsMsg) Decode() error

func (*GonatsMsg) DecodeData

func (self *GonatsMsg) DecodeData(out interface{}) error

ParseData 解析消息数据。

func (*GonatsMsg) Encode

func (self *GonatsMsg) Encode() *GonatsMsg

func (*GonatsMsg) Execute

func (self *GonatsMsg) Execute() *GonatsMsg

HandleMsg 处理消息。

func (*GonatsMsg) From

func (self *GonatsMsg) From(msg *nats.Msg) *GonatsMsg

From 将nats.Msg转换信息填充到GonatsMsg。

func (*GonatsMsg) FromReq

func (self *GonatsMsg) FromReq(req *GonatsMsg) *GonatsMsg

func (*GonatsMsg) Init

func (self *GonatsMsg) Init()

func (*GonatsMsg) IsMsgReq

func (self *GonatsMsg) IsMsgReq() bool

func (*GonatsMsg) Parse2PageEsRequest

func (self *GonatsMsg) Parse2PageEsRequest()

func (*GonatsMsg) Parse2PageRequest

func (self *GonatsMsg) Parse2PageRequest()

以下为示例方法，使用接口或工厂模式进行改进可能需要更多上下文信息。

func (*GonatsMsg) SetData

func (self *GonatsMsg) SetData(model interface{}) error

SetData 设置消息数据。

func (*GonatsMsg) Shutdown

func (self *GonatsMsg) Shutdown()

func (*GonatsMsg) To

func (self *GonatsMsg) To() *nats.Msg

To: 转换GonatsMsg为nats.Msg

func (*GonatsMsg) ToNats

func (self *GonatsMsg) ToNats() *nats.Msg

type GonatsMsgresp

type GonatsMsgresp struct {
	basedto.BaseEntity `json:"-"`
	*GonatsMsg
}

func EsErrorResp

func EsErrorResp(msg *GonatsMsg, err error) *GonatsMsgresp

func EsNotAupport

func EsNotAupport(msg *GonatsMsg) *GonatsMsgresp

func FindBeanGonatsMsgresp

func FindBeanGonatsMsgresp() *GonatsMsgresp

FindBeanGonatsMsgresp

func NewGonatsMsgresp

func NewGonatsMsgresp() *GonatsMsgresp

func NewResp

func NewResp(req *nats.Msg) *GonatsMsgresp

NewGonatsMsgRes 创建一个从NATS消息响应的GonatsMsg实例。

func NewRespMsg

func NewRespMsg(req *GonatsMsg) *GonatsMsgresp

NewResp 创建一个响应类型的GonatsMsg实例。

func (*GonatsMsgresp) Decode

func (self *GonatsMsgresp) Decode() error

func (*GonatsMsgresp) Parse2PageEsResult

func (self *GonatsMsgresp) Parse2PageEsResult()

func (*GonatsMsgresp) Parse2PageResult

func (self *GonatsMsgresp) Parse2PageResult()

func (*GonatsMsgresp) Parse2Result

func (self *GonatsMsgresp) Parse2Result()

type Header

type Header struct {
	basedto.BaseEntity `json:"-"`

	Domain     string `json:"domain"`
	Topic      string `json:"topic"`
	Action     string `json:"action"`
	MsgId      string `json:"msg_id"`
	SeqId      int64  `json:"seq_id"`
	ObjectId   string `json:"object_id"`
	ObjectType string `json:"object_type"`
	MsgReq     bool   `json:"msg_req"`
}

func DefaultHeader

func DefaultHeader() *Header

func FindBeanHeader

func FindBeanHeader() *Header

FindBeanHeader

func NewGonatsHeader

func NewGonatsHeader() *Header

func NewHeader

func NewHeader(opts ...HeaderOption) *Header

func (*Header) Check

func (self *Header) Check() error

func (*Header) ChooseChannel

func (self *Header) ChooseChannel() int

func (*Header) From

func (self *Header) From(msg *nats.Msg)

func (*Header) To

func (self *Header) To(msg *nats.Msg)

func (*Header) ToNats

func (self *Header) ToNats(msg *nats.Msg)

func (*Header) Topic2Pre

func (self *Header) Topic2Pre() string

type HeaderOption

type HeaderOption func(*Header)

func WithAction

func WithAction(action string) HeaderOption

func WithDomain

func WithDomain(domain string) HeaderOption

func WithMsgId

func WithMsgId(msgId string) HeaderOption

func WithMsgReq

func WithMsgReq(msgReq bool) HeaderOption

func WithObjectId

func WithObjectId(objectId string) HeaderOption

func WithObjectType

func WithObjectType(objectType string) HeaderOption

func WithSeqId

func WithSeqId(seqId int64) HeaderOption

func WithTopic

func WithTopic(topic string) HeaderOption