msb-public
/
Open-IM-Server
mirror of https://github.com/OpenIMSDK/Open-IM-Server
2
0
Code Issues Projects Releases Wiki Activity

pbfile

Browse Source
pull/103/head
root 4 years ago
parent d88ba3545b
commit 784ac4ecfc
7 changed files with 7197 additions and 5787 deletions
Show Stats Download Patch File Download Diff File

642
src/proto/auth/auth.pb.go
Unescape View File

@ -1,404 +1,446 @@
// Code generated by protoc-gen-go. DO NOT EDIT. // Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.26.0
// protoc v3.7.1
// source: auth/auth.proto // source: auth/auth.proto
package pbAuth // import "auth" package pbAuth
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import ( import (
context "golang.org/x/net/context" protoreflect "google.golang.org/protobuf/reflect/protoreflect"
grpc "google.golang.org/grpc" protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
) )
// Reference imports to suppress errors if they are not otherwise used. const (
var _ = proto.Marshal // Verify that this generated code is sufficiently up-to-date.
var _ = fmt.Errorf _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
var _ = math.Inf // Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
// 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.ProtoPackageIsVersion2 // please upgrade the proto package
type UserRegisterReq struct { type UserRegisterReq struct {
UID string `protobuf:"bytes,1,opt,name=UID" json:"UID,omitempty"` state protoimpl.MessageState
Name string `protobuf:"bytes,2,opt,name=Name" json:"Name,omitempty"` sizeCache protoimpl.SizeCache
Icon string `protobuf:"bytes,3,opt,name=Icon" json:"Icon,omitempty"` unknownFields protoimpl.UnknownFields
Gender int32 `protobuf:"varint,4,opt,name=Gender" json:"Gender,omitempty"`
Mobile string `protobuf:"bytes,5,opt,name=Mobile" json:"Mobile,omitempty"` UID string `protobuf:"bytes,1,opt,name=UID,proto3" json:"UID,omitempty"`
Birth string `protobuf:"bytes,6,opt,name=Birth" json:"Birth,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
Email string `protobuf:"bytes,7,opt,name=Email" json:"Email,omitempty"` Icon string `protobuf:"bytes,3,opt,name=Icon,proto3" json:"Icon,omitempty"`
Ex string `protobuf:"bytes,8,opt,name=Ex" json:"Ex,omitempty"` Gender int32 `protobuf:"varint,4,opt,name=Gender,proto3" json:"Gender,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` Mobile string `protobuf:"bytes,5,opt,name=Mobile,proto3" json:"Mobile,omitempty"`
XXX_unrecognized []byte `json:"-"` Birth string `protobuf:"bytes,6,opt,name=Birth,proto3" json:"Birth,omitempty"`
XXX_sizecache int32 `json:"-"` Email string `protobuf:"bytes,7,opt,name=Email,proto3" json:"Email,omitempty"`
} Ex string `protobuf:"bytes,8,opt,name=Ex,proto3" json:"Ex,omitempty"`
}
func (m *UserRegisterReq) Reset() { *m = UserRegisterReq{} }
func (m *UserRegisterReq) String() string { return proto.CompactTextString(m) } func (x *UserRegisterReq) Reset() {
func (*UserRegisterReq) ProtoMessage() {} *x = UserRegisterReq{}
func (*UserRegisterReq) Descriptor() ([]byte, []int) { if protoimpl.UnsafeEnabled {
return fileDescriptor_auth_ef7bd0d2906761f0, []int{0} mi := &file_auth_auth_proto_msgTypes[0]
} ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
func (m *UserRegisterReq) XXX_Unmarshal(b []byte) error { ms.StoreMessageInfo(mi)
return xxx_messageInfo_UserRegisterReq.Unmarshal(m, b) }
}
func (m *UserRegisterReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UserRegisterReq.Marshal(b, m, deterministic)
}
func (dst *UserRegisterReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_UserRegisterReq.Merge(dst, src)
} }
func (m *UserRegisterReq) XXX_Size() int {
return xxx_messageInfo_UserRegisterReq.Size(m) func (x *UserRegisterReq) String() string {
return protoimpl.X.MessageStringOf(x)
} }
func (m *UserRegisterReq) XXX_DiscardUnknown() {
xxx_messageInfo_UserRegisterReq.DiscardUnknown(m) func (*UserRegisterReq) ProtoMessage() {}
func (x *UserRegisterReq) ProtoReflect() protoreflect.Message {
mi := &file_auth_auth_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
} }
var xxx_messageInfo_UserRegisterReq proto.InternalMessageInfo // Deprecated: Use UserRegisterReq.ProtoReflect.Descriptor instead.
func (*UserRegisterReq) Descriptor() ([]byte, []int) {
return file_auth_auth_proto_rawDescGZIP(), []int{0}
}
func (m *UserRegisterReq) GetUID() string { func (x *UserRegisterReq) GetUID() string {
if m != nil { if x != nil {
return m.UID return x.UID
} }
return "" return ""
} }
func (m *UserRegisterReq) GetName() string { func (x *UserRegisterReq) GetName() string {
if m != nil { if x != nil {
return m.Name return x.Name
} }
return "" return ""
} }
func (m *UserRegisterReq) GetIcon() string { func (x *UserRegisterReq) GetIcon() string {
if m != nil { if x != nil {
return m.Icon return x.Icon
} }
return "" return ""
} }
func (m *UserRegisterReq) GetGender() int32 { func (x *UserRegisterReq) GetGender() int32 {
if m != nil { if x != nil {
return m.Gender return x.Gender
} }
return 0 return 0
} }
func (m *UserRegisterReq) GetMobile() string { func (x *UserRegisterReq) GetMobile() string {
if m != nil { if x != nil {
return m.Mobile return x.Mobile
} }
return "" return ""
} }
func (m *UserRegisterReq) GetBirth() string { func (x *UserRegisterReq) GetBirth() string {
if m != nil { if x != nil {
return m.Birth return x.Birth
} }
return "" return ""
} }
func (m *UserRegisterReq) GetEmail() string { func (x *UserRegisterReq) GetEmail() string {
if m != nil { if x != nil {
return m.Email return x.Email
} }
return "" return ""
} }
func (m *UserRegisterReq) GetEx() string { func (x *UserRegisterReq) GetEx() string {
if m != nil { if x != nil {
return m.Ex return x.Ex
} }
return "" return ""
} }
type UserRegisterResp struct { type UserRegisterResp struct {
Success bool `protobuf:"varint,1,opt,name=Success" json:"Success,omitempty"` state protoimpl.MessageState
XXX_NoUnkeyedLiteral struct{} `json:"-"` sizeCache protoimpl.SizeCache
XXX_unrecognized []byte `json:"-"` unknownFields protoimpl.UnknownFields
XXX_sizecache int32 `json:"-"`
}
func (m *UserRegisterResp) Reset() { *m = UserRegisterResp{} } Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
func (m *UserRegisterResp) String() string { return proto.CompactTextString(m) }
func (*UserRegisterResp) ProtoMessage() {}
func (*UserRegisterResp) Descriptor() ([]byte, []int) {
return fileDescriptor_auth_ef7bd0d2906761f0, []int{1}
}
func (m *UserRegisterResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UserRegisterResp.Unmarshal(m, b)
}
func (m *UserRegisterResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UserRegisterResp.Marshal(b, m, deterministic)
}
func (dst *UserRegisterResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_UserRegisterResp.Merge(dst, src)
} }
func (m *UserRegisterResp) XXX_Size() int {
return xxx_messageInfo_UserRegisterResp.Size(m) func (x *UserRegisterResp) Reset() {
*x = UserRegisterResp{}
if protoimpl.UnsafeEnabled {
mi := &file_auth_auth_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
} }
func (m *UserRegisterResp) XXX_DiscardUnknown() {
xxx_messageInfo_UserRegisterResp.DiscardUnknown(m) func (x *UserRegisterResp) String() string {
return protoimpl.X.MessageStringOf(x)
} }
var xxx_messageInfo_UserRegisterResp proto.InternalMessageInfo func (*UserRegisterResp) ProtoMessage() {}
func (m *UserRegisterResp) GetSuccess() bool { func (x *UserRegisterResp) ProtoReflect() protoreflect.Message {
if m != nil { mi := &file_auth_auth_proto_msgTypes[1]
return m.Success if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
} }
return false return mi.MessageOf(x)
} }
type UserTokenReq struct { // Deprecated: Use UserRegisterResp.ProtoReflect.Descriptor instead.
Platform int32 `protobuf:"varint,1,opt,name=Platform" json:"Platform,omitempty"` func (*UserRegisterResp) Descriptor() ([]byte, []int) {
UID string `protobuf:"bytes,2,opt,name=UID" json:"UID,omitempty"` return file_auth_auth_proto_rawDescGZIP(), []int{1}
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *UserTokenReq) Reset() { *m = UserTokenReq{} } func (x *UserRegisterResp) GetSuccess() bool {
func (m *UserTokenReq) String() string { return proto.CompactTextString(m) } if x != nil {
func (*UserTokenReq) ProtoMessage() {} return x.Success
func (*UserTokenReq) Descriptor() ([]byte, []int) { }
return fileDescriptor_auth_ef7bd0d2906761f0, []int{2} return false
}
func (m *UserTokenReq) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UserTokenReq.Unmarshal(m, b)
}
func (m *UserTokenReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UserTokenReq.Marshal(b, m, deterministic)
}
func (dst *UserTokenReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_UserTokenReq.Merge(dst, src)
}
func (m *UserTokenReq) XXX_Size() int {
return xxx_messageInfo_UserTokenReq.Size(m)
}
func (m *UserTokenReq) XXX_DiscardUnknown() {
xxx_messageInfo_UserTokenReq.DiscardUnknown(m)
} }
var xxx_messageInfo_UserTokenReq proto.InternalMessageInfo type UserTokenReq struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
func (m *UserTokenReq) GetPlatform() int32 { Platform int32 `protobuf:"varint,1,opt,name=Platform,proto3" json:"Platform,omitempty"`
if m != nil { UID string `protobuf:"bytes,2,opt,name=UID,proto3" json:"UID,omitempty"`
return m.Platform
}
return 0
} }
func (m *UserTokenReq) GetUID() string { func (x *UserTokenReq) Reset() {
if m != nil { *x = UserTokenReq{}
return m.UID if protoimpl.UnsafeEnabled {
mi := &file_auth_auth_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
} }
return ""
} }
type UserTokenResp struct { func (x *UserTokenReq) String() string {
ErrCode int32 `protobuf:"varint,1,opt,name=ErrCode" json:"ErrCode,omitempty"` return protoimpl.X.MessageStringOf(x)
ErrMsg string `protobuf:"bytes,2,opt,name=ErrMsg" json:"ErrMsg,omitempty"`
Token string `protobuf:"bytes,3,opt,name=Token" json:"Token,omitempty"`
ExpiredTime int64 `protobuf:"varint,4,opt,name=ExpiredTime" json:"ExpiredTime,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *UserTokenResp) Reset() { *m = UserTokenResp{} }
func (m *UserTokenResp) String() string { return proto.CompactTextString(m) }
func (*UserTokenResp) ProtoMessage() {}
func (*UserTokenResp) Descriptor() ([]byte, []int) {
return fileDescriptor_auth_ef7bd0d2906761f0, []int{3}
}
func (m *UserTokenResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_UserTokenResp.Unmarshal(m, b)
}
func (m *UserTokenResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_UserTokenResp.Marshal(b, m, deterministic)
}
func (dst *UserTokenResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_UserTokenResp.Merge(dst, src)
}
func (m *UserTokenResp) XXX_Size() int {
return xxx_messageInfo_UserTokenResp.Size(m)
}
func (m *UserTokenResp) XXX_DiscardUnknown() {
xxx_messageInfo_UserTokenResp.DiscardUnknown(m)
} }
var xxx_messageInfo_UserTokenResp proto.InternalMessageInfo func (*UserTokenReq) ProtoMessage() {}
func (m *UserTokenResp) GetErrCode() int32 { func (x *UserTokenReq) ProtoReflect() protoreflect.Message {
if m != nil { mi := &file_auth_auth_proto_msgTypes[2]
return m.ErrCode if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
} }
return 0 return mi.MessageOf(x)
}
// Deprecated: Use UserTokenReq.ProtoReflect.Descriptor instead.
func (*UserTokenReq) Descriptor() ([]byte, []int) {
return file_auth_auth_proto_rawDescGZIP(), []int{2}
} }
func (m *UserTokenResp) GetErrMsg() string { func (x *UserTokenReq) GetPlatform() int32 {
if m != nil { if x != nil {
return m.ErrMsg return x.Platform
} }
return "" return 0
} }
func (m *UserTokenResp) GetToken() string { func (x *UserTokenReq) GetUID() string {
if m != nil { if x != nil {
return m.Token return x.UID
} }
return "" return ""
} }
func (m *UserTokenResp) GetExpiredTime() int64 { type UserTokenResp struct {
if m != nil { state protoimpl.MessageState
return m.ExpiredTime sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
ErrCode int32 `protobuf:"varint,1,opt,name=ErrCode,proto3" json:"ErrCode,omitempty"`
ErrMsg string `protobuf:"bytes,2,opt,name=ErrMsg,proto3" json:"ErrMsg,omitempty"`
Token string `protobuf:"bytes,3,opt,name=Token,proto3" json:"Token,omitempty"`
ExpiredTime int64 `protobuf:"varint,4,opt,name=ExpiredTime,proto3" json:"ExpiredTime,omitempty"`
}
func (x *UserTokenResp) Reset() {
*x = UserTokenResp{}
if protoimpl.UnsafeEnabled {
mi := &file_auth_auth_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
} }
return 0
} }
func init() { func (x *UserTokenResp) String() string {
proto.RegisterType((*UserRegisterReq)(nil), "pbAuth.UserRegisterReq") return protoimpl.X.MessageStringOf(x)
proto.RegisterType((*UserRegisterResp)(nil), "pbAuth.UserRegisterResp")
proto.RegisterType((*UserTokenReq)(nil), "pbAuth.UserTokenReq")
proto.RegisterType((*UserTokenResp)(nil), "pbAuth.UserTokenResp")
} }
// Reference imports to suppress errors if they are not otherwise used. func (*UserTokenResp) ProtoMessage() {}
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
// Client API for Auth service func (x *UserTokenResp) ProtoReflect() protoreflect.Message {
mi := &file_auth_auth_proto_msgTypes[3]
type AuthClient interface { if protoimpl.UnsafeEnabled && x != nil {
UserRegister(ctx context.Context, in *UserRegisterReq, opts ...grpc.CallOption) (*UserRegisterResp, error) ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
UserToken(ctx context.Context, in *UserTokenReq, opts ...grpc.CallOption) (*UserTokenResp, error) if ms.LoadMessageInfo() == nil {
} ms.StoreMessageInfo(mi)
}
type authClient struct { return ms
cc *grpc.ClientConn }
return mi.MessageOf(x)
} }
func NewAuthClient(cc *grpc.ClientConn) AuthClient { // Deprecated: Use UserTokenResp.ProtoReflect.Descriptor instead.
return &authClient{cc} func (*UserTokenResp) Descriptor() ([]byte, []int) {
return file_auth_auth_proto_rawDescGZIP(), []int{3}
} }
func (c *authClient) UserRegister(ctx context.Context, in *UserRegisterReq, opts ...grpc.CallOption) (*UserRegisterResp, error) { func (x *UserTokenResp) GetErrCode() int32 {
out := new(UserRegisterResp) if x != nil {
err := grpc.Invoke(ctx, "/pbAuth.Auth/UserRegister", in, out, c.cc, opts...) return x.ErrCode
if err != nil {
return nil, err
} }
return out, nil return 0
} }
func (c *authClient) UserToken(ctx context.Context, in *UserTokenReq, opts ...grpc.CallOption) (*UserTokenResp, error) { func (x *UserTokenResp) GetErrMsg() string {
out := new(UserTokenResp) if x != nil {
err := grpc.Invoke(ctx, "/pbAuth.Auth/UserToken", in, out, c.cc, opts...) return x.ErrMsg
if err != nil {
return nil, err
} }
return out, nil return ""
}
// Server API for Auth service
type AuthServer interface {
UserRegister(context.Context, *UserRegisterReq) (*UserRegisterResp, error)
UserToken(context.Context, *UserTokenReq) (*UserTokenResp, error)
} }
func RegisterAuthServer(s *grpc.Server, srv AuthServer) { func (x *UserTokenResp) GetToken() string {
s.RegisterService(&_Auth_serviceDesc, srv) if x != nil {
return x.Token
}
return ""
} }
func _Auth_UserRegister_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func (x *UserTokenResp) GetExpiredTime() int64 {
in := new(UserRegisterReq) if x != nil {
if err := dec(in); err != nil { return x.ExpiredTime
return nil, err
}
if interceptor == nil {
return srv.(AuthServer).UserRegister(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/pbAuth.Auth/UserRegister",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { return 0
return srv.(AuthServer).UserRegister(ctx, req.(*UserRegisterReq))
}
return interceptor(ctx, in, info, handler)
} }
func _Auth_UserToken_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { var File_auth_auth_proto protoreflect.FileDescriptor
in := new(UserTokenReq)
if err := dec(in); err != nil { var file_auth_auth_proto_rawDesc = []byte{
return nil, err 0x0a, 0x0f, 0x61, 0x75, 0x74, 0x68, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x2e, 0x70, 0x72, 0x6f, 0x74,
} 0x6f, 0x12, 0x06, 0x70, 0x62, 0x41, 0x75, 0x74, 0x68, 0x22, 0xb7, 0x01, 0x0a, 0x0f, 0x55, 0x73,
if interceptor == nil { 0x65, 0x72, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x12, 0x10, 0x0a,
return srv.(AuthServer).UserToken(ctx, in) 0x03, 0x55, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x55, 0x49, 0x44, 0x12,
} 0x12, 0x0a, 0x04, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x4e,
info := &grpc.UnaryServerInfo{ 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x49, 0x63, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28,
Server: srv, 0x09, 0x52, 0x04, 0x49, 0x63, 0x6f, 0x6e, 0x12, 0x16, 0x0a, 0x06, 0x47, 0x65, 0x6e, 0x64, 0x65,
FullMethod: "/pbAuth.Auth/UserToken", 0x72, 0x18, 0x04, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x47, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x12,
0x16, 0x0a, 0x06, 0x4d, 0x6f, 0x62, 0x69, 0x6c, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52,
0x06, 0x4d, 0x6f, 0x62, 0x69, 0x6c, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x42, 0x69, 0x72, 0x74, 0x68,
0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x42, 0x69, 0x72, 0x74, 0x68, 0x12, 0x14, 0x0a,
0x05, 0x45, 0x6d, 0x61, 0x69, 0x6c, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x45, 0x6d,
0x61, 0x69, 0x6c, 0x12, 0x0e, 0x0a, 0x02, 0x45, 0x78, 0x18, 0x08, 0x20, 0x01, 0x28, 0x09, 0x52,
0x02, 0x45, 0x78, 0x22, 0x2c, 0x0a, 0x10, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x67, 0x69, 0x73,
0x74, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x12, 0x18, 0x0a, 0x07, 0x53, 0x75, 0x63, 0x63, 0x65,
0x73, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x08, 0x52, 0x07, 0x53, 0x75, 0x63, 0x63, 0x65, 0x73,
0x73, 0x22, 0x3c, 0x0a, 0x0c, 0x55, 0x73, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65,
0x71, 0x12, 0x1a, 0x0a, 0x08, 0x50, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x18, 0x01, 0x20,
0x01, 0x28, 0x05, 0x52, 0x08, 0x50, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x12, 0x10, 0x0a,
0x03, 0x55, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x55, 0x49, 0x44, 0x22,
0x79, 0x0a, 0x0d, 0x55, 0x73, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70,
0x12, 0x18, 0x0a, 0x07, 0x45, 0x72, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
0x05, 0x52, 0x07, 0x45, 0x72, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x45, 0x72,
0x72, 0x4d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x45, 0x72, 0x72, 0x4d,
0x73, 0x67, 0x12, 0x14, 0x0a, 0x05, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28,
0x09, 0x52, 0x05, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x12, 0x20, 0x0a, 0x0b, 0x45, 0x78, 0x70, 0x69,
0x72, 0x65, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x03, 0x52, 0x0b, 0x45,
0x78, 0x70, 0x69, 0x72, 0x65, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x32, 0x83, 0x01, 0x0a, 0x04, 0x41,
0x75, 0x74, 0x68, 0x12, 0x41, 0x0a, 0x0c, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x67, 0x69, 0x73,
0x74, 0x65, 0x72, 0x12, 0x17, 0x2e, 0x70, 0x62, 0x41, 0x75, 0x74, 0x68, 0x2e, 0x55, 0x73, 0x65,
0x72, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74, 0x65, 0x72, 0x52, 0x65, 0x71, 0x1a, 0x18, 0x2e, 0x70,
0x62, 0x41, 0x75, 0x74, 0x68, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x67, 0x69, 0x73, 0x74,
0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x12, 0x38, 0x0a, 0x09, 0x55, 0x73, 0x65, 0x72, 0x54, 0x6f,
0x6b, 0x65, 0x6e, 0x12, 0x14, 0x2e, 0x70, 0x62, 0x41, 0x75, 0x74, 0x68, 0x2e, 0x55, 0x73, 0x65,
0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65, 0x71, 0x1a, 0x15, 0x2e, 0x70, 0x62, 0x41, 0x75,
0x74, 0x68, 0x2e, 0x55, 0x73, 0x65, 0x72, 0x54, 0x6f, 0x6b, 0x65, 0x6e, 0x52, 0x65, 0x73, 0x70,
0x42, 0x0f, 0x5a, 0x0d, 0x2e, 0x2f, 0x61, 0x75, 0x74, 0x68, 0x3b, 0x70, 0x62, 0x41, 0x75, 0x74,
0x68, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
file_auth_auth_proto_rawDescOnce sync.Once
file_auth_auth_proto_rawDescData = file_auth_auth_proto_rawDesc
)
func file_auth_auth_proto_rawDescGZIP() []byte {
file_auth_auth_proto_rawDescOnce.Do(func() {
file_auth_auth_proto_rawDescData = protoimpl.X.CompressGZIP(file_auth_auth_proto_rawDescData)
})
return file_auth_auth_proto_rawDescData
}
var file_auth_auth_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
var file_auth_auth_proto_goTypes = []interface{}{
(*UserRegisterReq)(nil), // 0: pbAuth.UserRegisterReq
(*UserRegisterResp)(nil), // 1: pbAuth.UserRegisterResp
(*UserTokenReq)(nil), // 2: pbAuth.UserTokenReq
(*UserTokenResp)(nil), // 3: pbAuth.UserTokenResp
}
var file_auth_auth_proto_depIdxs = []int32{
0, // 0: pbAuth.Auth.UserRegister:input_type -> pbAuth.UserRegisterReq
2, // 1: pbAuth.Auth.UserToken:input_type -> pbAuth.UserTokenReq
1, // 2: pbAuth.Auth.UserRegister:output_type -> pbAuth.UserRegisterResp
3, // 3: pbAuth.Auth.UserToken:output_type -> pbAuth.UserTokenResp
2, // [2:4] is the sub-list for method output_type
0, // [0:2] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name
0, // [0:0] is the sub-list for extension extendee
0, // [0:0] is the sub-list for field type_name
}
func init() { file_auth_auth_proto_init() }
func file_auth_auth_proto_init() {
if File_auth_auth_proto != nil {
return
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { if !protoimpl.UnsafeEnabled {
return srv.(AuthServer).UserToken(ctx, req.(*UserTokenReq)) file_auth_auth_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*UserRegisterReq); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_auth_auth_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*UserRegisterResp); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_auth_auth_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*UserTokenReq); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_auth_auth_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*UserTokenResp); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
} }
return interceptor(ctx, in, info, handler) type x struct{}
} out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
var _Auth_serviceDesc = grpc.ServiceDesc{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
ServiceName: "pbAuth.Auth", RawDescriptor: file_auth_auth_proto_rawDesc,
HandlerType: (*AuthServer)(nil), NumEnums: 0,
Methods: []grpc.MethodDesc{ NumMessages: 4,
{ NumExtensions: 0,
MethodName: "UserRegister", NumServices: 1,
Handler: _Auth_UserRegister_Handler,
},
{
MethodName: "UserToken",
Handler: _Auth_UserToken_Handler,
}, },
}, GoTypes: file_auth_auth_proto_goTypes,
Streams: []grpc.StreamDesc{}, DependencyIndexes: file_auth_auth_proto_depIdxs,
Metadata: "auth/auth.proto", MessageInfos: file_auth_auth_proto_msgTypes,
} }.Build()
File_auth_auth_proto = out.File
func init() { proto.RegisterFile("auth/auth.proto", fileDescriptor_auth_ef7bd0d2906761f0) } file_auth_auth_proto_rawDesc = nil
file_auth_auth_proto_goTypes = nil
var fileDescriptor_auth_ef7bd0d2906761f0 = []byte{ file_auth_auth_proto_depIdxs = nil
// 346 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x92, 0xc1, 0x4e, 0xc2, 0x40,
0x10, 0x86, 0xd3, 0x42, 0x0b, 0x0c, 0x22, 0x64, 0x82, 0xba, 0xe1, 0x44, 0x7a, 0xe2, 0x60, 0x30,
0xd1, 0x8b, 0x89, 0x5e, 0x40, 0x1b, 0xc3, 0x01, 0x63, 0x2a, 0x5c, 0xbc, 0x15, 0x58, 0xa1, 0x91,
0xb2, 0x75, 0xb7, 0x24, 0x78, 0xf6, 0xa1, 0x7c, 0x3d, 0x33, 0xbb, 0x5b, 0x82, 0x86, 0x4b, 0x3b,
0xff, 0xb7, 0x33, 0xd9, 0xfd, 0x67, 0x06, 0x9a, 0xf1, 0x36, 0x5f, 0x5d, 0xd1, 0xa7, 0x9f, 0x49,
0x91, 0x0b, 0xf4, 0xb3, 0xd9, 0x60, 0x9b, 0xaf, 0x82, 0x1f, 0x07, 0x9a, 0x53, 0xc5, 0x65, 0xc4,
0x97, 0x89, 0xca, 0xe9, 0xff, 0x89, 0x2d, 0x28, 0x4d, 0x47, 0x8f, 0xcc, 0xe9, 0x3a, 0xbd, 0x5a,
0x44, 0x21, 0x22, 0x94, 0x9f, 0xe3, 0x94, 0x33, 0x57, 0x23, 0x1d, 0x13, 0x1b, 0xcd, 0xc5, 0x86,
0x95, 0x0c, 0xa3, 0x18, 0xcf, 0xc1, 0x7f, 0xe2, 0x9b, 0x05, 0x97, 0xac, 0xdc, 0x75, 0x7a, 0x5e,
0x64, 0x15, 0xf1, 0xb1, 0x98, 0x25, 0x6b, 0xce, 0x3c, 0x9d, 0x6d, 0x15, 0xb6, 0xc1, 0x1b, 0x26,
0x32, 0x5f, 0x31, 0x5f, 0x63, 0x23, 0x88, 0x86, 0x69, 0x9c, 0xac, 0x59, 0xc5, 0x50, 0x2d, 0xf0,
0x14, 0xdc, 0x70, 0xc7, 0xaa, 0x1a, 0xb9, 0xe1, 0x2e, 0xb8, 0x84, 0xd6, 0xdf, 0x87, 0xab, 0x0c,
0x19, 0x54, 0x5e, 0xb7, 0xf3, 0x39, 0x57, 0x4a, 0xbf, 0xbe, 0x1a, 0x15, 0x32, 0xb8, 0x87, 0x13,
0xca, 0x9e, 0x88, 0x0f, 0xbe, 0x21, 0x8f, 0x1d, 0xa8, 0xbe, 0xac, 0xe3, 0xfc, 0x5d, 0xc8, 0x54,
0xa7, 0x7a, 0xd1, 0x5e, 0x17, 0xfe, 0xdd, 0xbd, 0xff, 0xe0, 0x0b, 0x1a, 0x07, 0xd5, 0xe6, 0xa2,
0x50, 0xca, 0x07, 0xb1, 0xe0, 0xb6, 0xba, 0x90, 0x64, 0x35, 0x94, 0x72, 0xac, 0x96, 0xb6, 0xde,
0x2a, 0x32, 0xa5, 0xcb, 0x6d, 0xbf, 0x8c, 0xc0, 0x2e, 0xd4, 0xc3, 0x5d, 0x96, 0x48, 0xbe, 0x98,
0x24, 0x29, 0xd7, 0x5d, 0x2b, 0x45, 0x87, 0xe8, 0xfa, 0xdb, 0x81, 0x32, 0x4d, 0x0a, 0x07, 0xc6,
0x41, 0xe1, 0x17, 0x2f, 0xfa, 0x66, 0x84, 0xfd, 0x7f, 0xe3, 0xeb, 0xb0, 0xe3, 0x07, 0x2a, 0xc3,
0x5b, 0xa8, 0xed, 0x6d, 0x60, 0xfb, 0x30, 0xad, 0xe8, 0x4b, 0xe7, 0xec, 0x08, 0x55, 0xd9, 0xb0,
0xf1, 0x56, 0xa7, 0xe5, 0xb9, 0x33, 0x87, 0x33, 0x5f, 0x2f, 0xd1, 0xcd, 0x6f, 0x00, 0x00, 0x00,
0xff, 0xff, 0x03, 0x0f, 0xb1, 0xb3, 0x57, 0x02, 0x00, 0x00,
} }

1987
src/proto/chat/chat.pb.go
View File

File diff suppressed because it is too large Load Diff

3297
src/proto/friend/friend.pb.go
View File

File diff suppressed because it is too large Load Diff

4631
src/proto/group/group.pb.go
View File

File diff suppressed because it is too large Load Diff

479
src/proto/push/push.pb.go
Unescape View File

@ -1,327 +1,360 @@
// Code generated by protoc-gen-go. DO NOT EDIT. // Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.26.0
// protoc v3.7.1
// source: push/push.proto // source: push/push.proto
package pbPush // import "push" package pbPush
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import ( import (
context "golang.org/x/net/context" protoreflect "google.golang.org/protobuf/reflect/protoreflect"
grpc "google.golang.org/grpc" protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
) )
// Reference imports to suppress errors if they are not otherwise used. const (
var _ = proto.Marshal // Verify that this generated code is sufficiently up-to-date.
var _ = fmt.Errorf _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
var _ = math.Inf // Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
// 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.ProtoPackageIsVersion2 // please upgrade the proto package
type PushMsgReq struct { type PushMsgReq struct {
SendID string `protobuf:"bytes,1,opt,name=SendID" json:"SendID,omitempty"` state protoimpl.MessageState
RecvID string `protobuf:"bytes,2,opt,name=RecvID" json:"RecvID,omitempty"` sizeCache protoimpl.SizeCache
Content string `protobuf:"bytes,3,opt,name=Content" json:"Content,omitempty"` unknownFields protoimpl.UnknownFields
RecvSeq int64 `protobuf:"varint,4,opt,name=RecvSeq" json:"RecvSeq,omitempty"`
SendTime int64 `protobuf:"varint,5,opt,name=SendTime" json:"SendTime,omitempty"` SendID string `protobuf:"bytes,1,opt,name=SendID,proto3" json:"SendID,omitempty"`
MsgFrom int32 `protobuf:"varint,6,opt,name=MsgFrom" json:"MsgFrom,omitempty"` RecvID string `protobuf:"bytes,2,opt,name=RecvID,proto3" json:"RecvID,omitempty"`
ContentType int32 `protobuf:"varint,7,opt,name=ContentType" json:"ContentType,omitempty"` Content string `protobuf:"bytes,3,opt,name=Content,proto3" json:"Content,omitempty"`
SessionType int32 `protobuf:"varint,8,opt,name=SessionType" json:"SessionType,omitempty"` RecvSeq int64 `protobuf:"varint,4,opt,name=RecvSeq,proto3" json:"RecvSeq,omitempty"`
OperationID string `protobuf:"bytes,9,opt,name=OperationID" json:"OperationID,omitempty"` SendTime int64 `protobuf:"varint,5,opt,name=SendTime,proto3" json:"SendTime,omitempty"`
MsgID string `protobuf:"bytes,10,opt,name=MsgID" json:"MsgID,omitempty"` MsgFrom int32 `protobuf:"varint,6,opt,name=MsgFrom,proto3" json:"MsgFrom,omitempty"`
OfflineInfo string `protobuf:"bytes,11,opt,name=OfflineInfo" json:"OfflineInfo,omitempty"` ContentType int32 `protobuf:"varint,7,opt,name=ContentType,proto3" json:"ContentType,omitempty"`
Options string `protobuf:"bytes,12,opt,name=Options" json:"Options,omitempty"` SessionType int32 `protobuf:"varint,8,opt,name=SessionType,proto3" json:"SessionType,omitempty"`
PlatformID int32 `protobuf:"varint,13,opt,name=PlatformID" json:"PlatformID,omitempty"` OperationID string `protobuf:"bytes,9,opt,name=OperationID,proto3" json:"OperationID,omitempty"`
SenderNickName string `protobuf:"bytes,14,opt,name=SenderNickName" json:"SenderNickName,omitempty"` MsgID string `protobuf:"bytes,10,opt,name=MsgID,proto3" json:"MsgID,omitempty"`
SenderFaceURL string `protobuf:"bytes,15,opt,name=SenderFaceURL" json:"SenderFaceURL,omitempty"` OfflineInfo string `protobuf:"bytes,11,opt,name=OfflineInfo,proto3" json:"OfflineInfo,omitempty"`
ClientMsgID string `protobuf:"bytes,16,opt,name=ClientMsgID" json:"ClientMsgID,omitempty"` Options string `protobuf:"bytes,12,opt,name=Options,proto3" json:"Options,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` PlatformID int32 `protobuf:"varint,13,opt,name=PlatformID,proto3" json:"PlatformID,omitempty"`
XXX_unrecognized []byte `json:"-"` SenderNickName string `protobuf:"bytes,14,opt,name=SenderNickName,proto3" json:"SenderNickName,omitempty"`
XXX_sizecache int32 `json:"-"` SenderFaceURL string `protobuf:"bytes,15,opt,name=SenderFaceURL,proto3" json:"SenderFaceURL,omitempty"`
} ClientMsgID string `protobuf:"bytes,16,opt,name=ClientMsgID,proto3" json:"ClientMsgID,omitempty"`
}
func (m *PushMsgReq) Reset() { *m = PushMsgReq{} }
func (m *PushMsgReq) String() string { return proto.CompactTextString(m) } func (x *PushMsgReq) Reset() {
func (*PushMsgReq) ProtoMessage() {} *x = PushMsgReq{}
func (*PushMsgReq) Descriptor() ([]byte, []int) { if protoimpl.UnsafeEnabled {
return fileDescriptor_push_a8d13c8ad86fddce, []int{0} mi := &file_push_push_proto_msgTypes[0]
} ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
func (m *PushMsgReq) XXX_Unmarshal(b []byte) error { ms.StoreMessageInfo(mi)
return xxx_messageInfo_PushMsgReq.Unmarshal(m, b) }
}
func (m *PushMsgReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PushMsgReq.Marshal(b, m, deterministic)
}
func (dst *PushMsgReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_PushMsgReq.Merge(dst, src)
} }
func (m *PushMsgReq) XXX_Size() int {
return xxx_messageInfo_PushMsgReq.Size(m) func (x *PushMsgReq) String() string {
return protoimpl.X.MessageStringOf(x)
} }
func (m *PushMsgReq) XXX_DiscardUnknown() {
xxx_messageInfo_PushMsgReq.DiscardUnknown(m) func (*PushMsgReq) ProtoMessage() {}
func (x *PushMsgReq) ProtoReflect() protoreflect.Message {
mi := &file_push_push_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
} }
var xxx_messageInfo_PushMsgReq proto.InternalMessageInfo // Deprecated: Use PushMsgReq.ProtoReflect.Descriptor instead.
func (*PushMsgReq) Descriptor() ([]byte, []int) {
return file_push_push_proto_rawDescGZIP(), []int{0}
}
func (m *PushMsgReq) GetSendID() string { func (x *PushMsgReq) GetSendID() string {
if m != nil { if x != nil {
return m.SendID return x.SendID
} }
return "" return ""
} }
func (m *PushMsgReq) GetRecvID() string { func (x *PushMsgReq) GetRecvID() string {
if m != nil { if x != nil {
return m.RecvID return x.RecvID
} }
return "" return ""
} }
func (m *PushMsgReq) GetContent() string { func (x *PushMsgReq) GetContent() string {
if m != nil { if x != nil {
return m.Content return x.Content
} }
return "" return ""
} }
func (m *PushMsgReq) GetRecvSeq() int64 { func (x *PushMsgReq) GetRecvSeq() int64 {
if m != nil { if x != nil {
return m.RecvSeq return x.RecvSeq
} }
return 0 return 0
} }
func (m *PushMsgReq) GetSendTime() int64 { func (x *PushMsgReq) GetSendTime() int64 {
if m != nil { if x != nil {
return m.SendTime return x.SendTime
} }
return 0 return 0
} }
func (m *PushMsgReq) GetMsgFrom() int32 { func (x *PushMsgReq) GetMsgFrom() int32 {
if m != nil { if x != nil {
return m.MsgFrom return x.MsgFrom
} }
return 0 return 0
} }
func (m *PushMsgReq) GetContentType() int32 { func (x *PushMsgReq) GetContentType() int32 {
if m != nil { if x != nil {
return m.ContentType return x.ContentType
} }
return 0 return 0
} }
func (m *PushMsgReq) GetSessionType() int32 { func (x *PushMsgReq) GetSessionType() int32 {
if m != nil { if x != nil {
return m.SessionType return x.SessionType
} }
return 0 return 0
} }
func (m *PushMsgReq) GetOperationID() string { func (x *PushMsgReq) GetOperationID() string {
if m != nil { if x != nil {
return m.OperationID return x.OperationID
} }
return "" return ""
} }
func (m *PushMsgReq) GetMsgID() string { func (x *PushMsgReq) GetMsgID() string {
if m != nil { if x != nil {
return m.MsgID return x.MsgID
} }
return "" return ""
} }
func (m *PushMsgReq) GetOfflineInfo() string { func (x *PushMsgReq) GetOfflineInfo() string {
if m != nil { if x != nil {
return m.OfflineInfo return x.OfflineInfo
} }
return "" return ""
} }
func (m *PushMsgReq) GetOptions() string { func (x *PushMsgReq) GetOptions() string {
if m != nil { if x != nil {
return m.Options return x.Options
} }
return "" return ""
} }
func (m *PushMsgReq) GetPlatformID() int32 { func (x *PushMsgReq) GetPlatformID() int32 {
if m != nil { if x != nil {
return m.PlatformID return x.PlatformID
} }
return 0 return 0
} }
func (m *PushMsgReq) GetSenderNickName() string { func (x *PushMsgReq) GetSenderNickName() string {
if m != nil { if x != nil {
return m.SenderNickName return x.SenderNickName
} }
return "" return ""
} }
func (m *PushMsgReq) GetSenderFaceURL() string { func (x *PushMsgReq) GetSenderFaceURL() string {
if m != nil { if x != nil {
return m.SenderFaceURL return x.SenderFaceURL
} }
return "" return ""
} }
func (m *PushMsgReq) GetClientMsgID() string { func (x *PushMsgReq) GetClientMsgID() string {
if m != nil { if x != nil {
return m.ClientMsgID return x.ClientMsgID
} }
return "" return ""
} }
type PushMsgResp struct { type PushMsgResp struct {
ResultCode int32 `protobuf:"varint,1,opt,name=ResultCode" json:"ResultCode,omitempty"` state protoimpl.MessageState
XXX_NoUnkeyedLiteral struct{} `json:"-"` sizeCache protoimpl.SizeCache
XXX_unrecognized []byte `json:"-"` unknownFields protoimpl.UnknownFields
XXX_sizecache int32 `json:"-"`
}
func (m *PushMsgResp) Reset() { *m = PushMsgResp{} } ResultCode int32 `protobuf:"varint,1,opt,name=ResultCode,proto3" json:"ResultCode,omitempty"`
func (m *PushMsgResp) String() string { return proto.CompactTextString(m) }
func (*PushMsgResp) ProtoMessage() {}
func (*PushMsgResp) Descriptor() ([]byte, []int) {
return fileDescriptor_push_a8d13c8ad86fddce, []int{1}
}
func (m *PushMsgResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_PushMsgResp.Unmarshal(m, b)
}
func (m *PushMsgResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_PushMsgResp.Marshal(b, m, deterministic)
}
func (dst *PushMsgResp) XXX_Merge(src proto.Message) {
xxx_messageInfo_PushMsgResp.Merge(dst, src)
}
func (m *PushMsgResp) XXX_Size() int {
return xxx_messageInfo_PushMsgResp.Size(m)
}
func (m *PushMsgResp) XXX_DiscardUnknown() {
xxx_messageInfo_PushMsgResp.DiscardUnknown(m)
} }
var xxx_messageInfo_PushMsgResp proto.InternalMessageInfo func (x *PushMsgResp) Reset() {
*x = PushMsgResp{}
func (m *PushMsgResp) GetResultCode() int32 { if protoimpl.UnsafeEnabled {
if m != nil { mi := &file_push_push_proto_msgTypes[1]
return m.ResultCode ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
} }
return 0
} }
func init() { func (x *PushMsgResp) String() string {
proto.RegisterType((*PushMsgReq)(nil), "push.PushMsgReq") return protoimpl.X.MessageStringOf(x)
proto.RegisterType((*PushMsgResp)(nil), "push.PushMsgResp")
} }
// Reference imports to suppress errors if they are not otherwise used. func (*PushMsgResp) ProtoMessage() {}
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
// Client API for PushMsgService service
type PushMsgServiceClient interface {
PushMsg(ctx context.Context, in *PushMsgReq, opts ...grpc.CallOption) (*PushMsgResp, error)
}
type pushMsgServiceClient struct { func (x *PushMsgResp) ProtoReflect() protoreflect.Message {
cc *grpc.ClientConn mi := &file_push_push_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
} }
func NewPushMsgServiceClient(cc *grpc.ClientConn) PushMsgServiceClient { // Deprecated: Use PushMsgResp.ProtoReflect.Descriptor instead.
return &pushMsgServiceClient{cc} func (*PushMsgResp) Descriptor() ([]byte, []int) {
return file_push_push_proto_rawDescGZIP(), []int{1}
} }
func (c *pushMsgServiceClient) PushMsg(ctx context.Context, in *PushMsgReq, opts ...grpc.CallOption) (*PushMsgResp, error) { func (x *PushMsgResp) GetResultCode() int32 {
out := new(PushMsgResp) if x != nil {
err := grpc.Invoke(ctx, "/push.PushMsgService/PushMsg", in, out, c.cc, opts...) return x.ResultCode
if err != nil {
return nil, err
} }
return out, nil return 0
} }
// Server API for PushMsgService service var File_push_push_proto protoreflect.FileDescriptor
var file_push_push_proto_rawDesc = []byte{
0x0a, 0x0f, 0x70, 0x75, 0x73, 0x68, 0x2f, 0x70, 0x75, 0x73, 0x68, 0x2e, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x12, 0x04, 0x70, 0x75, 0x73, 0x68, 0x22, 0xee, 0x03, 0x0a, 0x0a, 0x50, 0x75, 0x73, 0x68,
0x4d, 0x73, 0x67, 0x52, 0x65, 0x71, 0x12, 0x16, 0x0a, 0x06, 0x53, 0x65, 0x6e, 0x64, 0x49, 0x44,
0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x53, 0x65, 0x6e, 0x64, 0x49, 0x44, 0x12, 0x16,
0x0a, 0x06, 0x52, 0x65, 0x63, 0x76, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06,
0x52, 0x65, 0x63, 0x76, 0x49, 0x44, 0x12, 0x18, 0x0a, 0x07, 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e,
0x74, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74,
0x12, 0x18, 0x0a, 0x07, 0x52, 0x65, 0x63, 0x76, 0x53, 0x65, 0x71, 0x18, 0x04, 0x20, 0x01, 0x28,
0x03, 0x52, 0x07, 0x52, 0x65, 0x63, 0x76, 0x53, 0x65, 0x71, 0x12, 0x1a, 0x0a, 0x08, 0x53, 0x65,
0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x03, 0x52, 0x08, 0x53, 0x65,
0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x4d, 0x73, 0x67, 0x46, 0x72, 0x6f,
0x6d, 0x18, 0x06, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x4d, 0x73, 0x67, 0x46, 0x72, 0x6f, 0x6d,
0x12, 0x20, 0x0a, 0x0b, 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x18,
0x07, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x54, 0x79,
0x70, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70,
0x65, 0x18, 0x08, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x53, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e,
0x54, 0x79, 0x70, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f,
0x6e, 0x49, 0x44, 0x18, 0x09, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x4f, 0x70, 0x65, 0x72, 0x61,
0x74, 0x69, 0x6f, 0x6e, 0x49, 0x44, 0x12, 0x14, 0x0a, 0x05, 0x4d, 0x73, 0x67, 0x49, 0x44, 0x18,
0x0a, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x4d, 0x73, 0x67, 0x49, 0x44, 0x12, 0x20, 0x0a, 0x0b,
0x4f, 0x66, 0x66, 0x6c, 0x69, 0x6e, 0x65, 0x49, 0x6e, 0x66, 0x6f, 0x18, 0x0b, 0x20, 0x01, 0x28,
0x09, 0x52, 0x0b, 0x4f, 0x66, 0x66, 0x6c, 0x69, 0x6e, 0x65, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x18,
0x0a, 0x07, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x09, 0x52,
0x07, 0x4f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x1e, 0x0a, 0x0a, 0x50, 0x6c, 0x61, 0x74,
0x66, 0x6f, 0x72, 0x6d, 0x49, 0x44, 0x18, 0x0d, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x50, 0x6c,
0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x49, 0x44, 0x12, 0x26, 0x0a, 0x0e, 0x53, 0x65, 0x6e, 0x64,
0x65, 0x72, 0x4e, 0x69, 0x63, 0x6b, 0x4e, 0x61, 0x6d, 0x65, 0x18, 0x0e, 0x20, 0x01, 0x28, 0x09,
0x52, 0x0e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x4e, 0x69, 0x63, 0x6b, 0x4e, 0x61, 0x6d, 0x65,
0x12, 0x24, 0x0a, 0x0d, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x46, 0x61, 0x63, 0x65, 0x55, 0x52,
0x4c, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x46,
0x61, 0x63, 0x65, 0x55, 0x52, 0x4c, 0x12, 0x20, 0x0a, 0x0b, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74,
0x4d, 0x73, 0x67, 0x49, 0x44, 0x18, 0x10, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x43, 0x6c, 0x69,
0x65, 0x6e, 0x74, 0x4d, 0x73, 0x67, 0x49, 0x44, 0x22, 0x2d, 0x0a, 0x0b, 0x50, 0x75, 0x73, 0x68,
0x4d, 0x73, 0x67, 0x52, 0x65, 0x73, 0x70, 0x12, 0x1e, 0x0a, 0x0a, 0x52, 0x65, 0x73, 0x75, 0x6c,
0x74, 0x43, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x52, 0x65, 0x73,
0x75, 0x6c, 0x74, 0x43, 0x6f, 0x64, 0x65, 0x32, 0x40, 0x0a, 0x0e, 0x50, 0x75, 0x73, 0x68, 0x4d,
0x73, 0x67, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x2e, 0x0a, 0x07, 0x50, 0x75, 0x73,
0x68, 0x4d, 0x73, 0x67, 0x12, 0x10, 0x2e, 0x70, 0x75, 0x73, 0x68, 0x2e, 0x50, 0x75, 0x73, 0x68,
0x4d, 0x73, 0x67, 0x52, 0x65, 0x71, 0x1a, 0x11, 0x2e, 0x70, 0x75, 0x73, 0x68, 0x2e, 0x50, 0x75,
0x73, 0x68, 0x4d, 0x73, 0x67, 0x52, 0x65, 0x73, 0x70, 0x42, 0x0f, 0x5a, 0x0d, 0x2e, 0x2f, 0x70,
0x75, 0x73, 0x68, 0x3b, 0x70, 0x62, 0x50, 0x75, 0x73, 0x68, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74,
0x6f, 0x33,
}
var (
file_push_push_proto_rawDescOnce sync.Once
file_push_push_proto_rawDescData = file_push_push_proto_rawDesc
)
type PushMsgServiceServer interface { func file_push_push_proto_rawDescGZIP() []byte {
PushMsg(context.Context, *PushMsgReq) (*PushMsgResp, error) file_push_push_proto_rawDescOnce.Do(func() {
file_push_push_proto_rawDescData = protoimpl.X.CompressGZIP(file_push_push_proto_rawDescData)
})
return file_push_push_proto_rawDescData
} }
func RegisterPushMsgServiceServer(s *grpc.Server, srv PushMsgServiceServer) { var file_push_push_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
s.RegisterService(&_PushMsgService_serviceDesc, srv) var file_push_push_proto_goTypes = []interface{}{
(*PushMsgReq)(nil), // 0: push.PushMsgReq
(*PushMsgResp)(nil), // 1: push.PushMsgResp
}
var file_push_push_proto_depIdxs = []int32{
0, // 0: push.PushMsgService.PushMsg:input_type -> push.PushMsgReq
1, // 1: push.PushMsgService.PushMsg:output_type -> push.PushMsgResp
1, // [1:2] is the sub-list for method output_type
0, // [0:1] is the sub-list for method input_type
0, // [0:0] is the sub-list for extension type_name
0, // [0:0] is the sub-list for extension extendee
0, // [0:0] is the sub-list for field type_name
} }
func _PushMsgService_PushMsg_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func init() { file_push_push_proto_init() }
in := new(PushMsgReq) func file_push_push_proto_init() {
if err := dec(in); err != nil { if File_push_push_proto != nil {
return nil, err return
} }
if interceptor == nil { if !protoimpl.UnsafeEnabled {
return srv.(PushMsgServiceServer).PushMsg(ctx, in) file_push_push_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*PushMsgReq); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_push_push_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*PushMsgResp); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
} }
info := &grpc.UnaryServerInfo{ type x struct{}
Server: srv, out := protoimpl.TypeBuilder{
FullMethod: "/push.PushMsgService/PushMsg", File: protoimpl.DescBuilder{
} GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
handler := func(ctx context.Context, req interface{}) (interface{}, error) { RawDescriptor: file_push_push_proto_rawDesc,
return srv.(PushMsgServiceServer).PushMsg(ctx, req.(*PushMsgReq)) NumEnums: 0,
} NumMessages: 2,
return interceptor(ctx, in, info, handler) NumExtensions: 0,
} NumServices: 1,
var _PushMsgService_serviceDesc = grpc.ServiceDesc{
ServiceName: "push.PushMsgService",
HandlerType: (*PushMsgServiceServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "PushMsg",
Handler: _PushMsgService_PushMsg_Handler,
}, },
}, GoTypes: file_push_push_proto_goTypes,
Streams: []grpc.StreamDesc{}, DependencyIndexes: file_push_push_proto_depIdxs,
Metadata: "push/push.proto", MessageInfos: file_push_push_proto_msgTypes,
} }.Build()
File_push_push_proto = out.File
func init() { proto.RegisterFile("push/push.proto", fileDescriptor_push_a8d13c8ad86fddce) } file_push_push_proto_rawDesc = nil
file_push_push_proto_goTypes = nil
var fileDescriptor_push_a8d13c8ad86fddce = []byte{ file_push_push_proto_depIdxs = nil
// 377 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x5c, 0x92, 0x5d, 0xeb, 0xda, 0x30,
0x14, 0xc6, 0xe9, 0xb4, 0xbe, 0x9c, 0xce, 0x97, 0x85, 0x31, 0x82, 0x17, 0xa3, 0xc8, 0x18, 0xde,
0xcc, 0xc1, 0x76, 0xb9, 0x9b, 0x31, 0x8b, 0x50, 0x98, 0x2f, 0xa4, 0xee, 0x66, 0x77, 0xb5, 0x9e,
0x6a, 0x59, 0x9b, 0xc4, 0xa6, 0x0a, 0xfb, 0xd2, 0xfb, 0x0c, 0x23, 0x49, 0xd5, 0xfe, 0xbd, 0x29,
0x7d, 0x7e, 0xe7, 0x39, 0x87, 0x27, 0xc9, 0x81, 0x91, 0xbc, 0xa8, 0xd3, 0x67, 0xfd, 0x99, 0xcb,
0x52, 0x54, 0x82, 0xb4, 0xf5, 0xff, 0xf4, 0x5f, 0x0b, 0x60, 0x7b, 0x51, 0xa7, 0x95, 0x3a, 0x32,
0x3c, 0x93, 0x77, 0xd0, 0x89, 0x90, 0x1f, 0xc2, 0x80, 0x3a, 0xbe, 0x33, 0xeb, 0xb3, 0x5a, 0x69,
0xce, 0x30, 0xb9, 0x86, 0x01, 0x7d, 0x65, 0xb9, 0x55, 0x84, 0x42, 0x77, 0x21, 0x78, 0x85, 0xbc,
0xa2, 0x2d, 0x53, 0xb8, 0x49, 0x5d, 0xd1, 0x9e, 0x08, 0xcf, 0xb4, 0xed, 0x3b, 0xb3, 0x16, 0xbb,
0x49, 0x32, 0x81, 0x9e, 0x9e, 0xba, 0xcb, 0x0a, 0xa4, 0xae, 0x29, 0xdd, 0xb5, 0xee, 0x5a, 0xa9,
0xe3, 0xb2, 0x14, 0x05, 0xed, 0xf8, 0xce, 0xcc, 0x65, 0x37, 0x49, 0x7c, 0xf0, 0xea, 0xd1, 0xbb,
0xbf, 0x12, 0x69, 0xd7, 0x54, 0x9b, 0x48, 0x3b, 0x22, 0x54, 0x2a, 0x13, 0xdc, 0x38, 0x7a, 0xd6,
0xd1, 0x40, 0xda, 0xb1, 0x91, 0x58, 0xc6, 0x55, 0x26, 0x78, 0x18, 0xd0, 0xbe, 0x49, 0xdc, 0x44,
0xe4, 0x2d, 0xb8, 0x2b, 0x75, 0x0c, 0x03, 0x0a, 0xa6, 0x66, 0x85, 0xe9, 0x4b, 0xd3, 0x3c, 0xe3,
0x18, 0xf2, 0x54, 0x50, 0xaf, 0xee, 0x7b, 0x20, 0x9d, 0x7b, 0x23, 0xf5, 0x0c, 0x45, 0x5f, 0xdb,
0x7b, 0xa8, 0x25, 0x79, 0x0f, 0xb0, 0xcd, 0xe3, 0x2a, 0x15, 0x65, 0x11, 0x06, 0x74, 0x60, 0x42,
0x35, 0x08, 0xf9, 0x08, 0x43, 0x7d, 0x7a, 0x2c, 0xd7, 0x59, 0xf2, 0x67, 0x1d, 0x17, 0x48, 0x87,
0x66, 0xc0, 0x13, 0x25, 0x1f, 0x60, 0x60, 0xc9, 0x32, 0x4e, 0xf0, 0x17, 0xfb, 0x49, 0x47, 0xc6,
0xf6, 0x12, 0x9a, 0x5b, 0xca, 0x33, 0xe4, 0x95, 0x3d, 0xc5, 0xd8, 0x26, 0x6d, 0xa0, 0xe9, 0x27,
0xf0, 0xee, 0xef, 0xad, 0xa4, 0x8e, 0xc7, 0x50, 0x5d, 0xf2, 0x6a, 0x21, 0x0e, 0x68, 0x1e, 0xdd,
0x65, 0x0d, 0xf2, 0xe5, 0x3b, 0x0c, 0x6b, 0x7b, 0x84, 0xe5, 0x35, 0x4b, 0x90, 0xcc, 0xa1, 0x5b,
0x13, 0x32, 0x9e, 0x9b, 0x7d, 0x7a, 0xec, 0xcf, 0xe4, 0xcd, 0x13, 0x51, 0xf2, 0xc7, 0xe0, 0xb7,
0xa7, 0xd9, 0x37, 0xb9, 0xd7, 0x74, 0xdf, 0x31, 0xdb, 0xf7, 0xf5, 0x7f, 0x00, 0x00, 0x00, 0xff,
0xff, 0x50, 0x88, 0x84, 0xf6, 0x90, 0x02, 0x00, 0x00,
} }

583
src/proto/relay/relay.pb.go
Unescape View File

@ -1,209 +1,224 @@
// Code generated by protoc-gen-go. DO NOT EDIT. // Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.26.0
// protoc v3.7.1
// source: relay/relay.proto // source: relay/relay.proto
package pbRelay // import "relay" package pbRelay
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import ( import (
context "golang.org/x/net/context" protoreflect "google.golang.org/protobuf/reflect/protoreflect"
grpc "google.golang.org/grpc" protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
) )
// Reference imports to suppress errors if they are not otherwise used. const (
var _ = proto.Marshal // Verify that this generated code is sufficiently up-to-date.
var _ = fmt.Errorf _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
var _ = math.Inf // Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
// 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.ProtoPackageIsVersion2 // please upgrade the proto package
type MsgToUserReq struct { type MsgToUserReq struct {
SendID string `protobuf:"bytes,1,opt,name=SendID" json:"SendID,omitempty"` state protoimpl.MessageState
RecvID string `protobuf:"bytes,2,opt,name=RecvID" json:"RecvID,omitempty"` sizeCache protoimpl.SizeCache
Content string `protobuf:"bytes,5,opt,name=Content" json:"Content,omitempty"` unknownFields protoimpl.UnknownFields
RecvSeq int64 `protobuf:"varint,6,opt,name=RecvSeq" json:"RecvSeq,omitempty"`
SendTime int64 `protobuf:"varint,7,opt,name=SendTime" json:"SendTime,omitempty"` SendID string `protobuf:"bytes,1,opt,name=SendID,proto3" json:"SendID,omitempty"`
MsgFrom int32 `protobuf:"varint,8,opt,name=MsgFrom" json:"MsgFrom,omitempty"` RecvID string `protobuf:"bytes,2,opt,name=RecvID,proto3" json:"RecvID,omitempty"`
ContentType int32 `protobuf:"varint,9,opt,name=ContentType" json:"ContentType,omitempty"` Content string `protobuf:"bytes,5,opt,name=Content,proto3" json:"Content,omitempty"`
SessionType int32 `protobuf:"varint,10,opt,name=SessionType" json:"SessionType,omitempty"` RecvSeq int64 `protobuf:"varint,6,opt,name=RecvSeq,proto3" json:"RecvSeq,omitempty"`
OperationID string `protobuf:"bytes,11,opt,name=OperationID" json:"OperationID,omitempty"` SendTime int64 `protobuf:"varint,7,opt,name=SendTime,proto3" json:"SendTime,omitempty"`
ServerMsgID string `protobuf:"bytes,12,opt,name=ServerMsgID" json:"ServerMsgID,omitempty"` MsgFrom int32 `protobuf:"varint,8,opt,name=MsgFrom,proto3" json:"MsgFrom,omitempty"`
PlatformID int32 `protobuf:"varint,13,opt,name=PlatformID" json:"PlatformID,omitempty"` ContentType int32 `protobuf:"varint,9,opt,name=ContentType,proto3" json:"ContentType,omitempty"`
SenderNickName string `protobuf:"bytes,14,opt,name=SenderNickName" json:"SenderNickName,omitempty"` SessionType int32 `protobuf:"varint,10,opt,name=SessionType,proto3" json:"SessionType,omitempty"`
SenderFaceURL string `protobuf:"bytes,15,opt,name=SenderFaceURL" json:"SenderFaceURL,omitempty"` OperationID string `protobuf:"bytes,11,opt,name=OperationID,proto3" json:"OperationID,omitempty"`
ClientMsgID string `protobuf:"bytes,16,opt,name=ClientMsgID" json:"ClientMsgID,omitempty"` ServerMsgID string `protobuf:"bytes,12,opt,name=ServerMsgID,proto3" json:"ServerMsgID,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` PlatformID int32 `protobuf:"varint,13,opt,name=PlatformID,proto3" json:"PlatformID,omitempty"`
XXX_unrecognized []byte `json:"-"` SenderNickName string `protobuf:"bytes,14,opt,name=SenderNickName,proto3" json:"SenderNickName,omitempty"`
XXX_sizecache int32 `json:"-"` SenderFaceURL string `protobuf:"bytes,15,opt,name=SenderFaceURL,proto3" json:"SenderFaceURL,omitempty"`
} ClientMsgID string `protobuf:"bytes,16,opt,name=ClientMsgID,proto3" json:"ClientMsgID,omitempty"`
}
func (m *MsgToUserReq) Reset() { *m = MsgToUserReq{} }
func (m *MsgToUserReq) String() string { return proto.CompactTextString(m) } func (x *MsgToUserReq) Reset() {
func (*MsgToUserReq) ProtoMessage() {} *x = MsgToUserReq{}
func (*MsgToUserReq) Descriptor() ([]byte, []int) { if protoimpl.UnsafeEnabled {
return fileDescriptor_relay_1ba173c940428df4, []int{0} mi := &file_relay_relay_proto_msgTypes[0]
} ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
func (m *MsgToUserReq) XXX_Unmarshal(b []byte) error { ms.StoreMessageInfo(mi)
return xxx_messageInfo_MsgToUserReq.Unmarshal(m, b) }
}
func (m *MsgToUserReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MsgToUserReq.Marshal(b, m, deterministic)
}
func (dst *MsgToUserReq) XXX_Merge(src proto.Message) {
xxx_messageInfo_MsgToUserReq.Merge(dst, src)
} }
func (m *MsgToUserReq) XXX_Size() int {
return xxx_messageInfo_MsgToUserReq.Size(m) func (x *MsgToUserReq) String() string {
return protoimpl.X.MessageStringOf(x)
} }
func (m *MsgToUserReq) XXX_DiscardUnknown() {
xxx_messageInfo_MsgToUserReq.DiscardUnknown(m) func (*MsgToUserReq) ProtoMessage() {}
func (x *MsgToUserReq) ProtoReflect() protoreflect.Message {
mi := &file_relay_relay_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
} }
var xxx_messageInfo_MsgToUserReq proto.InternalMessageInfo // Deprecated: Use MsgToUserReq.ProtoReflect.Descriptor instead.
func (*MsgToUserReq) Descriptor() ([]byte, []int) {
return file_relay_relay_proto_rawDescGZIP(), []int{0}
}
func (m *MsgToUserReq) GetSendID() string { func (x *MsgToUserReq) GetSendID() string {
if m != nil { if x != nil {
return m.SendID return x.SendID
} }
return "" return ""
} }
func (m *MsgToUserReq) GetRecvID() string { func (x *MsgToUserReq) GetRecvID() string {
if m != nil { if x != nil {
return m.RecvID return x.RecvID
} }
return "" return ""
} }
func (m *MsgToUserReq) GetContent() string { func (x *MsgToUserReq) GetContent() string {
if m != nil { if x != nil {
return m.Content return x.Content
} }
return "" return ""
} }
func (m *MsgToUserReq) GetRecvSeq() int64 { func (x *MsgToUserReq) GetRecvSeq() int64 {
if m != nil { if x != nil {
return m.RecvSeq return x.RecvSeq
} }
return 0 return 0
} }
func (m *MsgToUserReq) GetSendTime() int64 { func (x *MsgToUserReq) GetSendTime() int64 {
if m != nil { if x != nil {
return m.SendTime return x.SendTime
} }
return 0 return 0
} }
func (m *MsgToUserReq) GetMsgFrom() int32 { func (x *MsgToUserReq) GetMsgFrom() int32 {
if m != nil { if x != nil {
return m.MsgFrom return x.MsgFrom
} }
return 0 return 0
} }
func (m *MsgToUserReq) GetContentType() int32 { func (x *MsgToUserReq) GetContentType() int32 {
if m != nil { if x != nil {
return m.ContentType return x.ContentType
} }
return 0 return 0
} }
func (m *MsgToUserReq) GetSessionType() int32 { func (x *MsgToUserReq) GetSessionType() int32 {
if m != nil { if x != nil {
return m.SessionType return x.SessionType
} }
return 0 return 0
} }
func (m *MsgToUserReq) GetOperationID() string { func (x *MsgToUserReq) GetOperationID() string {
if m != nil { if x != nil {
return m.OperationID return x.OperationID
} }
return "" return ""
} }
func (m *MsgToUserReq) GetServerMsgID() string { func (x *MsgToUserReq) GetServerMsgID() string {
if m != nil { if x != nil {
return m.ServerMsgID return x.ServerMsgID
} }
return "" return ""
} }
func (m *MsgToUserReq) GetPlatformID() int32 { func (x *MsgToUserReq) GetPlatformID() int32 {
if m != nil { if x != nil {
return m.PlatformID return x.PlatformID
} }
return 0 return 0
} }
func (m *MsgToUserReq) GetSenderNickName() string { func (x *MsgToUserReq) GetSenderNickName() string {
if m != nil { if x != nil {
return m.SenderNickName return x.SenderNickName
} }
return "" return ""
} }
func (m *MsgToUserReq) GetSenderFaceURL() string { func (x *MsgToUserReq) GetSenderFaceURL() string {
if m != nil { if x != nil {
return m.SenderFaceURL return x.SenderFaceURL
} }
return "" return ""
} }
func (m *MsgToUserReq) GetClientMsgID() string { func (x *MsgToUserReq) GetClientMsgID() string {
if m != nil { if x != nil {
return m.ClientMsgID return x.ClientMsgID
} }
return "" return ""
} }
type MsgToUserResp struct { type MsgToUserResp struct {
Resp []*SingleMsgToUser `protobuf:"bytes,1,rep,name=resp" json:"resp,omitempty"` state protoimpl.MessageState
XXX_NoUnkeyedLiteral struct{} `json:"-"` sizeCache protoimpl.SizeCache
XXX_unrecognized []byte `json:"-"` unknownFields protoimpl.UnknownFields
XXX_sizecache int32 `json:"-"`
}
func (m *MsgToUserResp) Reset() { *m = MsgToUserResp{} } Resp []*SingleMsgToUser `protobuf:"bytes,1,rep,name=resp,proto3" json:"resp,omitempty"`
func (m *MsgToUserResp) String() string { return proto.CompactTextString(m) }
func (*MsgToUserResp) ProtoMessage() {}
func (*MsgToUserResp) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_1ba173c940428df4, []int{1}
}
func (m *MsgToUserResp) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_MsgToUserResp.Unmarshal(m, b)
} }
func (m *MsgToUserResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_MsgToUserResp.Marshal(b, m, deterministic) func (x *MsgToUserResp) Reset() {
} *x = MsgToUserResp{}
func (dst *MsgToUserResp) XXX_Merge(src proto.Message) { if protoimpl.UnsafeEnabled {
xxx_messageInfo_MsgToUserResp.Merge(dst, src) mi := &file_relay_relay_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
} }
func (m *MsgToUserResp) XXX_Size() int {
return xxx_messageInfo_MsgToUserResp.Size(m) func (x *MsgToUserResp) String() string {
return protoimpl.X.MessageStringOf(x)
} }
func (m *MsgToUserResp) XXX_DiscardUnknown() {
xxx_messageInfo_MsgToUserResp.DiscardUnknown(m) func (*MsgToUserResp) ProtoMessage() {}
func (x *MsgToUserResp) ProtoReflect() protoreflect.Message {
mi := &file_relay_relay_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
} }
var xxx_messageInfo_MsgToUserResp proto.InternalMessageInfo // Deprecated: Use MsgToUserResp.ProtoReflect.Descriptor instead.
func (*MsgToUserResp) Descriptor() ([]byte, []int) {
return file_relay_relay_proto_rawDescGZIP(), []int{1}
}
func (m *MsgToUserResp) GetResp() []*SingleMsgToUser { func (x *MsgToUserResp) GetResp() []*SingleMsgToUser {
if m != nil { if x != nil {
return m.Resp return x.Resp
} }
return nil return nil
} }
// message SendMsgByWSReq{ //message SendMsgByWSReq{
// string SendID = 1; // string SendID = 1;
// string RecvID = 2; // string RecvID = 2;
// string Content = 3; // string Content = 3;
@ -213,167 +228,211 @@ func (m *MsgToUserResp) GetResp() []*SingleMsgToUser {
// int64 SessionType = 7; // int64 SessionType = 7;
// string OperationID = 8; // string OperationID = 8;
// int64 PlatformID = 9; // int64 PlatformID = 9;
// } //}
type SingleMsgToUser struct { type SingleMsgToUser struct {
ResultCode int64 `protobuf:"varint,1,opt,name=ResultCode" json:"ResultCode,omitempty"` state protoimpl.MessageState
RecvID string `protobuf:"bytes,2,opt,name=RecvID" json:"RecvID,omitempty"` sizeCache protoimpl.SizeCache
RecvPlatFormID int32 `protobuf:"varint,3,opt,name=RecvPlatFormID" json:"RecvPlatFormID,omitempty"` unknownFields protoimpl.UnknownFields
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SingleMsgToUser) Reset() { *m = SingleMsgToUser{} } ResultCode int64 `protobuf:"varint,1,opt,name=ResultCode,proto3" json:"ResultCode,omitempty"`
func (m *SingleMsgToUser) String() string { return proto.CompactTextString(m) } RecvID string `protobuf:"bytes,2,opt,name=RecvID,proto3" json:"RecvID,omitempty"`
func (*SingleMsgToUser) ProtoMessage() {} RecvPlatFormID int32 `protobuf:"varint,3,opt,name=RecvPlatFormID,proto3" json:"RecvPlatFormID,omitempty"`
func (*SingleMsgToUser) Descriptor() ([]byte, []int) {
return fileDescriptor_relay_1ba173c940428df4, []int{2}
}
func (m *SingleMsgToUser) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SingleMsgToUser.Unmarshal(m, b)
}
func (m *SingleMsgToUser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SingleMsgToUser.Marshal(b, m, deterministic)
} }
func (dst *SingleMsgToUser) XXX_Merge(src proto.Message) {
xxx_messageInfo_SingleMsgToUser.Merge(dst, src)
}
func (m *SingleMsgToUser) XXX_Size() int {
return xxx_messageInfo_SingleMsgToUser.Size(m)
}
func (m *SingleMsgToUser) XXX_DiscardUnknown() {
xxx_messageInfo_SingleMsgToUser.DiscardUnknown(m)
}
var xxx_messageInfo_SingleMsgToUser proto.InternalMessageInfo
func (m *SingleMsgToUser) GetResultCode() int64 { func (x *SingleMsgToUser) Reset() {
if m != nil { *x = SingleMsgToUser{}
return m.ResultCode if protoimpl.UnsafeEnabled {
mi := &file_relay_relay_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
} }
return 0
} }
func (m *SingleMsgToUser) GetRecvID() string { func (x *SingleMsgToUser) String() string {
if m != nil { return protoimpl.X.MessageStringOf(x)
return m.RecvID
}
return ""
} }
func (m *SingleMsgToUser) GetRecvPlatFormID() int32 { func (*SingleMsgToUser) ProtoMessage() {}
if m != nil {
return m.RecvPlatFormID
}
return 0
}
func init() {
proto.RegisterType((*MsgToUserReq)(nil), "relay.MsgToUserReq")
proto.RegisterType((*MsgToUserResp)(nil), "relay.MsgToUserResp")
proto.RegisterType((*SingleMsgToUser)(nil), "relay.SingleMsgToUser")
}
// 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
// Client API for OnlineMessageRelayService service
type OnlineMessageRelayServiceClient interface { func (x *SingleMsgToUser) ProtoReflect() protoreflect.Message {
MsgToUser(ctx context.Context, in *MsgToUserReq, opts ...grpc.CallOption) (*MsgToUserResp, error) mi := &file_relay_relay_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
} }
type onlineMessageRelayServiceClient struct { // Deprecated: Use SingleMsgToUser.ProtoReflect.Descriptor instead.
cc *grpc.ClientConn func (*SingleMsgToUser) Descriptor() ([]byte, []int) {
return file_relay_relay_proto_rawDescGZIP(), []int{2}
} }
func NewOnlineMessageRelayServiceClient(cc *grpc.ClientConn) OnlineMessageRelayServiceClient { func (x *SingleMsgToUser) GetResultCode() int64 {
return &onlineMessageRelayServiceClient{cc} if x != nil {
return x.ResultCode
}
return 0
} }
func (c *onlineMessageRelayServiceClient) MsgToUser(ctx context.Context, in *MsgToUserReq, opts ...grpc.CallOption) (*MsgToUserResp, error) { func (x *SingleMsgToUser) GetRecvID() string {
out := new(MsgToUserResp) if x != nil {
err := grpc.Invoke(ctx, "/relay.OnlineMessageRelayService/MsgToUser", in, out, c.cc, opts...) return x.RecvID
if err != nil {
return nil, err
} }
return out, nil return ""
} }
// Server API for OnlineMessageRelayService service func (x *SingleMsgToUser) GetRecvPlatFormID() int32 {
if x != nil {
type OnlineMessageRelayServiceServer interface { return x.RecvPlatFormID
MsgToUser(context.Context, *MsgToUserReq) (*MsgToUserResp, error) }
return 0
} }
func RegisterOnlineMessageRelayServiceServer(s *grpc.Server, srv OnlineMessageRelayServiceServer) { var File_relay_relay_proto protoreflect.FileDescriptor
s.RegisterService(&_OnlineMessageRelayService_serviceDesc, srv)
} var file_relay_relay_proto_rawDesc = []byte{
0x0a, 0x11, 0x72, 0x65, 0x6c, 0x61, 0x79, 0x2f, 0x72, 0x65, 0x6c, 0x61, 0x79, 0x2e, 0x70, 0x72,
0x6f, 0x74, 0x6f, 0x12, 0x05, 0x72, 0x65, 0x6c, 0x61, 0x79, 0x22, 0xc0, 0x03, 0x0a, 0x0c, 0x4d,
0x73, 0x67, 0x54, 0x6f, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, 0x12, 0x16, 0x0a, 0x06, 0x53,
0x65, 0x6e, 0x64, 0x49, 0x44, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x53, 0x65, 0x6e,
0x64, 0x49, 0x44, 0x12, 0x16, 0x0a, 0x06, 0x52, 0x65, 0x63, 0x76, 0x49, 0x44, 0x18, 0x02, 0x20,
0x01, 0x28, 0x09, 0x52, 0x06, 0x52, 0x65, 0x63, 0x76, 0x49, 0x44, 0x12, 0x18, 0x0a, 0x07, 0x43,
0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x43, 0x6f,
0x6e, 0x74, 0x65, 0x6e, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x52, 0x65, 0x63, 0x76, 0x53, 0x65, 0x71,
0x18, 0x06, 0x20, 0x01, 0x28, 0x03, 0x52, 0x07, 0x52, 0x65, 0x63, 0x76, 0x53, 0x65, 0x71, 0x12,
0x1a, 0x0a, 0x08, 0x53, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x18, 0x07, 0x20, 0x01, 0x28,
0x03, 0x52, 0x08, 0x53, 0x65, 0x6e, 0x64, 0x54, 0x69, 0x6d, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x4d,
0x73, 0x67, 0x46, 0x72, 0x6f, 0x6d, 0x18, 0x08, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x4d, 0x73,
0x67, 0x46, 0x72, 0x6f, 0x6d, 0x12, 0x20, 0x0a, 0x0b, 0x43, 0x6f, 0x6e, 0x74, 0x65, 0x6e, 0x74,
0x54, 0x79, 0x70, 0x65, 0x18, 0x09, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x43, 0x6f, 0x6e, 0x74,
0x65, 0x6e, 0x74, 0x54, 0x79, 0x70, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x53, 0x65, 0x73, 0x73, 0x69,
0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x18, 0x0a, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0b, 0x53, 0x65,
0x73, 0x73, 0x69, 0x6f, 0x6e, 0x54, 0x79, 0x70, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x4f, 0x70, 0x65,
0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x44, 0x18, 0x0b, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b,
0x4f, 0x70, 0x65, 0x72, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x44, 0x12, 0x20, 0x0a, 0x0b, 0x53,
0x65, 0x72, 0x76, 0x65, 0x72, 0x4d, 0x73, 0x67, 0x49, 0x44, 0x18, 0x0c, 0x20, 0x01, 0x28, 0x09,
0x52, 0x0b, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x4d, 0x73, 0x67, 0x49, 0x44, 0x12, 0x1e, 0x0a,
0x0a, 0x50, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x49, 0x44, 0x18, 0x0d, 0x20, 0x01, 0x28,
0x05, 0x52, 0x0a, 0x50, 0x6c, 0x61, 0x74, 0x66, 0x6f, 0x72, 0x6d, 0x49, 0x44, 0x12, 0x26, 0x0a,
0x0e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x4e, 0x69, 0x63, 0x6b, 0x4e, 0x61, 0x6d, 0x65, 0x18,
0x0e, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0e, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x4e, 0x69, 0x63,
0x6b, 0x4e, 0x61, 0x6d, 0x65, 0x12, 0x24, 0x0a, 0x0d, 0x53, 0x65, 0x6e, 0x64, 0x65, 0x72, 0x46,
0x61, 0x63, 0x65, 0x55, 0x52, 0x4c, 0x18, 0x0f, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0d, 0x53, 0x65,
0x6e, 0x64, 0x65, 0x72, 0x46, 0x61, 0x63, 0x65, 0x55, 0x52, 0x4c, 0x12, 0x20, 0x0a, 0x0b, 0x43,
0x6c, 0x69, 0x65, 0x6e, 0x74, 0x4d, 0x73, 0x67, 0x49, 0x44, 0x18, 0x10, 0x20, 0x01, 0x28, 0x09,
0x52, 0x0b, 0x43, 0x6c, 0x69, 0x65, 0x6e, 0x74, 0x4d, 0x73, 0x67, 0x49, 0x44, 0x22, 0x3b, 0x0a,
0x0d, 0x4d, 0x73, 0x67, 0x54, 0x6f, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x73, 0x70, 0x12, 0x2a,
0x0a, 0x04, 0x72, 0x65, 0x73, 0x70, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x16, 0x2e, 0x72,
0x65, 0x6c, 0x61, 0x79, 0x2e, 0x53, 0x69, 0x6e, 0x67, 0x6c, 0x65, 0x4d, 0x73, 0x67, 0x54, 0x6f,
0x55, 0x73, 0x65, 0x72, 0x52, 0x04, 0x72, 0x65, 0x73, 0x70, 0x22, 0x71, 0x0a, 0x0f, 0x53, 0x69,
0x6e, 0x67, 0x6c, 0x65, 0x4d, 0x73, 0x67, 0x54, 0x6f, 0x55, 0x73, 0x65, 0x72, 0x12, 0x1e, 0x0a,
0x0a, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x43, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
0x03, 0x52, 0x0a, 0x52, 0x65, 0x73, 0x75, 0x6c, 0x74, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x16, 0x0a,
0x06, 0x52, 0x65, 0x63, 0x76, 0x49, 0x44, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x52,
0x65, 0x63, 0x76, 0x49, 0x44, 0x12, 0x26, 0x0a, 0x0e, 0x52, 0x65, 0x63, 0x76, 0x50, 0x6c, 0x61,
0x74, 0x46, 0x6f, 0x72, 0x6d, 0x49, 0x44, 0x18, 0x03, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0e, 0x52,
0x65, 0x63, 0x76, 0x50, 0x6c, 0x61, 0x74, 0x46, 0x6f, 0x72, 0x6d, 0x49, 0x44, 0x32, 0x53, 0x0a,
0x19, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x52, 0x65,
0x6c, 0x61, 0x79, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x36, 0x0a, 0x09, 0x4d, 0x73,
0x67, 0x54, 0x6f, 0x55, 0x73, 0x65, 0x72, 0x12, 0x13, 0x2e, 0x72, 0x65, 0x6c, 0x61, 0x79, 0x2e,
0x4d, 0x73, 0x67, 0x54, 0x6f, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65, 0x71, 0x1a, 0x14, 0x2e, 0x72,
0x65, 0x6c, 0x61, 0x79, 0x2e, 0x4d, 0x73, 0x67, 0x54, 0x6f, 0x55, 0x73, 0x65, 0x72, 0x52, 0x65,
0x73, 0x70, 0x42, 0x11, 0x5a, 0x0f, 0x2e, 0x2f, 0x72, 0x65, 0x6c, 0x61, 0x79, 0x3b, 0x70, 0x62,
0x52, 0x65, 0x6c, 0x61, 0x79, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}
var (
file_relay_relay_proto_rawDescOnce sync.Once
file_relay_relay_proto_rawDescData = file_relay_relay_proto_rawDesc
)
func _OnlineMessageRelayService_MsgToUser_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { func file_relay_relay_proto_rawDescGZIP() []byte {
in := new(MsgToUserReq) file_relay_relay_proto_rawDescOnce.Do(func() {
if err := dec(in); err != nil { file_relay_relay_proto_rawDescData = protoimpl.X.CompressGZIP(file_relay_relay_proto_rawDescData)
return nil, err })
} return file_relay_relay_proto_rawDescData
if interceptor == nil { }
return srv.(OnlineMessageRelayServiceServer).MsgToUser(ctx, in)
var file_relay_relay_proto_msgTypes = make([]protoimpl.MessageInfo, 3)
var file_relay_relay_proto_goTypes = []interface{}{
(*MsgToUserReq)(nil), // 0: relay.MsgToUserReq
(*MsgToUserResp)(nil), // 1: relay.MsgToUserResp
(*SingleMsgToUser)(nil), // 2: relay.SingleMsgToUser
}
var file_relay_relay_proto_depIdxs = []int32{
2, // 0: relay.MsgToUserResp.resp:type_name -> relay.SingleMsgToUser
0, // 1: relay.OnlineMessageRelayService.MsgToUser:input_type -> relay.MsgToUserReq
1, // 2: relay.OnlineMessageRelayService.MsgToUser:output_type -> relay.MsgToUserResp
2, // [2:3] is the sub-list for method output_type
1, // [1:2] is the sub-list for method input_type
1, // [1:1] is the sub-list for extension type_name
1, // [1:1] is the sub-list for extension extendee
0, // [0:1] is the sub-list for field type_name
}
func init() { file_relay_relay_proto_init() }
func file_relay_relay_proto_init() {
if File_relay_relay_proto != nil {
return
} }
info := &grpc.UnaryServerInfo{ if !protoimpl.UnsafeEnabled {
Server: srv, file_relay_relay_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
FullMethod: "/relay.OnlineMessageRelayService/MsgToUser", switch v := v.(*MsgToUserReq); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_relay_relay_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MsgToUserResp); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_relay_relay_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*SingleMsgToUser); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { type x struct{}
return srv.(OnlineMessageRelayServiceServer).MsgToUser(ctx, req.(*MsgToUserReq)) out := protoimpl.TypeBuilder{
} File: protoimpl.DescBuilder{
return interceptor(ctx, in, info, handler) GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
} RawDescriptor: file_relay_relay_proto_rawDesc,
NumEnums: 0,
var _OnlineMessageRelayService_serviceDesc = grpc.ServiceDesc{ NumMessages: 3,
ServiceName: "relay.OnlineMessageRelayService", NumExtensions: 0,
HandlerType: (*OnlineMessageRelayServiceServer)(nil), NumServices: 1,
Methods: []grpc.MethodDesc{
{
MethodName: "MsgToUser",
Handler: _OnlineMessageRelayService_MsgToUser_Handler,
}, },
}, GoTypes: file_relay_relay_proto_goTypes,
Streams: []grpc.StreamDesc{}, DependencyIndexes: file_relay_relay_proto_depIdxs,
Metadata: "relay/relay.proto", MessageInfos: file_relay_relay_proto_msgTypes,
} }.Build()
File_relay_relay_proto = out.File
func init() { proto.RegisterFile("relay/relay.proto", fileDescriptor_relay_1ba173c940428df4) } file_relay_relay_proto_rawDesc = nil
file_relay_relay_proto_goTypes = nil
var fileDescriptor_relay_1ba173c940428df4 = []byte{ file_relay_relay_proto_depIdxs = nil
// 412 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x92, 0xc1, 0x6f, 0xd3, 0x30,
0x14, 0xc6, 0x15, 0x42, 0xbb, 0xf5, 0x75, 0x6d, 0xc1, 0xa0, 0xc9, 0xec, 0x80, 0xa2, 0x0a, 0x4d,
0x11, 0x87, 0x21, 0x0d, 0x89, 0xcb, 0x6e, 0x2c, 0xaa, 0x14, 0x89, 0x6c, 0xc8, 0xe9, 0x2e, 0xdc,
0xb2, 0xec, 0x11, 0x59, 0x24, 0x76, 0x6a, 0x87, 0x49, 0xfb, 0xef, 0xf8, 0xd3, 0x90, 0x9f, 0x5b,
0x6a, 0x8a, 0xb8, 0x44, 0xf9, 0x7e, 0xef, 0xcb, 0xcb, 0xe7, 0xe7, 0x07, 0x2f, 0x0d, 0xb6, 0xd5,
0xd3, 0x07, 0x7a, 0x5e, 0xf4, 0x46, 0x0f, 0x9a, 0x8d, 0x48, 0x2c, 0x7f, 0xc5, 0x70, 0x52, 0xd8,
0x66, 0xad, 0xef, 0x2c, 0x1a, 0x81, 0x1b, 0x76, 0x0a, 0xe3, 0x12, 0xd5, 0x43, 0x9e, 0xf1, 0x28,
0x89, 0xd2, 0x89, 0xd8, 0x2a, 0xc7, 0x05, 0xd6, 0x8f, 0x79, 0xc6, 0x9f, 0x79, 0xee, 0x15, 0xe3,
0x70, 0x74, 0xad, 0xd5, 0x80, 0x6a, 0xe0, 0x23, 0x2a, 0xec, 0xa4, 0xab, 0x38, 0x4f, 0x89, 0x1b,
0x3e, 0x4e, 0xa2, 0x34, 0x16, 0x3b, 0xc9, 0xce, 0xe0, 0xd8, 0x75, 0x5d, 0xcb, 0x0e, 0xf9, 0x11,
0x95, 0xfe, 0x68, 0xf7, 0x55, 0x61, 0x9b, 0x95, 0xd1, 0x1d, 0x3f, 0x4e, 0xa2, 0x74, 0x24, 0x76,
0x92, 0x25, 0x30, 0xdd, 0xb6, 0x5e, 0x3f, 0xf5, 0xc8, 0x27, 0x54, 0x0d, 0x91, 0x73, 0x94, 0x68,
0xad, 0xd4, 0x8a, 0x1c, 0xe0, 0x1d, 0x01, 0x72, 0x8e, 0xdb, 0x1e, 0x4d, 0x35, 0x48, 0xad, 0xf2,
0x8c, 0x4f, 0x29, 0x71, 0x88, 0x7c, 0x0f, 0xf3, 0x88, 0xa6, 0xb0, 0x4d, 0x9e, 0xf1, 0x13, 0xef,
0x08, 0x10, 0x7b, 0x0b, 0xf0, 0xb5, 0xad, 0x86, 0xef, 0xda, 0x74, 0x79, 0xc6, 0x67, 0xf4, 0x93,
0x80, 0xb0, 0x73, 0x98, 0xbb, 0xd3, 0xa0, 0xb9, 0x91, 0xf5, 0x8f, 0x9b, 0xaa, 0x43, 0x3e, 0xa7,
0x26, 0x07, 0x94, 0xbd, 0x83, 0x99, 0x27, 0xab, 0xaa, 0xc6, 0x3b, 0xf1, 0x85, 0x2f, 0xc8, 0xf6,
0x37, 0xa4, 0x53, 0xb7, 0x12, 0xd5, 0xe0, 0xf3, 0xbc, 0xf0, 0x79, 0x02, 0xb4, 0xbc, 0x82, 0x59,
0x70, 0x83, 0xb6, 0x67, 0xef, 0xe1, 0xb9, 0x41, 0xdb, 0xf3, 0x28, 0x89, 0xd3, 0xe9, 0xe5, 0xe9,
0x85, 0xbf, 0xf6, 0x52, 0xaa, 0xa6, 0xc5, 0xbd, 0x93, 0x3c, 0xcb, 0x0d, 0x2c, 0x0e, 0x0a, 0xee,
0x7c, 0x02, 0xed, 0xcf, 0x76, 0xb8, 0xd6, 0x0f, 0x48, 0x5b, 0x10, 0x8b, 0x80, 0xfc, 0x77, 0x13,
0xce, 0x61, 0xee, 0xde, 0xdc, 0x24, 0x56, 0x7e, 0x36, 0x31, 0xcd, 0xe6, 0x80, 0x5e, 0x96, 0xf0,
0xe6, 0x56, 0xb5, 0x52, 0x61, 0x81, 0xd6, 0x56, 0x0d, 0x0a, 0x17, 0xcf, 0x0d, 0x58, 0xd6, 0xc8,
0x3e, 0xc1, 0x64, 0x9f, 0xe4, 0xd5, 0x36, 0x7a, 0xb8, 0xa0, 0x67, 0xaf, 0xff, 0x85, 0xb6, 0xff,
0xbc, 0xf8, 0x36, 0x23, 0x7c, 0xd5, 0xdf, 0x53, 0xbf, 0xfb, 0x31, 0xad, 0xf9, 0xc7, 0xdf, 0x01,
0x00, 0x00, 0xff, 0xff, 0xca, 0xdd, 0x7b, 0x0c, 0xfb, 0x02, 0x00, 0x00,
} }

1365
src/proto/user/user.pb.go
View File

File diff suppressed because it is too large Load Diff
Write Preview
Loading…
Cancel
Save