events

type ChangeInfo struct {
	ID int64
}

type DeviceCore struct {
	ProductID  string `json:"productID"`  //产品id
	DeviceName string `json:"deviceName"` //设备名称
}

type DeviceUpdateInfo struct {
	ProductID  string
	DeviceName string
	Data       any
}

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

type GatewayUpdateInfo struct {
	GatewayProductID  string
	GatewayDeviceName string
	Status            int32         //拓扑关系变化状态。* 2：解绑* 1：绑定
	Devices           []*DeviceCore //子设备列表
}

type HandleFunc func(ctx context.Context, msg []byte, natsMsg *nats.Msg) error

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

type MySpanContextConfig struct {
	TraceID string
	SpanID  string
}