event

type EventBus struct {
	Bus sync.Map
}

type EventChannel struct {
	// contains filtered or unexported fields
}

type EventData struct {
	// contains filtered or unexported fields
}

type EventMonitorItem interface {
	ProgramID() string          //返回实例的名字
	Type() string               //返回实例的消息类型
	Send(topic ...string) error //发送消息到消息队列
}

type IMessage interface {
	GetId() uint64     //获取消息ID
	GetMethod() string //获取消息协议
	GetBytes() []byte  //获取消息内容
	GetData() string   //获取消息内容的字符串
}

type Item interface {
	MsgType() string    //消息一级类型
	MsgSubType() string //消息二级类型
	PubBus()            //发送数据到消息总线

	Set(k, v string) //设置
	Updates() error  //更新
}

type JsonBase struct {
	Method     string      `json:"method"`
	From       string      `json:"from,omitempty"`       //调用者（登录人）
	To         string      `json:"to,omitempty"`         //被调者
	Origin     string      `json:"origin,omitempty"`     //来源域名（或Ip）
	PlatFormId string      `json:"platformId,omitempty"` //平台id
	Zone       int         `json:"zone,omitempty"`       //时区
	RemoteIP   string      `json:"remoteIP,omitempty"`   //被调者Ip
	JWT        interface{} `json:"jwt,omitempty"`        //来源jwt验证信息
}

type JsonBody struct {
	Data string `json:"data,omitempty"`
}

type JsonError struct {
	Code    uint64      `json:"code"`
	Message string      `json:"message"`
	Data    interface{} `json:"data,omitempty"`
}

type JsonMsg struct {
	*JsonRequest
	*JsonParams
}

type JsonNotify struct {
	ProgramID     string          `json:"programId,omitempty"`     //系统程序id
	Id            uint64          `json:"id,omitempty"`            //消息id
	Type          MessageType     `json:"type,omitempty"`          //消息类型
	SubType       MessageSub      `json:"subType,omitempty"`       //一级类型(二级类型)
	Operator      MessageOperator `json:"operator,omitempty"`      //仅Data类型消息才有操作权限
	Timestamp     int64           `json:"timestamp,omitempty"`     //消息推送的时间戳
	KeepaliveTime time.Duration   `json:"keepaliveTime,omitempty"` //定时消息同步间隔时间
}

type JsonParams struct {
	Params interface{} `json:"params,omitempty"`
}

type JsonRequest struct {
	ID uint64 `json:"id"`
	*JsonBase
}

type Message[T MsgAble] struct {
	Able     T
	MqRabbit *mq.RabbitMQ
	MqRedis  *redis.Client
	Opts     *MsgOptions
}

type MessageOperator string

type MessageSub string

type MessageType string

type MsgAble interface {
	*JsonMsg | *XMLMsg
	PackageMsg
}

type MsgOption func(options *MsgOptions)

type MsgOptions struct {
	Id uint64
	*JsonParams
	*JsonBody
	*JsonNotify
	*JsonBase
	*JsonError
	*XMLHeader
	*XMLBody
}

type PackageMsg interface {
	PackEncode() []byte
	PackDecode(data []byte, value interface{}) error

	SetMessage(options *MsgOptions)
	GetMessage() []byte
}

type Subject interface {
	NotifyUp() error
	EventUp() error
}

type XMLBody struct {
	Items []struct {
		Data string `xml:",innerxml"`
	} `xml:"items"`
}

type XMLHeader struct {
	Id      uint64 `xml:"id"`      //当前消息ID
	Type    string `xml:"msgType"` //消息类型一级类
	SubType string `xml:"subType"` //消息子类型（二级分类）

	//执行的操作[ack,select,increment]
	//ack：当前消息为编辑响应消息
	//select：当前消息为查询响应消息
	//increment：当前消息为增量推送消息
	Operator string `xml:"operator"`
}

type XMLMsg struct {
	XMLName xml.Name   `xml:"Msg"`
	Head    *XMLHeader `xml:"Head"`
	Body    *XMLBody   `xml:"Body"`
}