|
@@ -1,7 +1,7 @@
|
|
|
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
|
|
|
// versions:
|
|
|
-// - protoc-gen-go-grpc v1.3.0
|
|
|
-// - protoc v3.21.12
|
|
|
+// - protoc-gen-go-grpc v1.2.0
|
|
|
+// - protoc v3.19.4
|
|
|
// source: message.proto
|
|
|
|
|
|
package message
|
|
@@ -18,42 +18,29 @@ import (
|
|
|
// Requires gRPC-Go v1.32.0 or later.
|
|
|
const _ = grpc.SupportPackageIsVersion7
|
|
|
|
|
|
-const (
|
|
|
- Message_MultipleSaveMsg_FullMethodName = "/message.Message/multipleSaveMsg"
|
|
|
- Message_ChangeReadStatus_FullMethodName = "/message.Message/ChangeReadStatus"
|
|
|
- Message_FindUserMsg_FullMethodName = "/message.Message/FindUserMsg"
|
|
|
- Message_FindMessageDetail_FullMethodName = "/message.Message/FindMessageDetail"
|
|
|
- Message_GetMsgType_FullMethodName = "/message.Message/GetMsgType"
|
|
|
- Message_FindUserBuoyMsg_FullMethodName = "/message.Message/FindUserBuoyMsg"
|
|
|
- Message_ClearUnreadMsg_FullMethodName = "/message.Message/ClearUnreadMsg"
|
|
|
- Message_UserMsgList_FullMethodName = "/message.Message/UserMsgList"
|
|
|
- Message_SendWxTmplMsg_FullMethodName = "/message.Message/SendWxTmplMsg"
|
|
|
- Message_UserUnreadMsgList_FullMethodName = "/message.Message/UserUnreadMsgList"
|
|
|
-)
|
|
|
-
|
|
|
// MessageClient is the client API for Message service.
|
|
|
//
|
|
|
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
|
|
|
type MessageClient interface {
|
|
|
- // 批量保存消息
|
|
|
+ //批量保存消息
|
|
|
MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error)
|
|
|
// 修改消息阅读状态
|
|
|
ChangeReadStatus(ctx context.Context, in *ChangeReadStatusReq, opts ...grpc.CallOption) (*Response, error)
|
|
|
- // 查询指定用户的历史消息记录
|
|
|
+ // 查询指定用户的历史消息记录
|
|
|
FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error)
|
|
|
- // 查看详细详情
|
|
|
+ //查看详细详情
|
|
|
FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error)
|
|
|
- // 消息的分类
|
|
|
+ // 消息的分类
|
|
|
GetMsgType(ctx context.Context, in *GetMsgTypeReq, opts ...grpc.CallOption) (*GetMsgTypeRes, error)
|
|
|
- // 查询指定用户的浮标消息
|
|
|
+ // 查询指定用户的浮标消息
|
|
|
FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error)
|
|
|
- // 一键清空未读消息
|
|
|
+ // 一键清空未读消息
|
|
|
ClearUnreadMsg(ctx context.Context, in *ClearUnreadMsgReq, opts ...grpc.CallOption) (*Response, error)
|
|
|
- // new用户消息列表
|
|
|
+ // new用户消息列表
|
|
|
UserMsgList(ctx context.Context, in *UserMsgListReq, opts ...grpc.CallOption) (*UserMsgListRes, error)
|
|
|
- // 发送剑鱼微信模版消息
|
|
|
+ // 发送剑鱼微信模版消息
|
|
|
SendWxTmplMsg(ctx context.Context, in *WxTmplMsgRequest, opts ...grpc.CallOption) (*SendMsgResponse, error)
|
|
|
- // 官网、移动端首页、工作桌面消息滚动
|
|
|
+ // 官网、移动端首页、工作桌面消息滚动
|
|
|
UserUnreadMsgList(ctx context.Context, in *UserUnreadMsgListReq, opts ...grpc.CallOption) (*UserUnreadMsgListRes, error)
|
|
|
}
|
|
|
|
|
@@ -67,7 +54,7 @@ func NewMessageClient(cc grpc.ClientConnInterface) MessageClient {
|
|
|
|
|
|
func (c *messageClient) MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error) {
|
|
|
out := new(MultipleSaveMsgResp)
|
|
|
- err := c.cc.Invoke(ctx, Message_MultipleSaveMsg_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/multipleSaveMsg", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -76,7 +63,7 @@ func (c *messageClient) MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsg
|
|
|
|
|
|
func (c *messageClient) ChangeReadStatus(ctx context.Context, in *ChangeReadStatusReq, opts ...grpc.CallOption) (*Response, error) {
|
|
|
out := new(Response)
|
|
|
- err := c.cc.Invoke(ctx, Message_ChangeReadStatus_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/ChangeReadStatus", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -85,7 +72,7 @@ func (c *messageClient) ChangeReadStatus(ctx context.Context, in *ChangeReadStat
|
|
|
|
|
|
func (c *messageClient) FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error) {
|
|
|
out := new(FindUserMsgRes)
|
|
|
- err := c.cc.Invoke(ctx, Message_FindUserMsg_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/FindUserMsg", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -94,7 +81,7 @@ func (c *messageClient) FindUserMsg(ctx context.Context, in *FindUserMsgReq, opt
|
|
|
|
|
|
func (c *messageClient) FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error) {
|
|
|
out := new(MessageDetailResp)
|
|
|
- err := c.cc.Invoke(ctx, Message_FindMessageDetail_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/FindMessageDetail", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -103,7 +90,7 @@ func (c *messageClient) FindMessageDetail(ctx context.Context, in *MessageDetail
|
|
|
|
|
|
func (c *messageClient) GetMsgType(ctx context.Context, in *GetMsgTypeReq, opts ...grpc.CallOption) (*GetMsgTypeRes, error) {
|
|
|
out := new(GetMsgTypeRes)
|
|
|
- err := c.cc.Invoke(ctx, Message_GetMsgType_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/GetMsgType", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -112,7 +99,7 @@ func (c *messageClient) GetMsgType(ctx context.Context, in *GetMsgTypeReq, opts
|
|
|
|
|
|
func (c *messageClient) FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error) {
|
|
|
out := new(FindUserBuoyMsgRes)
|
|
|
- err := c.cc.Invoke(ctx, Message_FindUserBuoyMsg_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/FindUserBuoyMsg", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -121,7 +108,7 @@ func (c *messageClient) FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsg
|
|
|
|
|
|
func (c *messageClient) ClearUnreadMsg(ctx context.Context, in *ClearUnreadMsgReq, opts ...grpc.CallOption) (*Response, error) {
|
|
|
out := new(Response)
|
|
|
- err := c.cc.Invoke(ctx, Message_ClearUnreadMsg_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/ClearUnreadMsg", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -130,7 +117,7 @@ func (c *messageClient) ClearUnreadMsg(ctx context.Context, in *ClearUnreadMsgRe
|
|
|
|
|
|
func (c *messageClient) UserMsgList(ctx context.Context, in *UserMsgListReq, opts ...grpc.CallOption) (*UserMsgListRes, error) {
|
|
|
out := new(UserMsgListRes)
|
|
|
- err := c.cc.Invoke(ctx, Message_UserMsgList_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/UserMsgList", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -139,7 +126,7 @@ func (c *messageClient) UserMsgList(ctx context.Context, in *UserMsgListReq, opt
|
|
|
|
|
|
func (c *messageClient) SendWxTmplMsg(ctx context.Context, in *WxTmplMsgRequest, opts ...grpc.CallOption) (*SendMsgResponse, error) {
|
|
|
out := new(SendMsgResponse)
|
|
|
- err := c.cc.Invoke(ctx, Message_SendWxTmplMsg_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/SendWxTmplMsg", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -148,7 +135,7 @@ func (c *messageClient) SendWxTmplMsg(ctx context.Context, in *WxTmplMsgRequest,
|
|
|
|
|
|
func (c *messageClient) UserUnreadMsgList(ctx context.Context, in *UserUnreadMsgListReq, opts ...grpc.CallOption) (*UserUnreadMsgListRes, error) {
|
|
|
out := new(UserUnreadMsgListRes)
|
|
|
- err := c.cc.Invoke(ctx, Message_UserUnreadMsgList_FullMethodName, in, out, opts...)
|
|
|
+ err := c.cc.Invoke(ctx, "/message.Message/UserUnreadMsgList", in, out, opts...)
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
@@ -159,25 +146,25 @@ func (c *messageClient) UserUnreadMsgList(ctx context.Context, in *UserUnreadMsg
|
|
|
// All implementations must embed UnimplementedMessageServer
|
|
|
// for forward compatibility
|
|
|
type MessageServer interface {
|
|
|
- // 批量保存消息
|
|
|
+ //批量保存消息
|
|
|
MultipleSaveMsg(context.Context, *MultipleSaveMsgReq) (*MultipleSaveMsgResp, error)
|
|
|
// 修改消息阅读状态
|
|
|
ChangeReadStatus(context.Context, *ChangeReadStatusReq) (*Response, error)
|
|
|
- // 查询指定用户的历史消息记录
|
|
|
+ // 查询指定用户的历史消息记录
|
|
|
FindUserMsg(context.Context, *FindUserMsgReq) (*FindUserMsgRes, error)
|
|
|
- // 查看详细详情
|
|
|
+ //查看详细详情
|
|
|
FindMessageDetail(context.Context, *MessageDetailReq) (*MessageDetailResp, error)
|
|
|
- // 消息的分类
|
|
|
+ // 消息的分类
|
|
|
GetMsgType(context.Context, *GetMsgTypeReq) (*GetMsgTypeRes, error)
|
|
|
- // 查询指定用户的浮标消息
|
|
|
+ // 查询指定用户的浮标消息
|
|
|
FindUserBuoyMsg(context.Context, *FindUserBuoyMsgReq) (*FindUserBuoyMsgRes, error)
|
|
|
- // 一键清空未读消息
|
|
|
+ // 一键清空未读消息
|
|
|
ClearUnreadMsg(context.Context, *ClearUnreadMsgReq) (*Response, error)
|
|
|
- // new用户消息列表
|
|
|
+ // new用户消息列表
|
|
|
UserMsgList(context.Context, *UserMsgListReq) (*UserMsgListRes, error)
|
|
|
- // 发送剑鱼微信模版消息
|
|
|
+ // 发送剑鱼微信模版消息
|
|
|
SendWxTmplMsg(context.Context, *WxTmplMsgRequest) (*SendMsgResponse, error)
|
|
|
- // 官网、移动端首页、工作桌面消息滚动
|
|
|
+ // 官网、移动端首页、工作桌面消息滚动
|
|
|
UserUnreadMsgList(context.Context, *UserUnreadMsgListReq) (*UserUnreadMsgListRes, error)
|
|
|
mustEmbedUnimplementedMessageServer()
|
|
|
}
|
|
@@ -239,7 +226,7 @@ func _Message_MultipleSaveMsg_Handler(srv interface{}, ctx context.Context, dec
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_MultipleSaveMsg_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/multipleSaveMsg",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).MultipleSaveMsg(ctx, req.(*MultipleSaveMsgReq))
|
|
@@ -257,7 +244,7 @@ func _Message_ChangeReadStatus_Handler(srv interface{}, ctx context.Context, dec
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_ChangeReadStatus_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/ChangeReadStatus",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).ChangeReadStatus(ctx, req.(*ChangeReadStatusReq))
|
|
@@ -275,7 +262,7 @@ func _Message_FindUserMsg_Handler(srv interface{}, ctx context.Context, dec func
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_FindUserMsg_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/FindUserMsg",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).FindUserMsg(ctx, req.(*FindUserMsgReq))
|
|
@@ -293,7 +280,7 @@ func _Message_FindMessageDetail_Handler(srv interface{}, ctx context.Context, de
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_FindMessageDetail_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/FindMessageDetail",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).FindMessageDetail(ctx, req.(*MessageDetailReq))
|
|
@@ -311,7 +298,7 @@ func _Message_GetMsgType_Handler(srv interface{}, ctx context.Context, dec func(
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_GetMsgType_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/GetMsgType",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).GetMsgType(ctx, req.(*GetMsgTypeReq))
|
|
@@ -329,7 +316,7 @@ func _Message_FindUserBuoyMsg_Handler(srv interface{}, ctx context.Context, dec
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_FindUserBuoyMsg_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/FindUserBuoyMsg",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).FindUserBuoyMsg(ctx, req.(*FindUserBuoyMsgReq))
|
|
@@ -347,7 +334,7 @@ func _Message_ClearUnreadMsg_Handler(srv interface{}, ctx context.Context, dec f
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_ClearUnreadMsg_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/ClearUnreadMsg",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).ClearUnreadMsg(ctx, req.(*ClearUnreadMsgReq))
|
|
@@ -365,7 +352,7 @@ func _Message_UserMsgList_Handler(srv interface{}, ctx context.Context, dec func
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_UserMsgList_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/UserMsgList",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).UserMsgList(ctx, req.(*UserMsgListReq))
|
|
@@ -383,7 +370,7 @@ func _Message_SendWxTmplMsg_Handler(srv interface{}, ctx context.Context, dec fu
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_SendWxTmplMsg_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/SendWxTmplMsg",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).SendWxTmplMsg(ctx, req.(*WxTmplMsgRequest))
|
|
@@ -401,7 +388,7 @@ func _Message_UserUnreadMsgList_Handler(srv interface{}, ctx context.Context, de
|
|
|
}
|
|
|
info := &grpc.UnaryServerInfo{
|
|
|
Server: srv,
|
|
|
- FullMethod: Message_UserUnreadMsgList_FullMethodName,
|
|
|
+ FullMethod: "/message.Message/UserUnreadMsgList",
|
|
|
}
|
|
|
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
|
|
|
return srv.(MessageServer).UserUnreadMsgList(ctx, req.(*UserUnreadMsgListReq))
|