events

README

这个包负责提供事件的封装及解包

Documentation

Index

• func NatsSubscription(handle HandleFunc) func(msg *nats.Msg)
• func NewEventMsg(ctx context.Context, data []byte) []byte
• type DataUpdateInfo
• type EventHandle
  • func GetEventMsg(data []byte) EventHandle
• type HandleFunc
• type MsgHead
  • func (m *MsgHead) GetCtx() context.Context
  • func (m *MsgHead) GetData() []byte
  • func (m *MsgHead) GetTs() time.Time
• type MySpanContextConfig

Functions

func NatsSubscription

func NatsSubscription(handle HandleFunc) func(msg *nats.Msg)

func NewEventMsg

func NewEventMsg(ctx context.Context, data []byte) []byte

Types

type DataUpdateInfo

type DataUpdateInfo struct {
	ProductID  string
	DeviceName string
}

type EventHandle

type EventHandle interface {
	GetCtx() context.Context
	GetTs() time.Time
	GetData() []byte
}

func GetEventMsg

func GetEventMsg(data []byte) EventHandle

type HandleFunc

type HandleFunc func(ctx context.Context, msg []byte) error

type MsgHead

type MsgHead struct {
	Trace     []byte //追踪tid
	Timestamp int64  //发送时毫秒级时间戳
	Data      []byte //传送的内容
}

MsgHead 消息队列的头 todo 后续考虑用proto重构这个头

func (*MsgHead) GetCtx

func (m *MsgHead) GetCtx() context.Context

func (*MsgHead) GetData

func (m *MsgHead) GetData() []byte

func (*MsgHead) GetTs

func (m *MsgHead) GetTs() time.Time

type MySpanContextConfig

type MySpanContextConfig struct {
	TraceID string
	SpanID  string
}