// Code generated by protoc-gen-go. DO NOT EDIT. // source: message.proto package message import ( context "context" fmt "fmt" proto "github.com/golang/protobuf/proto" grpc "google.golang.org/grpc" codes "google.golang.org/grpc/codes" status "google.golang.org/grpc/status" math "math" ) // Reference imports to suppress errors if they are not otherwise used. var _ = proto.Marshal var _ = fmt.Errorf var _ = math.Inf // This is a compile-time assertion to ensure that this generated file // is compatible with the proto package it is being compiled against. // A compilation error at this line likely means your copy of the // proto package needs to be updated. const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package type SendMsgRequest struct { ReceiveUserId string `protobuf:"bytes,1,opt,name=receiveUserId,proto3" json:"receiveUserId,omitempty"` ReceiveName string `protobuf:"bytes,2,opt,name=receiveName,proto3" json:"receiveName,omitempty"` SendUserId string `protobuf:"bytes,3,opt,name=sendUserId,proto3" json:"sendUserId,omitempty"` SendName string `protobuf:"bytes,4,opt,name=sendName,proto3" json:"sendName,omitempty"` Title string `protobuf:"bytes,5,opt,name=title,proto3" json:"title,omitempty"` Content string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` MsgType int64 `protobuf:"varint,7,opt,name=msgType,proto3" json:"msgType,omitempty"` Link string `protobuf:"bytes,8,opt,name=link,proto3" json:"link,omitempty"` CiteId int64 `protobuf:"varint,9,opt,name=citeId,proto3" json:"citeId,omitempty"` Appid string `protobuf:"bytes,10,opt,name=appid,proto3" json:"appid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *SendMsgRequest) Reset() { *m = SendMsgRequest{} } func (m *SendMsgRequest) String() string { return proto.CompactTextString(m) } func (*SendMsgRequest) ProtoMessage() {} func (*SendMsgRequest) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{0} } func (m *SendMsgRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_SendMsgRequest.Unmarshal(m, b) } func (m *SendMsgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_SendMsgRequest.Marshal(b, m, deterministic) } func (m *SendMsgRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_SendMsgRequest.Merge(m, src) } func (m *SendMsgRequest) XXX_Size() int { return xxx_messageInfo_SendMsgRequest.Size(m) } func (m *SendMsgRequest) XXX_DiscardUnknown() { xxx_messageInfo_SendMsgRequest.DiscardUnknown(m) } var xxx_messageInfo_SendMsgRequest proto.InternalMessageInfo func (m *SendMsgRequest) GetReceiveUserId() string { if m != nil { return m.ReceiveUserId } return "" } func (m *SendMsgRequest) GetReceiveName() string { if m != nil { return m.ReceiveName } return "" } func (m *SendMsgRequest) GetSendUserId() string { if m != nil { return m.SendUserId } return "" } func (m *SendMsgRequest) GetSendName() string { if m != nil { return m.SendName } return "" } func (m *SendMsgRequest) GetTitle() string { if m != nil { return m.Title } return "" } func (m *SendMsgRequest) GetContent() string { if m != nil { return m.Content } return "" } func (m *SendMsgRequest) GetMsgType() int64 { if m != nil { return m.MsgType } return 0 } func (m *SendMsgRequest) GetLink() string { if m != nil { return m.Link } return "" } func (m *SendMsgRequest) GetCiteId() int64 { if m != nil { return m.CiteId } return 0 } func (m *SendMsgRequest) GetAppid() string { if m != nil { return m.Appid } return "" } type ChangeReadStatusRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ReadStatus int64 `protobuf:"varint,2,opt,name=readStatus,proto3" json:"readStatus,omitempty"` Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ChangeReadStatusRequest) Reset() { *m = ChangeReadStatusRequest{} } func (m *ChangeReadStatusRequest) String() string { return proto.CompactTextString(m) } func (*ChangeReadStatusRequest) ProtoMessage() {} func (*ChangeReadStatusRequest) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{1} } func (m *ChangeReadStatusRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ChangeReadStatusRequest.Unmarshal(m, b) } func (m *ChangeReadStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ChangeReadStatusRequest.Marshal(b, m, deterministic) } func (m *ChangeReadStatusRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_ChangeReadStatusRequest.Merge(m, src) } func (m *ChangeReadStatusRequest) XXX_Size() int { return xxx_messageInfo_ChangeReadStatusRequest.Size(m) } func (m *ChangeReadStatusRequest) XXX_DiscardUnknown() { xxx_messageInfo_ChangeReadStatusRequest.DiscardUnknown(m) } var xxx_messageInfo_ChangeReadStatusRequest proto.InternalMessageInfo func (m *ChangeReadStatusRequest) GetId() string { if m != nil { return m.Id } return "" } func (m *ChangeReadStatusRequest) GetReadStatus() int64 { if m != nil { return m.ReadStatus } return 0 } func (m *ChangeReadStatusRequest) GetAppid() string { if m != nil { return m.Appid } return "" } type ResCount struct { MsgType int64 `protobuf:"varint,1,opt,name=msgType,proto3" json:"msgType,omitempty"` Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *ResCount) Reset() { *m = ResCount{} } func (m *ResCount) String() string { return proto.CompactTextString(m) } func (*ResCount) ProtoMessage() {} func (*ResCount) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{2} } func (m *ResCount) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_ResCount.Unmarshal(m, b) } func (m *ResCount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_ResCount.Marshal(b, m, deterministic) } func (m *ResCount) XXX_Merge(src proto.Message) { xxx_messageInfo_ResCount.Merge(m, src) } func (m *ResCount) XXX_Size() int { return xxx_messageInfo_ResCount.Size(m) } func (m *ResCount) XXX_DiscardUnknown() { xxx_messageInfo_ResCount.DiscardUnknown(m) } var xxx_messageInfo_ResCount proto.InternalMessageInfo func (m *ResCount) GetMsgType() int64 { if m != nil { return m.MsgType } return 0 } func (m *ResCount) GetCount() int64 { if m != nil { return m.Count } return 0 } // 删除单一消息 type DeleteSingleMessageRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *DeleteSingleMessageRequest) Reset() { *m = DeleteSingleMessageRequest{} } func (m *DeleteSingleMessageRequest) String() string { return proto.CompactTextString(m) } func (*DeleteSingleMessageRequest) ProtoMessage() {} func (*DeleteSingleMessageRequest) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{3} } func (m *DeleteSingleMessageRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DeleteSingleMessageRequest.Unmarshal(m, b) } func (m *DeleteSingleMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DeleteSingleMessageRequest.Marshal(b, m, deterministic) } func (m *DeleteSingleMessageRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_DeleteSingleMessageRequest.Merge(m, src) } func (m *DeleteSingleMessageRequest) XXX_Size() int { return xxx_messageInfo_DeleteSingleMessageRequest.Size(m) } func (m *DeleteSingleMessageRequest) XXX_DiscardUnknown() { xxx_messageInfo_DeleteSingleMessageRequest.DiscardUnknown(m) } var xxx_messageInfo_DeleteSingleMessageRequest proto.InternalMessageInfo func (m *DeleteSingleMessageRequest) GetId() string { if m != nil { return m.Id } return "" } func (m *DeleteSingleMessageRequest) GetAppid() string { if m != nil { return m.Appid } return "" } // 批量删除消息 type DeleteMultipleMessageRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *DeleteMultipleMessageRequest) Reset() { *m = DeleteMultipleMessageRequest{} } func (m *DeleteMultipleMessageRequest) String() string { return proto.CompactTextString(m) } func (*DeleteMultipleMessageRequest) ProtoMessage() {} func (*DeleteMultipleMessageRequest) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{4} } func (m *DeleteMultipleMessageRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_DeleteMultipleMessageRequest.Unmarshal(m, b) } func (m *DeleteMultipleMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_DeleteMultipleMessageRequest.Marshal(b, m, deterministic) } func (m *DeleteMultipleMessageRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_DeleteMultipleMessageRequest.Merge(m, src) } func (m *DeleteMultipleMessageRequest) XXX_Size() int { return xxx_messageInfo_DeleteMultipleMessageRequest.Size(m) } func (m *DeleteMultipleMessageRequest) XXX_DiscardUnknown() { xxx_messageInfo_DeleteMultipleMessageRequest.DiscardUnknown(m) } var xxx_messageInfo_DeleteMultipleMessageRequest proto.InternalMessageInfo func (m *DeleteMultipleMessageRequest) GetId() string { if m != nil { return m.Id } return "" } func (m *DeleteMultipleMessageRequest) GetAppid() string { if m != nil { return m.Appid } return "" } // 查询指定用户未读消息合计 type GetUnreadCountRequest struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` Appid string `protobuf:"bytes,2,opt,name=appid,proto3" json:"appid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetUnreadCountRequest) Reset() { *m = GetUnreadCountRequest{} } func (m *GetUnreadCountRequest) String() string { return proto.CompactTextString(m) } func (*GetUnreadCountRequest) ProtoMessage() {} func (*GetUnreadCountRequest) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{5} } func (m *GetUnreadCountRequest) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetUnreadCountRequest.Unmarshal(m, b) } func (m *GetUnreadCountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetUnreadCountRequest.Marshal(b, m, deterministic) } func (m *GetUnreadCountRequest) XXX_Merge(src proto.Message) { xxx_messageInfo_GetUnreadCountRequest.Merge(m, src) } func (m *GetUnreadCountRequest) XXX_Size() int { return xxx_messageInfo_GetUnreadCountRequest.Size(m) } func (m *GetUnreadCountRequest) XXX_DiscardUnknown() { xxx_messageInfo_GetUnreadCountRequest.DiscardUnknown(m) } var xxx_messageInfo_GetUnreadCountRequest proto.InternalMessageInfo func (m *GetUnreadCountRequest) GetUserId() string { if m != nil { return m.UserId } return "" } func (m *GetUnreadCountRequest) GetAppid() string { if m != nil { return m.Appid } return "" } type Response struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Response) Reset() { *m = Response{} } func (m *Response) String() string { return proto.CompactTextString(m) } func (*Response) ProtoMessage() {} func (*Response) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{6} } func (m *Response) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Response.Unmarshal(m, b) } func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Response.Marshal(b, m, deterministic) } func (m *Response) XXX_Merge(src proto.Message) { xxx_messageInfo_Response.Merge(m, src) } func (m *Response) XXX_Size() int { return xxx_messageInfo_Response.Size(m) } func (m *Response) XXX_DiscardUnknown() { xxx_messageInfo_Response.DiscardUnknown(m) } var xxx_messageInfo_Response proto.InternalMessageInfo func (m *Response) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *Response) GetMessage() string { if m != nil { return m.Message } return "" } type GetUnreadCountResponse struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Count int64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetUnreadCountResponse) Reset() { *m = GetUnreadCountResponse{} } func (m *GetUnreadCountResponse) String() string { return proto.CompactTextString(m) } func (*GetUnreadCountResponse) ProtoMessage() {} func (*GetUnreadCountResponse) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{7} } func (m *GetUnreadCountResponse) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetUnreadCountResponse.Unmarshal(m, b) } func (m *GetUnreadCountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetUnreadCountResponse.Marshal(b, m, deterministic) } func (m *GetUnreadCountResponse) XXX_Merge(src proto.Message) { xxx_messageInfo_GetUnreadCountResponse.Merge(m, src) } func (m *GetUnreadCountResponse) XXX_Size() int { return xxx_messageInfo_GetUnreadCountResponse.Size(m) } func (m *GetUnreadCountResponse) XXX_DiscardUnknown() { xxx_messageInfo_GetUnreadCountResponse.DiscardUnknown(m) } var xxx_messageInfo_GetUnreadCountResponse proto.InternalMessageInfo func (m *GetUnreadCountResponse) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *GetUnreadCountResponse) GetMessage() string { if m != nil { return m.Message } return "" } func (m *GetUnreadCountResponse) GetCount() int64 { if m != nil { return m.Count } return 0 } type FindUserMsgReq struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` ReceiveUserId string `protobuf:"bytes,2,opt,name=receiveUserId,proto3" json:"receiveUserId,omitempty"` Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` OffSet int64 `protobuf:"varint,4,opt,name=offSet,proto3" json:"offSet,omitempty"` PageSize int64 `protobuf:"varint,5,opt,name=pageSize,proto3" json:"pageSize,omitempty"` MsgType int64 `protobuf:"varint,6,opt,name=msgType,proto3" json:"msgType,omitempty"` Read int64 `protobuf:"varint,7,opt,name=read,proto3" json:"read,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *FindUserMsgReq) Reset() { *m = FindUserMsgReq{} } func (m *FindUserMsgReq) String() string { return proto.CompactTextString(m) } func (*FindUserMsgReq) ProtoMessage() {} func (*FindUserMsgReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{8} } func (m *FindUserMsgReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_FindUserMsgReq.Unmarshal(m, b) } func (m *FindUserMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_FindUserMsgReq.Marshal(b, m, deterministic) } func (m *FindUserMsgReq) XXX_Merge(src proto.Message) { xxx_messageInfo_FindUserMsgReq.Merge(m, src) } func (m *FindUserMsgReq) XXX_Size() int { return xxx_messageInfo_FindUserMsgReq.Size(m) } func (m *FindUserMsgReq) XXX_DiscardUnknown() { xxx_messageInfo_FindUserMsgReq.DiscardUnknown(m) } var xxx_messageInfo_FindUserMsgReq proto.InternalMessageInfo func (m *FindUserMsgReq) GetUserId() string { if m != nil { return m.UserId } return "" } func (m *FindUserMsgReq) GetReceiveUserId() string { if m != nil { return m.ReceiveUserId } return "" } func (m *FindUserMsgReq) GetAppid() string { if m != nil { return m.Appid } return "" } func (m *FindUserMsgReq) GetOffSet() int64 { if m != nil { return m.OffSet } return 0 } func (m *FindUserMsgReq) GetPageSize() int64 { if m != nil { return m.PageSize } return 0 } func (m *FindUserMsgReq) GetMsgType() int64 { if m != nil { return m.MsgType } return 0 } func (m *FindUserMsgReq) GetRead() int64 { if m != nil { return m.Read } return 0 } type Messages struct { ReceiveUserId string `protobuf:"bytes,1,opt,name=receiveUserId,proto3" json:"receiveUserId,omitempty"` ReceiveName string `protobuf:"bytes,2,opt,name=receiveName,proto3" json:"receiveName,omitempty"` SendUserId string `protobuf:"bytes,3,opt,name=sendUserId,proto3" json:"sendUserId,omitempty"` SendName string `protobuf:"bytes,4,opt,name=sendName,proto3" json:"sendName,omitempty"` Title string `protobuf:"bytes,5,opt,name=title,proto3" json:"title,omitempty"` Content string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` MsgType int64 `protobuf:"varint,7,opt,name=msgType,proto3" json:"msgType,omitempty"` Link string `protobuf:"bytes,8,opt,name=link,proto3" json:"link,omitempty"` CiteId int64 `protobuf:"varint,9,opt,name=citeId,proto3" json:"citeId,omitempty"` IsRead int64 `protobuf:"varint,10,opt,name=isRead,proto3" json:"isRead,omitempty"` Createtime string `protobuf:"bytes,11,opt,name=createtime,proto3" json:"createtime,omitempty"` Appid string `protobuf:"bytes,12,opt,name=appid,proto3" json:"appid,omitempty"` Id string `protobuf:"bytes,13,opt,name=id,proto3" json:"id,omitempty"` MsgLogId int64 `protobuf:"varint,14,opt,name=msgLogId,proto3" json:"msgLogId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *Messages) Reset() { *m = Messages{} } func (m *Messages) String() string { return proto.CompactTextString(m) } func (*Messages) ProtoMessage() {} func (*Messages) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{9} } func (m *Messages) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_Messages.Unmarshal(m, b) } func (m *Messages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_Messages.Marshal(b, m, deterministic) } func (m *Messages) XXX_Merge(src proto.Message) { xxx_messageInfo_Messages.Merge(m, src) } func (m *Messages) XXX_Size() int { return xxx_messageInfo_Messages.Size(m) } func (m *Messages) XXX_DiscardUnknown() { xxx_messageInfo_Messages.DiscardUnknown(m) } var xxx_messageInfo_Messages proto.InternalMessageInfo func (m *Messages) GetReceiveUserId() string { if m != nil { return m.ReceiveUserId } return "" } func (m *Messages) GetReceiveName() string { if m != nil { return m.ReceiveName } return "" } func (m *Messages) GetSendUserId() string { if m != nil { return m.SendUserId } return "" } func (m *Messages) GetSendName() string { if m != nil { return m.SendName } return "" } func (m *Messages) GetTitle() string { if m != nil { return m.Title } return "" } func (m *Messages) GetContent() string { if m != nil { return m.Content } return "" } func (m *Messages) GetMsgType() int64 { if m != nil { return m.MsgType } return 0 } func (m *Messages) GetLink() string { if m != nil { return m.Link } return "" } func (m *Messages) GetCiteId() int64 { if m != nil { return m.CiteId } return 0 } func (m *Messages) GetIsRead() int64 { if m != nil { return m.IsRead } return 0 } func (m *Messages) GetCreatetime() string { if m != nil { return m.Createtime } return "" } func (m *Messages) GetAppid() string { if m != nil { return m.Appid } return "" } func (m *Messages) GetId() string { if m != nil { return m.Id } return "" } func (m *Messages) GetMsgLogId() int64 { if m != nil { return m.MsgLogId } return 0 } type FindUserMsgRes struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Data []*Messages `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"` Count int64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *FindUserMsgRes) Reset() { *m = FindUserMsgRes{} } func (m *FindUserMsgRes) String() string { return proto.CompactTextString(m) } func (*FindUserMsgRes) ProtoMessage() {} func (*FindUserMsgRes) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{10} } func (m *FindUserMsgRes) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_FindUserMsgRes.Unmarshal(m, b) } func (m *FindUserMsgRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_FindUserMsgRes.Marshal(b, m, deterministic) } func (m *FindUserMsgRes) XXX_Merge(src proto.Message) { xxx_messageInfo_FindUserMsgRes.Merge(m, src) } func (m *FindUserMsgRes) XXX_Size() int { return xxx_messageInfo_FindUserMsgRes.Size(m) } func (m *FindUserMsgRes) XXX_DiscardUnknown() { xxx_messageInfo_FindUserMsgRes.DiscardUnknown(m) } var xxx_messageInfo_FindUserMsgRes proto.InternalMessageInfo func (m *FindUserMsgRes) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *FindUserMsgRes) GetMessage() string { if m != nil { return m.Message } return "" } func (m *FindUserMsgRes) GetData() []*Messages { if m != nil { return m.Data } return nil } func (m *FindUserMsgRes) GetCount() int64 { if m != nil { return m.Count } return 0 } type GetClassUnreadCountReq struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` MsgType int64 `protobuf:"varint,2,opt,name=msgType,proto3" json:"msgType,omitempty"` Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetClassUnreadCountReq) Reset() { *m = GetClassUnreadCountReq{} } func (m *GetClassUnreadCountReq) String() string { return proto.CompactTextString(m) } func (*GetClassUnreadCountReq) ProtoMessage() {} func (*GetClassUnreadCountReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{11} } func (m *GetClassUnreadCountReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetClassUnreadCountReq.Unmarshal(m, b) } func (m *GetClassUnreadCountReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetClassUnreadCountReq.Marshal(b, m, deterministic) } func (m *GetClassUnreadCountReq) XXX_Merge(src proto.Message) { xxx_messageInfo_GetClassUnreadCountReq.Merge(m, src) } func (m *GetClassUnreadCountReq) XXX_Size() int { return xxx_messageInfo_GetClassUnreadCountReq.Size(m) } func (m *GetClassUnreadCountReq) XXX_DiscardUnknown() { xxx_messageInfo_GetClassUnreadCountReq.DiscardUnknown(m) } var xxx_messageInfo_GetClassUnreadCountReq proto.InternalMessageInfo func (m *GetClassUnreadCountReq) GetUserId() string { if m != nil { return m.UserId } return "" } func (m *GetClassUnreadCountReq) GetMsgType() int64 { if m != nil { return m.MsgType } return 0 } func (m *GetClassUnreadCountReq) GetAppid() string { if m != nil { return m.Appid } return "" } //查看消息内容 type MessageDetailReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *MessageDetailReq) Reset() { *m = MessageDetailReq{} } func (m *MessageDetailReq) String() string { return proto.CompactTextString(m) } func (*MessageDetailReq) ProtoMessage() {} func (*MessageDetailReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{12} } func (m *MessageDetailReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_MessageDetailReq.Unmarshal(m, b) } func (m *MessageDetailReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_MessageDetailReq.Marshal(b, m, deterministic) } func (m *MessageDetailReq) XXX_Merge(src proto.Message) { xxx_messageInfo_MessageDetailReq.Merge(m, src) } func (m *MessageDetailReq) XXX_Size() int { return xxx_messageInfo_MessageDetailReq.Size(m) } func (m *MessageDetailReq) XXX_DiscardUnknown() { xxx_messageInfo_MessageDetailReq.DiscardUnknown(m) } var xxx_messageInfo_MessageDetailReq proto.InternalMessageInfo func (m *MessageDetailReq) GetId() string { if m != nil { return m.Id } return "" } type MessageDetailResp struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Data *Messages `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *MessageDetailResp) Reset() { *m = MessageDetailResp{} } func (m *MessageDetailResp) String() string { return proto.CompactTextString(m) } func (*MessageDetailResp) ProtoMessage() {} func (*MessageDetailResp) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{13} } func (m *MessageDetailResp) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_MessageDetailResp.Unmarshal(m, b) } func (m *MessageDetailResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_MessageDetailResp.Marshal(b, m, deterministic) } func (m *MessageDetailResp) XXX_Merge(src proto.Message) { xxx_messageInfo_MessageDetailResp.Merge(m, src) } func (m *MessageDetailResp) XXX_Size() int { return xxx_messageInfo_MessageDetailResp.Size(m) } func (m *MessageDetailResp) XXX_DiscardUnknown() { xxx_messageInfo_MessageDetailResp.DiscardUnknown(m) } var xxx_messageInfo_MessageDetailResp proto.InternalMessageInfo func (m *MessageDetailResp) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *MessageDetailResp) GetMessage() string { if m != nil { return m.Message } return "" } func (m *MessageDetailResp) GetData() *Messages { if m != nil { return m.Data } return nil } type GetLastMessageReq struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` MsgType int64 `protobuf:"varint,2,opt,name=msgType,proto3" json:"msgType,omitempty"` Appid string `protobuf:"bytes,3,opt,name=appid,proto3" json:"appid,omitempty"` IsRead int64 `protobuf:"varint,4,opt,name=isRead,proto3" json:"isRead,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetLastMessageReq) Reset() { *m = GetLastMessageReq{} } func (m *GetLastMessageReq) String() string { return proto.CompactTextString(m) } func (*GetLastMessageReq) ProtoMessage() {} func (*GetLastMessageReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{14} } func (m *GetLastMessageReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetLastMessageReq.Unmarshal(m, b) } func (m *GetLastMessageReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetLastMessageReq.Marshal(b, m, deterministic) } func (m *GetLastMessageReq) XXX_Merge(src proto.Message) { xxx_messageInfo_GetLastMessageReq.Merge(m, src) } func (m *GetLastMessageReq) XXX_Size() int { return xxx_messageInfo_GetLastMessageReq.Size(m) } func (m *GetLastMessageReq) XXX_DiscardUnknown() { xxx_messageInfo_GetLastMessageReq.DiscardUnknown(m) } var xxx_messageInfo_GetLastMessageReq proto.InternalMessageInfo func (m *GetLastMessageReq) GetUserId() string { if m != nil { return m.UserId } return "" } func (m *GetLastMessageReq) GetMsgType() int64 { if m != nil { return m.MsgType } return 0 } func (m *GetLastMessageReq) GetAppid() string { if m != nil { return m.Appid } return "" } func (m *GetLastMessageReq) GetIsRead() int64 { if m != nil { return m.IsRead } return 0 } type GetLastMessageRes struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Data *Messages `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetLastMessageRes) Reset() { *m = GetLastMessageRes{} } func (m *GetLastMessageRes) String() string { return proto.CompactTextString(m) } func (*GetLastMessageRes) ProtoMessage() {} func (*GetLastMessageRes) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{15} } func (m *GetLastMessageRes) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetLastMessageRes.Unmarshal(m, b) } func (m *GetLastMessageRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetLastMessageRes.Marshal(b, m, deterministic) } func (m *GetLastMessageRes) XXX_Merge(src proto.Message) { xxx_messageInfo_GetLastMessageRes.Merge(m, src) } func (m *GetLastMessageRes) XXX_Size() int { return xxx_messageInfo_GetLastMessageRes.Size(m) } func (m *GetLastMessageRes) XXX_DiscardUnknown() { xxx_messageInfo_GetLastMessageRes.DiscardUnknown(m) } var xxx_messageInfo_GetLastMessageRes proto.InternalMessageInfo func (m *GetLastMessageRes) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *GetLastMessageRes) GetMessage() string { if m != nil { return m.Message } return "" } func (m *GetLastMessageRes) GetData() *Messages { if m != nil { return m.Data } return nil } // 获取用户分类的的未读消息分类及数量 及分类下最新的消息 type GetUnreadClassCountReq struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` Appid string `protobuf:"bytes,2,opt,name=appid,proto3" json:"appid,omitempty"` NeedMsg bool `protobuf:"varint,3,opt,name=needMsg,proto3" json:"needMsg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetUnreadClassCountReq) Reset() { *m = GetUnreadClassCountReq{} } func (m *GetUnreadClassCountReq) String() string { return proto.CompactTextString(m) } func (*GetUnreadClassCountReq) ProtoMessage() {} func (*GetUnreadClassCountReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{16} } func (m *GetUnreadClassCountReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetUnreadClassCountReq.Unmarshal(m, b) } func (m *GetUnreadClassCountReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetUnreadClassCountReq.Marshal(b, m, deterministic) } func (m *GetUnreadClassCountReq) XXX_Merge(src proto.Message) { xxx_messageInfo_GetUnreadClassCountReq.Merge(m, src) } func (m *GetUnreadClassCountReq) XXX_Size() int { return xxx_messageInfo_GetUnreadClassCountReq.Size(m) } func (m *GetUnreadClassCountReq) XXX_DiscardUnknown() { xxx_messageInfo_GetUnreadClassCountReq.DiscardUnknown(m) } var xxx_messageInfo_GetUnreadClassCountReq proto.InternalMessageInfo func (m *GetUnreadClassCountReq) GetUserId() string { if m != nil { return m.UserId } return "" } func (m *GetUnreadClassCountReq) GetAppid() string { if m != nil { return m.Appid } return "" } func (m *GetUnreadClassCountReq) GetNeedMsg() bool { if m != nil { return m.NeedMsg } return false } type GetUnreadClassCountRes struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Data []*ResCount `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"` Info []*Messages `protobuf:"bytes,4,rep,name=info,proto3" json:"info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetUnreadClassCountRes) Reset() { *m = GetUnreadClassCountRes{} } func (m *GetUnreadClassCountRes) String() string { return proto.CompactTextString(m) } func (*GetUnreadClassCountRes) ProtoMessage() {} func (*GetUnreadClassCountRes) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{17} } func (m *GetUnreadClassCountRes) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetUnreadClassCountRes.Unmarshal(m, b) } func (m *GetUnreadClassCountRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetUnreadClassCountRes.Marshal(b, m, deterministic) } func (m *GetUnreadClassCountRes) XXX_Merge(src proto.Message) { xxx_messageInfo_GetUnreadClassCountRes.Merge(m, src) } func (m *GetUnreadClassCountRes) XXX_Size() int { return xxx_messageInfo_GetUnreadClassCountRes.Size(m) } func (m *GetUnreadClassCountRes) XXX_DiscardUnknown() { xxx_messageInfo_GetUnreadClassCountRes.DiscardUnknown(m) } var xxx_messageInfo_GetUnreadClassCountRes proto.InternalMessageInfo func (m *GetUnreadClassCountRes) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *GetUnreadClassCountRes) GetMessage() string { if m != nil { return m.Message } return "" } func (m *GetUnreadClassCountRes) GetData() []*ResCount { if m != nil { return m.Data } return nil } func (m *GetUnreadClassCountRes) GetInfo() []*Messages { if m != nil { return m.Info } return nil } type GetMsgTypeReq struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` Appid string `protobuf:"bytes,2,opt,name=appid,proto3" json:"appid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetMsgTypeReq) Reset() { *m = GetMsgTypeReq{} } func (m *GetMsgTypeReq) String() string { return proto.CompactTextString(m) } func (*GetMsgTypeReq) ProtoMessage() {} func (*GetMsgTypeReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{18} } func (m *GetMsgTypeReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetMsgTypeReq.Unmarshal(m, b) } func (m *GetMsgTypeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetMsgTypeReq.Marshal(b, m, deterministic) } func (m *GetMsgTypeReq) XXX_Merge(src proto.Message) { xxx_messageInfo_GetMsgTypeReq.Merge(m, src) } func (m *GetMsgTypeReq) XXX_Size() int { return xxx_messageInfo_GetMsgTypeReq.Size(m) } func (m *GetMsgTypeReq) XXX_DiscardUnknown() { xxx_messageInfo_GetMsgTypeReq.DiscardUnknown(m) } var xxx_messageInfo_GetMsgTypeReq proto.InternalMessageInfo func (m *GetMsgTypeReq) GetUserId() string { if m != nil { return m.UserId } return "" } func (m *GetMsgTypeReq) GetAppid() string { if m != nil { return m.Appid } return "" } type GetMsgTypeRes struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Data []int64 `protobuf:"varint,3,rep,packed,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *GetMsgTypeRes) Reset() { *m = GetMsgTypeRes{} } func (m *GetMsgTypeRes) String() string { return proto.CompactTextString(m) } func (*GetMsgTypeRes) ProtoMessage() {} func (*GetMsgTypeRes) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{19} } func (m *GetMsgTypeRes) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_GetMsgTypeRes.Unmarshal(m, b) } func (m *GetMsgTypeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_GetMsgTypeRes.Marshal(b, m, deterministic) } func (m *GetMsgTypeRes) XXX_Merge(src proto.Message) { xxx_messageInfo_GetMsgTypeRes.Merge(m, src) } func (m *GetMsgTypeRes) XXX_Size() int { return xxx_messageInfo_GetMsgTypeRes.Size(m) } func (m *GetMsgTypeRes) XXX_DiscardUnknown() { xxx_messageInfo_GetMsgTypeRes.DiscardUnknown(m) } var xxx_messageInfo_GetMsgTypeRes proto.InternalMessageInfo func (m *GetMsgTypeRes) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *GetMsgTypeRes) GetMessage() string { if m != nil { return m.Message } return "" } func (m *GetMsgTypeRes) GetData() []int64 { if m != nil { return m.Data } return nil } //更新分类下消息状态 已读、未读 type UpdateMessageReadReq struct { MsgType int64 `protobuf:"varint,1,opt,name=msgType,proto3" json:"msgType,omitempty"` ReceiveUserid string `protobuf:"bytes,2,opt,name=receiveUserid,proto3" json:"receiveUserid,omitempty"` AppId string `protobuf:"bytes,3,opt,name=appId,proto3" json:"appId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *UpdateMessageReadReq) Reset() { *m = UpdateMessageReadReq{} } func (m *UpdateMessageReadReq) String() string { return proto.CompactTextString(m) } func (*UpdateMessageReadReq) ProtoMessage() {} func (*UpdateMessageReadReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{20} } func (m *UpdateMessageReadReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_UpdateMessageReadReq.Unmarshal(m, b) } func (m *UpdateMessageReadReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_UpdateMessageReadReq.Marshal(b, m, deterministic) } func (m *UpdateMessageReadReq) XXX_Merge(src proto.Message) { xxx_messageInfo_UpdateMessageReadReq.Merge(m, src) } func (m *UpdateMessageReadReq) XXX_Size() int { return xxx_messageInfo_UpdateMessageReadReq.Size(m) } func (m *UpdateMessageReadReq) XXX_DiscardUnknown() { xxx_messageInfo_UpdateMessageReadReq.DiscardUnknown(m) } var xxx_messageInfo_UpdateMessageReadReq proto.InternalMessageInfo func (m *UpdateMessageReadReq) GetMsgType() int64 { if m != nil { return m.MsgType } return 0 } func (m *UpdateMessageReadReq) GetReceiveUserid() string { if m != nil { return m.ReceiveUserid } return "" } func (m *UpdateMessageReadReq) GetAppId() string { if m != nil { return m.AppId } return "" } type UpdateMessageReadResp struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Status int64 `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *UpdateMessageReadResp) Reset() { *m = UpdateMessageReadResp{} } func (m *UpdateMessageReadResp) String() string { return proto.CompactTextString(m) } func (*UpdateMessageReadResp) ProtoMessage() {} func (*UpdateMessageReadResp) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{21} } func (m *UpdateMessageReadResp) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_UpdateMessageReadResp.Unmarshal(m, b) } func (m *UpdateMessageReadResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_UpdateMessageReadResp.Marshal(b, m, deterministic) } func (m *UpdateMessageReadResp) XXX_Merge(src proto.Message) { xxx_messageInfo_UpdateMessageReadResp.Merge(m, src) } func (m *UpdateMessageReadResp) XXX_Size() int { return xxx_messageInfo_UpdateMessageReadResp.Size(m) } func (m *UpdateMessageReadResp) XXX_DiscardUnknown() { xxx_messageInfo_UpdateMessageReadResp.DiscardUnknown(m) } var xxx_messageInfo_UpdateMessageReadResp proto.InternalMessageInfo func (m *UpdateMessageReadResp) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *UpdateMessageReadResp) GetMessage() string { if m != nil { return m.Message } return "" } func (m *UpdateMessageReadResp) GetStatus() int64 { if m != nil { return m.Status } return 0 } type User struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` UserName string `protobuf:"bytes,2,opt,name=userName,proto3" json:"userName,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *User) Reset() { *m = User{} } func (m *User) String() string { return proto.CompactTextString(m) } func (*User) ProtoMessage() {} func (*User) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{22} } func (m *User) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_User.Unmarshal(m, b) } func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_User.Marshal(b, m, deterministic) } func (m *User) XXX_Merge(src proto.Message) { xxx_messageInfo_User.Merge(m, src) } func (m *User) XXX_Size() int { return xxx_messageInfo_User.Size(m) } func (m *User) XXX_DiscardUnknown() { xxx_messageInfo_User.DiscardUnknown(m) } var xxx_messageInfo_User proto.InternalMessageInfo func (m *User) GetUserId() string { if m != nil { return m.UserId } return "" } func (m *User) GetUserName() string { if m != nil { return m.UserName } return "" } type MultipleSaveMsgReq struct { UserIds string `protobuf:"bytes,1,opt,name=userIds,proto3" json:"userIds,omitempty"` UserNames string `protobuf:"bytes,2,opt,name=userNames,proto3" json:"userNames,omitempty"` SendUserId string `protobuf:"bytes,3,opt,name=sendUserId,proto3" json:"sendUserId,omitempty"` SendName string `protobuf:"bytes,4,opt,name=sendName,proto3" json:"sendName,omitempty"` Title string `protobuf:"bytes,5,opt,name=title,proto3" json:"title,omitempty"` Content string `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"` MsgType int64 `protobuf:"varint,7,opt,name=msgType,proto3" json:"msgType,omitempty"` Link string `protobuf:"bytes,8,opt,name=link,proto3" json:"link,omitempty"` CiteId int64 `protobuf:"varint,9,opt,name=citeId,proto3" json:"citeId,omitempty"` Appid string `protobuf:"bytes,10,opt,name=appid,proto3" json:"appid,omitempty"` MsgLogId int64 `protobuf:"varint,11,opt,name=msgLogId,proto3" json:"msgLogId,omitempty"` ShowBuoy int64 `protobuf:"varint,12,opt,name=showBuoy,proto3" json:"showBuoy,omitempty"` ShowContent string `protobuf:"bytes,13,opt,name=showContent,proto3" json:"showContent,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *MultipleSaveMsgReq) Reset() { *m = MultipleSaveMsgReq{} } func (m *MultipleSaveMsgReq) String() string { return proto.CompactTextString(m) } func (*MultipleSaveMsgReq) ProtoMessage() {} func (*MultipleSaveMsgReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{23} } func (m *MultipleSaveMsgReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_MultipleSaveMsgReq.Unmarshal(m, b) } func (m *MultipleSaveMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_MultipleSaveMsgReq.Marshal(b, m, deterministic) } func (m *MultipleSaveMsgReq) XXX_Merge(src proto.Message) { xxx_messageInfo_MultipleSaveMsgReq.Merge(m, src) } func (m *MultipleSaveMsgReq) XXX_Size() int { return xxx_messageInfo_MultipleSaveMsgReq.Size(m) } func (m *MultipleSaveMsgReq) XXX_DiscardUnknown() { xxx_messageInfo_MultipleSaveMsgReq.DiscardUnknown(m) } var xxx_messageInfo_MultipleSaveMsgReq proto.InternalMessageInfo func (m *MultipleSaveMsgReq) GetUserIds() string { if m != nil { return m.UserIds } return "" } func (m *MultipleSaveMsgReq) GetUserNames() string { if m != nil { return m.UserNames } return "" } func (m *MultipleSaveMsgReq) GetSendUserId() string { if m != nil { return m.SendUserId } return "" } func (m *MultipleSaveMsgReq) GetSendName() string { if m != nil { return m.SendName } return "" } func (m *MultipleSaveMsgReq) GetTitle() string { if m != nil { return m.Title } return "" } func (m *MultipleSaveMsgReq) GetContent() string { if m != nil { return m.Content } return "" } func (m *MultipleSaveMsgReq) GetMsgType() int64 { if m != nil { return m.MsgType } return 0 } func (m *MultipleSaveMsgReq) GetLink() string { if m != nil { return m.Link } return "" } func (m *MultipleSaveMsgReq) GetCiteId() int64 { if m != nil { return m.CiteId } return 0 } func (m *MultipleSaveMsgReq) GetAppid() string { if m != nil { return m.Appid } return "" } func (m *MultipleSaveMsgReq) GetMsgLogId() int64 { if m != nil { return m.MsgLogId } return 0 } func (m *MultipleSaveMsgReq) GetShowBuoy() int64 { if m != nil { return m.ShowBuoy } return 0 } func (m *MultipleSaveMsgReq) GetShowContent() string { if m != nil { return m.ShowContent } return "" } type MultipleSaveMsgResp struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` ErrCount int64 `protobuf:"varint,3,opt,name=errCount,proto3" json:"errCount,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *MultipleSaveMsgResp) Reset() { *m = MultipleSaveMsgResp{} } func (m *MultipleSaveMsgResp) String() string { return proto.CompactTextString(m) } func (*MultipleSaveMsgResp) ProtoMessage() {} func (*MultipleSaveMsgResp) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{24} } func (m *MultipleSaveMsgResp) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_MultipleSaveMsgResp.Unmarshal(m, b) } func (m *MultipleSaveMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_MultipleSaveMsgResp.Marshal(b, m, deterministic) } func (m *MultipleSaveMsgResp) XXX_Merge(src proto.Message) { xxx_messageInfo_MultipleSaveMsgResp.Merge(m, src) } func (m *MultipleSaveMsgResp) XXX_Size() int { return xxx_messageInfo_MultipleSaveMsgResp.Size(m) } func (m *MultipleSaveMsgResp) XXX_DiscardUnknown() { xxx_messageInfo_MultipleSaveMsgResp.DiscardUnknown(m) } var xxx_messageInfo_MultipleSaveMsgResp proto.InternalMessageInfo func (m *MultipleSaveMsgResp) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *MultipleSaveMsgResp) GetMessage() string { if m != nil { return m.Message } return "" } func (m *MultipleSaveMsgResp) GetErrCount() int64 { if m != nil { return m.ErrCount } return 0 } type FindUserBuoyMsgReq struct { UserId string `protobuf:"bytes,1,opt,name=userId,proto3" json:"userId,omitempty"` Appid string `protobuf:"bytes,2,opt,name=appid,proto3" json:"appid,omitempty"` PageSize int64 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *FindUserBuoyMsgReq) Reset() { *m = FindUserBuoyMsgReq{} } func (m *FindUserBuoyMsgReq) String() string { return proto.CompactTextString(m) } func (*FindUserBuoyMsgReq) ProtoMessage() {} func (*FindUserBuoyMsgReq) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{25} } func (m *FindUserBuoyMsgReq) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_FindUserBuoyMsgReq.Unmarshal(m, b) } func (m *FindUserBuoyMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_FindUserBuoyMsgReq.Marshal(b, m, deterministic) } func (m *FindUserBuoyMsgReq) XXX_Merge(src proto.Message) { xxx_messageInfo_FindUserBuoyMsgReq.Merge(m, src) } func (m *FindUserBuoyMsgReq) XXX_Size() int { return xxx_messageInfo_FindUserBuoyMsgReq.Size(m) } func (m *FindUserBuoyMsgReq) XXX_DiscardUnknown() { xxx_messageInfo_FindUserBuoyMsgReq.DiscardUnknown(m) } var xxx_messageInfo_FindUserBuoyMsgReq proto.InternalMessageInfo func (m *FindUserBuoyMsgReq) GetUserId() string { if m != nil { return m.UserId } return "" } func (m *FindUserBuoyMsgReq) GetAppid() string { if m != nil { return m.Appid } return "" } func (m *FindUserBuoyMsgReq) GetPageSize() int64 { if m != nil { return m.PageSize } return 0 } type FindUserBuoyMsgRes struct { Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Data []*BuoyMessages `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *FindUserBuoyMsgRes) Reset() { *m = FindUserBuoyMsgRes{} } func (m *FindUserBuoyMsgRes) String() string { return proto.CompactTextString(m) } func (*FindUserBuoyMsgRes) ProtoMessage() {} func (*FindUserBuoyMsgRes) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{26} } func (m *FindUserBuoyMsgRes) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_FindUserBuoyMsgRes.Unmarshal(m, b) } func (m *FindUserBuoyMsgRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_FindUserBuoyMsgRes.Marshal(b, m, deterministic) } func (m *FindUserBuoyMsgRes) XXX_Merge(src proto.Message) { xxx_messageInfo_FindUserBuoyMsgRes.Merge(m, src) } func (m *FindUserBuoyMsgRes) XXX_Size() int { return xxx_messageInfo_FindUserBuoyMsgRes.Size(m) } func (m *FindUserBuoyMsgRes) XXX_DiscardUnknown() { xxx_messageInfo_FindUserBuoyMsgRes.DiscardUnknown(m) } var xxx_messageInfo_FindUserBuoyMsgRes proto.InternalMessageInfo func (m *FindUserBuoyMsgRes) GetCode() int64 { if m != nil { return m.Code } return 0 } func (m *FindUserBuoyMsgRes) GetMessage() string { if m != nil { return m.Message } return "" } func (m *FindUserBuoyMsgRes) GetData() []*BuoyMessages { if m != nil { return m.Data } return nil } type BuoyMessages struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` BuoyDetail string `protobuf:"bytes,2,opt,name=buoy_detail,json=buoyDetail,proto3" json:"buoy_detail,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` } func (m *BuoyMessages) Reset() { *m = BuoyMessages{} } func (m *BuoyMessages) String() string { return proto.CompactTextString(m) } func (*BuoyMessages) ProtoMessage() {} func (*BuoyMessages) Descriptor() ([]byte, []int) { return fileDescriptor_33c57e4bae7b9afd, []int{27} } func (m *BuoyMessages) XXX_Unmarshal(b []byte) error { return xxx_messageInfo_BuoyMessages.Unmarshal(m, b) } func (m *BuoyMessages) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { return xxx_messageInfo_BuoyMessages.Marshal(b, m, deterministic) } func (m *BuoyMessages) XXX_Merge(src proto.Message) { xxx_messageInfo_BuoyMessages.Merge(m, src) } func (m *BuoyMessages) XXX_Size() int { return xxx_messageInfo_BuoyMessages.Size(m) } func (m *BuoyMessages) XXX_DiscardUnknown() { xxx_messageInfo_BuoyMessages.DiscardUnknown(m) } var xxx_messageInfo_BuoyMessages proto.InternalMessageInfo func (m *BuoyMessages) GetId() string { if m != nil { return m.Id } return "" } func (m *BuoyMessages) GetBuoyDetail() string { if m != nil { return m.BuoyDetail } return "" } func init() { proto.RegisterType((*SendMsgRequest)(nil), "message.SendMsgRequest") proto.RegisterType((*ChangeReadStatusRequest)(nil), "message.ChangeReadStatusRequest") proto.RegisterType((*ResCount)(nil), "message.ResCount") proto.RegisterType((*DeleteSingleMessageRequest)(nil), "message.DeleteSingleMessageRequest") proto.RegisterType((*DeleteMultipleMessageRequest)(nil), "message.DeleteMultipleMessageRequest") proto.RegisterType((*GetUnreadCountRequest)(nil), "message.GetUnreadCountRequest") proto.RegisterType((*Response)(nil), "message.Response") proto.RegisterType((*GetUnreadCountResponse)(nil), "message.GetUnreadCountResponse") proto.RegisterType((*FindUserMsgReq)(nil), "message.FindUserMsgReq") proto.RegisterType((*Messages)(nil), "message.Messages") proto.RegisterType((*FindUserMsgRes)(nil), "message.FindUserMsgRes") proto.RegisterType((*GetClassUnreadCountReq)(nil), "message.GetClassUnreadCountReq") proto.RegisterType((*MessageDetailReq)(nil), "message.MessageDetailReq") proto.RegisterType((*MessageDetailResp)(nil), "message.MessageDetailResp") proto.RegisterType((*GetLastMessageReq)(nil), "message.GetLastMessageReq") proto.RegisterType((*GetLastMessageRes)(nil), "message.GetLastMessageRes") proto.RegisterType((*GetUnreadClassCountReq)(nil), "message.GetUnreadClassCountReq") proto.RegisterType((*GetUnreadClassCountRes)(nil), "message.GetUnreadClassCountRes") proto.RegisterType((*GetMsgTypeReq)(nil), "message.GetMsgTypeReq") proto.RegisterType((*GetMsgTypeRes)(nil), "message.GetMsgTypeRes") proto.RegisterType((*UpdateMessageReadReq)(nil), "message.UpdateMessageReadReq") proto.RegisterType((*UpdateMessageReadResp)(nil), "message.UpdateMessageReadResp") proto.RegisterType((*User)(nil), "message.user") proto.RegisterType((*MultipleSaveMsgReq)(nil), "message.multipleSaveMsgReq") proto.RegisterType((*MultipleSaveMsgResp)(nil), "message.multipleSaveMsgResp") proto.RegisterType((*FindUserBuoyMsgReq)(nil), "message.FindUserBuoyMsgReq") proto.RegisterType((*FindUserBuoyMsgRes)(nil), "message.FindUserBuoyMsgRes") proto.RegisterType((*BuoyMessages)(nil), "message.BuoyMessages") } func init() { proto.RegisterFile("message.proto", fileDescriptor_33c57e4bae7b9afd) } var fileDescriptor_33c57e4bae7b9afd = []byte{ // 1123 bytes of a gzipped FileDescriptorProto 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe4, 0x58, 0xef, 0x6e, 0xe3, 0x44, 0x10, 0x57, 0xe2, 0x34, 0x49, 0x27, 0xd7, 0xdc, 0x65, 0xdb, 0xe6, 0x8c, 0x29, 0xbd, 0xc8, 0x50, 0xa9, 0x7c, 0xb9, 0x0f, 0xc7, 0x17, 0x38, 0x81, 0x4e, 0xba, 0x14, 0x4a, 0xa0, 0x41, 0x3a, 0x87, 0x8a, 0x2f, 0x40, 0xcf, 0x17, 0x4f, 0x53, 0x8b, 0xc4, 0x36, 0xd9, 0xcd, 0xa1, 0xc2, 0x6b, 0xf0, 0x00, 0x3c, 0x06, 0x4f, 0xc0, 0xe3, 0xf0, 0x08, 0x08, 0xed, 0x1f, 0xdb, 0x6b, 0x67, 0xdd, 0x2a, 0xd5, 0xf1, 0x85, 0xfb, 0xe6, 0x99, 0x9d, 0x9d, 0xd9, 0x99, 0x9d, 0x3f, 0xbf, 0x35, 0xec, 0x2c, 0x90, 0x52, 0x7f, 0x86, 0x8f, 0x93, 0x65, 0xcc, 0x62, 0xd2, 0x52, 0xa4, 0xfb, 0x47, 0x1d, 0xba, 0x13, 0x8c, 0x82, 0x31, 0x9d, 0x79, 0xf8, 0xf3, 0x0a, 0x29, 0x23, 0x1f, 0xc0, 0xce, 0x12, 0xa7, 0x18, 0xbe, 0xc6, 0x73, 0x8a, 0xcb, 0x51, 0x60, 0xd7, 0x06, 0xb5, 0xe3, 0x6d, 0xaf, 0xc8, 0x24, 0x03, 0xe8, 0x28, 0xc6, 0x37, 0xfe, 0x02, 0xed, 0xba, 0x90, 0xd1, 0x59, 0xe4, 0x10, 0x80, 0x62, 0x14, 0x28, 0x25, 0x96, 0x10, 0xd0, 0x38, 0xc4, 0x81, 0x36, 0xa7, 0xc4, 0xf6, 0x86, 0x58, 0xcd, 0x68, 0xb2, 0x07, 0x5b, 0x2c, 0x64, 0x73, 0xb4, 0xb7, 0xc4, 0x82, 0x24, 0x88, 0x0d, 0xad, 0x69, 0x1c, 0x31, 0x8c, 0x98, 0xdd, 0x14, 0xfc, 0x94, 0xe4, 0x2b, 0x0b, 0x3a, 0xfb, 0xf6, 0x3a, 0x41, 0xbb, 0x35, 0xa8, 0x1d, 0x5b, 0x5e, 0x4a, 0x12, 0x02, 0x8d, 0x79, 0x18, 0xfd, 0x64, 0xb7, 0xc5, 0x06, 0xf1, 0x4d, 0xfa, 0xd0, 0x9c, 0x86, 0x0c, 0x47, 0x81, 0xbd, 0x2d, 0x84, 0x15, 0xc5, 0xad, 0xfa, 0x49, 0x12, 0x06, 0x36, 0x48, 0xab, 0x82, 0x70, 0x2f, 0xe0, 0xe1, 0xf0, 0xca, 0x8f, 0x66, 0xe8, 0xa1, 0x1f, 0x4c, 0x98, 0xcf, 0x56, 0x34, 0x0d, 0x55, 0x17, 0xea, 0x61, 0x1a, 0x9f, 0x7a, 0x18, 0x70, 0x97, 0x97, 0x99, 0x90, 0x88, 0x89, 0xe5, 0x69, 0x9c, 0xdc, 0x80, 0xa5, 0x1b, 0x78, 0x0a, 0x6d, 0x0f, 0xe9, 0x30, 0x5e, 0x15, 0x1d, 0xa9, 0x15, 0x1d, 0xd9, 0x83, 0xad, 0x29, 0x17, 0x51, 0x6a, 0x25, 0xe1, 0x3e, 0x07, 0xe7, 0x04, 0xe7, 0xc8, 0x70, 0x12, 0x46, 0xb3, 0x39, 0x8e, 0xe5, 0xb5, 0x56, 0x9d, 0xcf, 0x6c, 0xff, 0x04, 0x0e, 0xa4, 0x8e, 0xf1, 0x6a, 0xce, 0xc2, 0xe4, 0x8e, 0x5a, 0x3e, 0x87, 0xfd, 0x53, 0x64, 0xe7, 0x11, 0x77, 0x57, 0xf8, 0x92, 0x6e, 0xef, 0x43, 0x73, 0xa5, 0x27, 0x92, 0xa2, 0x72, 0x35, 0x75, 0x5d, 0xcd, 0xc7, 0x22, 0x18, 0x49, 0x1c, 0x51, 0x71, 0x77, 0xd3, 0x38, 0x48, 0x23, 0x21, 0xbe, 0x45, 0x80, 0xe4, 0xf1, 0xd4, 0xbe, 0x2c, 0x95, 0xbf, 0x87, 0x7e, 0xf9, 0x00, 0x77, 0xd1, 0x93, 0x07, 0xda, 0xd2, 0x03, 0xfd, 0x57, 0x0d, 0xba, 0x5f, 0x84, 0x32, 0x79, 0x65, 0xb1, 0x54, 0x3a, 0xb6, 0x56, 0x40, 0x75, 0x53, 0x01, 0x19, 0xa3, 0xc8, 0x75, 0xc6, 0x97, 0x97, 0x13, 0x64, 0xa2, 0x24, 0x2c, 0x4f, 0x51, 0xbc, 0x58, 0x12, 0x7f, 0x86, 0x93, 0xf0, 0x57, 0x59, 0x13, 0x96, 0x97, 0xd1, 0x7a, 0xce, 0x34, 0xd7, 0x92, 0x9f, 0x47, 0x43, 0xd5, 0x84, 0xf8, 0x76, 0xff, 0xa9, 0x43, 0x5b, 0x5d, 0x30, 0x7d, 0x8b, 0x6b, 0xbd, 0x0f, 0xcd, 0x90, 0xf2, 0x8a, 0x16, 0xc5, 0x6e, 0x79, 0x8a, 0xe2, 0x9e, 0x4c, 0x97, 0xe8, 0x33, 0x64, 0xe1, 0x02, 0xed, 0x8e, 0xf4, 0x24, 0xe7, 0xe4, 0xd7, 0x76, 0x4f, 0xbf, 0x36, 0x59, 0x22, 0x3b, 0x59, 0x89, 0x38, 0xd0, 0x5e, 0xd0, 0xd9, 0x59, 0x3c, 0x1b, 0x05, 0x76, 0x57, 0x5e, 0x57, 0x4a, 0xbb, 0xbf, 0x95, 0x12, 0x89, 0x6e, 0x98, 0x9f, 0x47, 0xd0, 0x08, 0x7c, 0xe6, 0xdb, 0xd6, 0xc0, 0x3a, 0xee, 0x3c, 0xe9, 0x3d, 0x4e, 0x3b, 0x7b, 0x7a, 0xa9, 0x9e, 0x58, 0xce, 0xd3, 0xb8, 0xa1, 0xa7, 0xf1, 0x4b, 0x51, 0x24, 0xc3, 0xb9, 0x4f, 0x69, 0xb1, 0x54, 0x2b, 0xb3, 0x59, 0x0b, 0x77, 0x7d, 0xad, 0x23, 0x19, 0xfa, 0x80, 0x0b, 0x0f, 0xd4, 0x49, 0x4e, 0x90, 0xf9, 0xe1, 0x9c, 0xeb, 0x2e, 0x75, 0x10, 0xf7, 0x0a, 0x7a, 0x25, 0x19, 0x9a, 0xdc, 0x39, 0x0a, 0xb5, 0x1b, 0xa2, 0xe0, 0x52, 0xe8, 0x9d, 0x22, 0x3b, 0xf3, 0x29, 0xcb, 0x9b, 0xda, 0x9b, 0x72, 0x55, 0xcb, 0xa1, 0x86, 0x9e, 0x43, 0xdc, 0xbd, 0xb2, 0x51, 0xfa, 0xdf, 0xb8, 0xf7, 0x52, 0xef, 0x79, 0xfc, 0x52, 0x6f, 0xbd, 0x4e, 0x63, 0xd7, 0xe5, 0x07, 0x89, 0x10, 0x39, 0x0a, 0x10, 0x16, 0xdb, 0x5e, 0x4a, 0xba, 0xbf, 0xd7, 0x2a, 0x4c, 0xbc, 0xa9, 0xb4, 0x4d, 0x47, 0x9f, 0x4a, 0xdb, 0x23, 0x68, 0x84, 0xd1, 0x65, 0x6c, 0x37, 0x2a, 0xb3, 0x9b, 0x2f, 0xbb, 0x9f, 0xc1, 0xce, 0x29, 0xb2, 0xb1, 0xbc, 0x9e, 0x8d, 0xfd, 0x75, 0x5f, 0x14, 0xb7, 0x6f, 0xea, 0x0b, 0xd1, 0x7c, 0xb1, 0xd4, 0x55, 0xcc, 0x61, 0xef, 0x3c, 0x09, 0x7c, 0x96, 0x4f, 0x4f, 0x3f, 0xe0, 0x07, 0xab, 0x9e, 0xe8, 0xc5, 0xe6, 0x1b, 0x9a, 0xe6, 0x44, 0x36, 0x6d, 0x47, 0x7a, 0xea, 0x8d, 0x02, 0xf7, 0x07, 0xd8, 0x37, 0x58, 0xdb, 0xb8, 0x8a, 0xfa, 0xd0, 0xa4, 0x12, 0xac, 0xc8, 0x61, 0xa7, 0x28, 0xf7, 0x29, 0x34, 0x78, 0xfc, 0x2a, 0xa3, 0xea, 0x40, 0x9b, 0x7f, 0x69, 0xe3, 0x20, 0xa3, 0xdd, 0xbf, 0xeb, 0x40, 0x16, 0x0a, 0x49, 0x4c, 0xfc, 0xd7, 0xa8, 0xa6, 0xa5, 0x0d, 0x2d, 0xb9, 0x99, 0x2a, 0x5d, 0x29, 0x49, 0x0e, 0x60, 0x3b, 0xdd, 0x4c, 0x95, 0xb6, 0x9c, 0xf1, 0x7f, 0x81, 0x91, 0x85, 0x91, 0xd0, 0x29, 0x8e, 0x04, 0xe1, 0xc3, 0x55, 0xfc, 0xcb, 0xf3, 0x55, 0x7c, 0x2d, 0xe6, 0x8a, 0xe5, 0x65, 0x34, 0x1f, 0xbe, 0xfc, 0x7b, 0xa8, 0x4e, 0x2c, 0x67, 0x8c, 0xce, 0x72, 0x2f, 0x60, 0x77, 0x2d, 0xde, 0x1b, 0x67, 0x82, 0x03, 0x6d, 0x5c, 0x2e, 0x87, 0x1a, 0xf0, 0xc9, 0x68, 0xf7, 0x47, 0x20, 0xe9, 0xc4, 0xe2, 0x47, 0xba, 0x05, 0xfe, 0x98, 0x3b, 0x8c, 0x0e, 0x60, 0xac, 0x22, 0x80, 0x71, 0x17, 0x06, 0xfd, 0x9b, 0x96, 0xe4, 0x87, 0x85, 0xf6, 0xb2, 0x9f, 0xf5, 0x0d, 0xa1, 0xb0, 0xd8, 0x34, 0x9f, 0xc1, 0x3d, 0x9d, 0xbb, 0x86, 0x6f, 0x1f, 0x41, 0xe7, 0xd5, 0x2a, 0xbe, 0xbe, 0x08, 0xc4, 0x6c, 0x52, 0x86, 0x80, 0xb3, 0xe4, 0xb4, 0x7a, 0xf2, 0x67, 0x1b, 0x5a, 0x6a, 0x37, 0x39, 0x83, 0xfb, 0xa5, 0xe0, 0x93, 0x77, 0x33, 0xe3, 0xeb, 0x65, 0xe0, 0x1c, 0x54, 0x2f, 0xd2, 0x84, 0x9c, 0xc2, 0x83, 0xf2, 0x5b, 0x83, 0x0c, 0xb2, 0x1d, 0x15, 0xcf, 0x10, 0xa7, 0xd0, 0x4c, 0x25, 0xe4, 0xfd, 0x04, 0x3a, 0x13, 0xcc, 0x40, 0x06, 0x79, 0x98, 0x49, 0x14, 0x1f, 0x7b, 0xa6, 0xad, 0x63, 0xd8, 0x35, 0x3c, 0x29, 0xc8, 0xfb, 0x99, 0x64, 0xf5, 0x83, 0xc3, 0xa4, 0xee, 0x05, 0xec, 0x1b, 0x5f, 0x17, 0xe4, 0xa8, 0xa4, 0xd0, 0xfc, 0xfa, 0x30, 0xab, 0xec, 0x16, 0x91, 0x3e, 0x39, 0xcc, 0x84, 0x8c, 0x6f, 0x10, 0xe7, 0x51, 0xe5, 0xba, 0x52, 0xf9, 0x0c, 0x3a, 0x1a, 0x28, 0xd3, 0xe2, 0x55, 0xc4, 0xfc, 0x4e, 0xc5, 0x02, 0x25, 0xdf, 0xc1, 0xae, 0x01, 0x58, 0x91, 0x82, 0x61, 0x03, 0xec, 0xba, 0xfd, 0x64, 0x5f, 0x0a, 0x67, 0x35, 0x30, 0x41, 0x1c, 0x7d, 0x4b, 0x11, 0xda, 0x38, 0xd5, 0x6b, 0x94, 0x7c, 0x05, 0x3d, 0x7e, 0xe8, 0x02, 0xf2, 0x22, 0xef, 0x94, 0x27, 0x6c, 0x86, 0xda, 0x34, 0x5d, 0xeb, 0x60, 0x4d, 0xba, 0x5b, 0x46, 0x05, 0xc4, 0xe4, 0x8d, 0x0e, 0x4b, 0x9c, 0x5b, 0x04, 0x28, 0xf9, 0x14, 0x20, 0x9f, 0xcc, 0xa4, 0xaf, 0x8b, 0xe7, 0xd3, 0xde, 0x31, 0xf3, 0x29, 0xf1, 0xa0, 0xb7, 0x36, 0x16, 0xc9, 0x7b, 0x99, 0xb0, 0x69, 0x40, 0x3b, 0x87, 0x37, 0x2d, 0xd3, 0x84, 0x7c, 0x0d, 0xf7, 0x4b, 0xdd, 0x49, 0xab, 0xf0, 0xf5, 0xbe, 0xe8, 0xdc, 0xb0, 0x48, 0x5f, 0x35, 0xc5, 0xff, 0x97, 0x8f, 0xfe, 0x0d, 0x00, 0x00, 0xff, 0xff, 0xbf, 0x98, 0xf5, 0x70, 0x90, 0x11, 0x00, 0x00, } // Reference imports to suppress errors if they are not otherwise used. var _ context.Context var _ grpc.ClientConn // This is a compile-time assertion to ensure that this generated file // is compatible with the grpc package it is being compiled against. const _ = grpc.SupportPackageIsVersion4 // MessageClient is the client API for Message service. // // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. type MessageClient interface { //批量保存消息 MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error) // 修改消息阅读状态 ChangeReadStatus(ctx context.Context, in *ChangeReadStatusRequest, opts ...grpc.CallOption) (*Response, error) //指定用户发消息 SendUserMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*Response, error) // 删除单一消息 DeleteSingleMessage(ctx context.Context, in *DeleteSingleMessageRequest, opts ...grpc.CallOption) (*Response, error) // 删除多条消息 DeleteMultipleMessage(ctx context.Context, in *DeleteMultipleMessageRequest, opts ...grpc.CallOption) (*Response, error) // 查询指定用户未读消息合计 GetUnreadCount(ctx context.Context, in *GetUnreadCountRequest, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) // 查询指定用户的历史消息记录 FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error) // 查询指定用户指定分类的未读消息合计 GetClassUnreadCount(ctx context.Context, in *GetClassUnreadCountReq, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) // 获取指定用户指定分类的最新一条消息 GetLastMessage(ctx context.Context, in *GetLastMessageReq, opts ...grpc.CallOption) (*GetLastMessageRes, error) //查看详细详情 FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error) // 获取指定用户的分类及未读消息数量 GetUnreadClassCount(ctx context.Context, in *GetUnreadClassCountReq, opts ...grpc.CallOption) (*GetUnreadClassCountRes, error) // 获取指定用户收到消息的分类 GetMsgType(ctx context.Context, in *GetMsgTypeReq, opts ...grpc.CallOption) (*GetMsgTypeRes, error) //修改用户指定分类下的消息已读未读 UpdateMessageRead(ctx context.Context, in *UpdateMessageReadReq, opts ...grpc.CallOption) (*UpdateMessageReadResp, error) // 查询指定用户的浮标消息 FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error) } type messageClient struct { cc *grpc.ClientConn } func NewMessageClient(cc *grpc.ClientConn) MessageClient { return &messageClient{cc} } func (c *messageClient) MultipleSaveMsg(ctx context.Context, in *MultipleSaveMsgReq, opts ...grpc.CallOption) (*MultipleSaveMsgResp, error) { out := new(MultipleSaveMsgResp) err := c.cc.Invoke(ctx, "/message.Message/multipleSaveMsg", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) ChangeReadStatus(ctx context.Context, in *ChangeReadStatusRequest, opts ...grpc.CallOption) (*Response, error) { out := new(Response) err := c.cc.Invoke(ctx, "/message.Message/ChangeReadStatus", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) SendUserMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*Response, error) { out := new(Response) err := c.cc.Invoke(ctx, "/message.Message/SendUserMsg", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) DeleteSingleMessage(ctx context.Context, in *DeleteSingleMessageRequest, opts ...grpc.CallOption) (*Response, error) { out := new(Response) err := c.cc.Invoke(ctx, "/message.Message/DeleteSingleMessage", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) DeleteMultipleMessage(ctx context.Context, in *DeleteMultipleMessageRequest, opts ...grpc.CallOption) (*Response, error) { out := new(Response) err := c.cc.Invoke(ctx, "/message.Message/DeleteMultipleMessage", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) GetUnreadCount(ctx context.Context, in *GetUnreadCountRequest, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) { out := new(GetUnreadCountResponse) err := c.cc.Invoke(ctx, "/message.Message/GetUnreadCount", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) FindUserMsg(ctx context.Context, in *FindUserMsgReq, opts ...grpc.CallOption) (*FindUserMsgRes, error) { out := new(FindUserMsgRes) err := c.cc.Invoke(ctx, "/message.Message/FindUserMsg", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) GetClassUnreadCount(ctx context.Context, in *GetClassUnreadCountReq, opts ...grpc.CallOption) (*GetUnreadCountResponse, error) { out := new(GetUnreadCountResponse) err := c.cc.Invoke(ctx, "/message.Message/GetClassUnreadCount", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) GetLastMessage(ctx context.Context, in *GetLastMessageReq, opts ...grpc.CallOption) (*GetLastMessageRes, error) { out := new(GetLastMessageRes) err := c.cc.Invoke(ctx, "/message.Message/GetLastMessage", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) FindMessageDetail(ctx context.Context, in *MessageDetailReq, opts ...grpc.CallOption) (*MessageDetailResp, error) { out := new(MessageDetailResp) err := c.cc.Invoke(ctx, "/message.Message/FindMessageDetail", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) GetUnreadClassCount(ctx context.Context, in *GetUnreadClassCountReq, opts ...grpc.CallOption) (*GetUnreadClassCountRes, error) { out := new(GetUnreadClassCountRes) err := c.cc.Invoke(ctx, "/message.Message/GetUnreadClassCount", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) GetMsgType(ctx context.Context, in *GetMsgTypeReq, opts ...grpc.CallOption) (*GetMsgTypeRes, error) { out := new(GetMsgTypeRes) err := c.cc.Invoke(ctx, "/message.Message/GetMsgType", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) UpdateMessageRead(ctx context.Context, in *UpdateMessageReadReq, opts ...grpc.CallOption) (*UpdateMessageReadResp, error) { out := new(UpdateMessageReadResp) err := c.cc.Invoke(ctx, "/message.Message/UpdateMessageRead", in, out, opts...) if err != nil { return nil, err } return out, nil } func (c *messageClient) FindUserBuoyMsg(ctx context.Context, in *FindUserBuoyMsgReq, opts ...grpc.CallOption) (*FindUserBuoyMsgRes, error) { out := new(FindUserBuoyMsgRes) err := c.cc.Invoke(ctx, "/message.Message/FindUserBuoyMsg", in, out, opts...) if err != nil { return nil, err } return out, nil } // MessageServer is the server API for Message service. type MessageServer interface { //批量保存消息 MultipleSaveMsg(context.Context, *MultipleSaveMsgReq) (*MultipleSaveMsgResp, error) // 修改消息阅读状态 ChangeReadStatus(context.Context, *ChangeReadStatusRequest) (*Response, error) //指定用户发消息 SendUserMsg(context.Context, *SendMsgRequest) (*Response, error) // 删除单一消息 DeleteSingleMessage(context.Context, *DeleteSingleMessageRequest) (*Response, error) // 删除多条消息 DeleteMultipleMessage(context.Context, *DeleteMultipleMessageRequest) (*Response, error) // 查询指定用户未读消息合计 GetUnreadCount(context.Context, *GetUnreadCountRequest) (*GetUnreadCountResponse, error) // 查询指定用户的历史消息记录 FindUserMsg(context.Context, *FindUserMsgReq) (*FindUserMsgRes, error) // 查询指定用户指定分类的未读消息合计 GetClassUnreadCount(context.Context, *GetClassUnreadCountReq) (*GetUnreadCountResponse, error) // 获取指定用户指定分类的最新一条消息 GetLastMessage(context.Context, *GetLastMessageReq) (*GetLastMessageRes, error) //查看详细详情 FindMessageDetail(context.Context, *MessageDetailReq) (*MessageDetailResp, error) // 获取指定用户的分类及未读消息数量 GetUnreadClassCount(context.Context, *GetUnreadClassCountReq) (*GetUnreadClassCountRes, error) // 获取指定用户收到消息的分类 GetMsgType(context.Context, *GetMsgTypeReq) (*GetMsgTypeRes, error) //修改用户指定分类下的消息已读未读 UpdateMessageRead(context.Context, *UpdateMessageReadReq) (*UpdateMessageReadResp, error) // 查询指定用户的浮标消息 FindUserBuoyMsg(context.Context, *FindUserBuoyMsgReq) (*FindUserBuoyMsgRes, error) } // UnimplementedMessageServer can be embedded to have forward compatible implementations. type UnimplementedMessageServer struct { } func (*UnimplementedMessageServer) MultipleSaveMsg(ctx context.Context, req *MultipleSaveMsgReq) (*MultipleSaveMsgResp, error) { return nil, status.Errorf(codes.Unimplemented, "method MultipleSaveMsg not implemented") } func (*UnimplementedMessageServer) ChangeReadStatus(ctx context.Context, req *ChangeReadStatusRequest) (*Response, error) { return nil, status.Errorf(codes.Unimplemented, "method ChangeReadStatus not implemented") } func (*UnimplementedMessageServer) SendUserMsg(ctx context.Context, req *SendMsgRequest) (*Response, error) { return nil, status.Errorf(codes.Unimplemented, "method SendUserMsg not implemented") } func (*UnimplementedMessageServer) DeleteSingleMessage(ctx context.Context, req *DeleteSingleMessageRequest) (*Response, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteSingleMessage not implemented") } func (*UnimplementedMessageServer) DeleteMultipleMessage(ctx context.Context, req *DeleteMultipleMessageRequest) (*Response, error) { return nil, status.Errorf(codes.Unimplemented, "method DeleteMultipleMessage not implemented") } func (*UnimplementedMessageServer) GetUnreadCount(ctx context.Context, req *GetUnreadCountRequest) (*GetUnreadCountResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetUnreadCount not implemented") } func (*UnimplementedMessageServer) FindUserMsg(ctx context.Context, req *FindUserMsgReq) (*FindUserMsgRes, error) { return nil, status.Errorf(codes.Unimplemented, "method FindUserMsg not implemented") } func (*UnimplementedMessageServer) GetClassUnreadCount(ctx context.Context, req *GetClassUnreadCountReq) (*GetUnreadCountResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method GetClassUnreadCount not implemented") } func (*UnimplementedMessageServer) GetLastMessage(ctx context.Context, req *GetLastMessageReq) (*GetLastMessageRes, error) { return nil, status.Errorf(codes.Unimplemented, "method GetLastMessage not implemented") } func (*UnimplementedMessageServer) FindMessageDetail(ctx context.Context, req *MessageDetailReq) (*MessageDetailResp, error) { return nil, status.Errorf(codes.Unimplemented, "method FindMessageDetail not implemented") } func (*UnimplementedMessageServer) GetUnreadClassCount(ctx context.Context, req *GetUnreadClassCountReq) (*GetUnreadClassCountRes, error) { return nil, status.Errorf(codes.Unimplemented, "method GetUnreadClassCount not implemented") } func (*UnimplementedMessageServer) GetMsgType(ctx context.Context, req *GetMsgTypeReq) (*GetMsgTypeRes, error) { return nil, status.Errorf(codes.Unimplemented, "method GetMsgType not implemented") } func (*UnimplementedMessageServer) UpdateMessageRead(ctx context.Context, req *UpdateMessageReadReq) (*UpdateMessageReadResp, error) { return nil, status.Errorf(codes.Unimplemented, "method UpdateMessageRead not implemented") } func (*UnimplementedMessageServer) FindUserBuoyMsg(ctx context.Context, req *FindUserBuoyMsgReq) (*FindUserBuoyMsgRes, error) { return nil, status.Errorf(codes.Unimplemented, "method FindUserBuoyMsg not implemented") } func RegisterMessageServer(s *grpc.Server, srv MessageServer) { s.RegisterService(&_Message_serviceDesc, srv) } func _Message_MultipleSaveMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MultipleSaveMsgReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).MultipleSaveMsg(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/MultipleSaveMsg", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).MultipleSaveMsg(ctx, req.(*MultipleSaveMsgReq)) } return interceptor(ctx, in, info, handler) } func _Message_ChangeReadStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(ChangeReadStatusRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).ChangeReadStatus(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/ChangeReadStatus", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).ChangeReadStatus(ctx, req.(*ChangeReadStatusRequest)) } return interceptor(ctx, in, info, handler) } func _Message_SendUserMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(SendMsgRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).SendUserMsg(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/SendUserMsg", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).SendUserMsg(ctx, req.(*SendMsgRequest)) } return interceptor(ctx, in, info, handler) } func _Message_DeleteSingleMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteSingleMessageRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).DeleteSingleMessage(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/DeleteSingleMessage", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).DeleteSingleMessage(ctx, req.(*DeleteSingleMessageRequest)) } return interceptor(ctx, in, info, handler) } func _Message_DeleteMultipleMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(DeleteMultipleMessageRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).DeleteMultipleMessage(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/DeleteMultipleMessage", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).DeleteMultipleMessage(ctx, req.(*DeleteMultipleMessageRequest)) } return interceptor(ctx, in, info, handler) } func _Message_GetUnreadCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetUnreadCountRequest) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).GetUnreadCount(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/GetUnreadCount", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).GetUnreadCount(ctx, req.(*GetUnreadCountRequest)) } return interceptor(ctx, in, info, handler) } func _Message_FindUserMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(FindUserMsgReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).FindUserMsg(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/FindUserMsg", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).FindUserMsg(ctx, req.(*FindUserMsgReq)) } return interceptor(ctx, in, info, handler) } func _Message_GetClassUnreadCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetClassUnreadCountReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).GetClassUnreadCount(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/GetClassUnreadCount", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).GetClassUnreadCount(ctx, req.(*GetClassUnreadCountReq)) } return interceptor(ctx, in, info, handler) } func _Message_GetLastMessage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetLastMessageReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).GetLastMessage(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/GetLastMessage", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).GetLastMessage(ctx, req.(*GetLastMessageReq)) } return interceptor(ctx, in, info, handler) } func _Message_FindMessageDetail_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(MessageDetailReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).FindMessageDetail(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/FindMessageDetail", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).FindMessageDetail(ctx, req.(*MessageDetailReq)) } return interceptor(ctx, in, info, handler) } func _Message_GetUnreadClassCount_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetUnreadClassCountReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).GetUnreadClassCount(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/GetUnreadClassCount", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).GetUnreadClassCount(ctx, req.(*GetUnreadClassCountReq)) } return interceptor(ctx, in, info, handler) } func _Message_GetMsgType_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(GetMsgTypeReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).GetMsgType(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/GetMsgType", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).GetMsgType(ctx, req.(*GetMsgTypeReq)) } return interceptor(ctx, in, info, handler) } func _Message_UpdateMessageRead_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(UpdateMessageReadReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).UpdateMessageRead(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/UpdateMessageRead", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).UpdateMessageRead(ctx, req.(*UpdateMessageReadReq)) } return interceptor(ctx, in, info, handler) } func _Message_FindUserBuoyMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { in := new(FindUserBuoyMsgReq) if err := dec(in); err != nil { return nil, err } if interceptor == nil { return srv.(MessageServer).FindUserBuoyMsg(ctx, in) } info := &grpc.UnaryServerInfo{ Server: srv, FullMethod: "/message.Message/FindUserBuoyMsg", } handler := func(ctx context.Context, req interface{}) (interface{}, error) { return srv.(MessageServer).FindUserBuoyMsg(ctx, req.(*FindUserBuoyMsgReq)) } return interceptor(ctx, in, info, handler) } var _Message_serviceDesc = grpc.ServiceDesc{ ServiceName: "message.Message", HandlerType: (*MessageServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "multipleSaveMsg", Handler: _Message_MultipleSaveMsg_Handler, }, { MethodName: "ChangeReadStatus", Handler: _Message_ChangeReadStatus_Handler, }, { MethodName: "SendUserMsg", Handler: _Message_SendUserMsg_Handler, }, { MethodName: "DeleteSingleMessage", Handler: _Message_DeleteSingleMessage_Handler, }, { MethodName: "DeleteMultipleMessage", Handler: _Message_DeleteMultipleMessage_Handler, }, { MethodName: "GetUnreadCount", Handler: _Message_GetUnreadCount_Handler, }, { MethodName: "FindUserMsg", Handler: _Message_FindUserMsg_Handler, }, { MethodName: "GetClassUnreadCount", Handler: _Message_GetClassUnreadCount_Handler, }, { MethodName: "GetLastMessage", Handler: _Message_GetLastMessage_Handler, }, { MethodName: "FindMessageDetail", Handler: _Message_FindMessageDetail_Handler, }, { MethodName: "GetUnreadClassCount", Handler: _Message_GetUnreadClassCount_Handler, }, { MethodName: "GetMsgType", Handler: _Message_GetMsgType_Handler, }, { MethodName: "UpdateMessageRead", Handler: _Message_UpdateMessageRead_Handler, }, { MethodName: "FindUserBuoyMsg", Handler: _Message_FindUserBuoyMsg_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "message.proto", }