Documentation
¶
Index ¶
- type MaxSeqResp
- type MsgData
- type MsggatewayLogic
- func (l *MsggatewayLogic) DelUserConn(ctx context.Context, uid string, platform string)
- func (l *MsggatewayLogic) GetOnlineUserMap() map[string]interface{}
- func (l *MsggatewayLogic) GetUserConn(uid string, platform string) *UserConn
- func (l *MsggatewayLogic) GetUsersOnlineStatus(ctx context.Context, req *msggatewaypb.GetUsersOnlineStatusReq) (*msggatewaypb.GetUsersOnlineStatusResp, error)
- func (l *MsggatewayLogic) Msggateway(req *types.Request) (*types.Response, bool)
- func (l *MsggatewayLogic) SendMsgToUser(ctx context.Context, conn *UserConn, bMsg []byte, RecvPlatForm, RecvID string) error
- func (l *MsggatewayLogic) WsUpgrade(uid string, req *types.Request, w http.ResponseWriter, r *http.Request, ...) error
- type PullMessageResp
- type Req
- type Resp
- type SeqData
- type SeqListData
- type UserConn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MaxSeqResp ¶
type MaxSeqResp struct {
MaxSeq int64 `json:"maxSeq"`
}
type MsgData ¶
type MsgData struct {
PlatformID int32 `mapstructure:"platformID" validate:"required"`
SessionType int32 `mapstructure:"sessionType" validate:"required"`
MsgFrom int32 `mapstructure:"msgFrom" validate:"required"`
ContentType int32 `mapstructure:"contentType" validate:"required"`
RecvID string `mapstructure:"recvID" validate:"required"`
ForceList []string `mapstructure:"forceList"`
Content string `mapstructure:"content" validate:"required"`
Options map[string]interface{} `mapstructure:"options" validate:"required"`
ClientMsgID string `mapstructure:"clientMsgID" validate:"required"`
OfflineInfo map[string]interface{} `mapstructure:"offlineInfo" validate:"required"`
Ext map[string]interface{} `mapstructure:"ext"`
}
type MsggatewayLogic ¶
func NewMsggatewayLogic ¶
func NewMsggatewayLogic(ctx context.Context, svcCtx *wssvc.ServiceContext) *MsggatewayLogic
func (*MsggatewayLogic) DelUserConn ¶
func (l *MsggatewayLogic) DelUserConn(ctx context.Context, uid string, platform string)
func (*MsggatewayLogic) GetOnlineUserMap ¶
func (l *MsggatewayLogic) GetOnlineUserMap() map[string]interface{}
func (*MsggatewayLogic) GetUserConn ¶
func (l *MsggatewayLogic) GetUserConn(uid string, platform string) *UserConn
func (*MsggatewayLogic) GetUsersOnlineStatus ¶ added in v1.0.2
func (l *MsggatewayLogic) GetUsersOnlineStatus(ctx context.Context, req *msggatewaypb.GetUsersOnlineStatusReq) (*msggatewaypb.GetUsersOnlineStatusResp, error)
func (*MsggatewayLogic) Msggateway ¶
func (*MsggatewayLogic) SendMsgToUser ¶
type PullMessageResp ¶
type PullMessageResp struct {
}
type SeqListData ¶
type SeqListData struct {
SeqList []int64 `mapstructure:"seqList" validate:"required"`
}
Click to show internal directories.
Click to hide internal directories.