module

type JsCore struct {
	RespMessagesChan chan *core_func.EventData
	// contains filtered or unexported fields
}

type JsInterface interface {
	//recv消息
	RecvMsg() chan interface{} //todo your sturct,error or response
	//send消息
	SendMsg(interface{}) error
	//关闭循环，并释放资源
	Destroy()
}

type MActor interface {
	//recv消息
	ProcessRecvMsg(interface{}) error
	//关闭循环，并释放资源
	Destroy()
	// contains filtered or unexported methods
}

type MActorIm struct {
	SessionId string

	ReceivMsgChan chan interface{} //接收网络层数据通道
	// contains filtered or unexported fields
}

type ParamStru struct {
	UrlPath   string
	Token     string
	SessionId string
	UserId    int64
	GroupId   int64
	OrgId     int64
	OrgName   string
}

type Req struct {
	ReqFuncName string `json:"reqFuncName" `
	OperationID string `json:"operationID"`
	Data        string `json:"data"`
	UserID      string `json:"userID"`
	Batch       int    `json:"batchMsg"`
}

type RequestSt struct {
	Cmd          string `json:"cmd"` // "subscribe" "unsubscribe" or "heart"
	RequestId    string `json:"requestId"`
	Topic        string `json:"topic"`
	Extra        string `json:"extra"`
	MsgTimeStamp int64  `json:"msgStartTime"`
	MsgSeqId     int64  `json:"msgSeqId"`
}

type ResponseSt struct {
	Type         string `json:"type"`    //"response" or "mqMessage" or "heartConfig"
	Cmd          string `json:"cmd"`     //"connect" "subscribe" "unsubscribe"
	Success      bool   `json:"success"` //
	ErrMsg       string `json:"errMsg"`
	RequestId    string `json:"requestId"`
	Topic        string `json:"topic"`
	Extra        string `json:"extra"`
	MsgTimeStamp int64  `json:"msgTimeStamp"`
	MsgSeqId     int64  `json:"msgSeqId"`
	Data         string `json:"data"`
	Rate         int64  `json:"rate"`
}