From 912b1c20bd749c66d410f51d126e45c4904034fb Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=AE=B7=E5=8B=87?= Date: Mon, 14 Aug 2023 16:28:43 +0800 Subject: [PATCH] =?UTF-8?q?=1B[D1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/imserver/cs/cs_msgid.pb.go | 209 ++++++ server/imserver/cs/cs_proto.pb.go | 1014 +++++++++++++++++++++++++++++ server/imserver/ss/ss_msgid.pb.go | 157 +++++ server/imserver/ss/ss_proto.pb.go | 472 ++++++++++++++ third_party/f5 | 2 +- 5 files changed, 1853 insertions(+), 1 deletion(-) create mode 100644 server/imserver/cs/cs_msgid.pb.go create mode 100644 server/imserver/cs/cs_proto.pb.go create mode 100644 server/imserver/ss/ss_msgid.pb.go create mode 100644 server/imserver/ss/ss_proto.pb.go diff --git a/server/imserver/cs/cs_msgid.pb.go b/server/imserver/cs/cs_msgid.pb.go new file mode 100644 index 00000000..76f49758 --- /dev/null +++ b/server/imserver/cs/cs_msgid.pb.go @@ -0,0 +1,209 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.31.0 +// protoc v4.23.4 +// source: cs_msgid.proto + +package cs + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +// 消息id定义 +type CMMessageIdE int32 + +const ( + CMMessageIdE__CMPing CMMessageIdE = 101 + CMMessageIdE__CMLogin CMMessageIdE = 103 + CMMessageIdE__CMReconnect CMMessageIdE = 104 +) + +// Enum value maps for CMMessageIdE. +var ( + CMMessageIdE_name = map[int32]string{ + 101: "_CMPing", + 103: "_CMLogin", + 104: "_CMReconnect", + } + CMMessageIdE_value = map[string]int32{ + "_CMPing": 101, + "_CMLogin": 103, + "_CMReconnect": 104, + } +) + +func (x CMMessageIdE) Enum() *CMMessageIdE { + p := new(CMMessageIdE) + *p = x + return p +} + +func (x CMMessageIdE) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (CMMessageIdE) Descriptor() protoreflect.EnumDescriptor { + return file_cs_msgid_proto_enumTypes[0].Descriptor() +} + +func (CMMessageIdE) Type() protoreflect.EnumType { + return &file_cs_msgid_proto_enumTypes[0] +} + +func (x CMMessageIdE) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Do not use. +func (x *CMMessageIdE) UnmarshalJSON(b []byte) error { + num, err := protoimpl.X.UnmarshalJSONEnum(x.Descriptor(), b) + if err != nil { + return err + } + *x = CMMessageIdE(num) + return nil +} + +// Deprecated: Use CMMessageIdE.Descriptor instead. +func (CMMessageIdE) EnumDescriptor() ([]byte, []int) { + return file_cs_msgid_proto_rawDescGZIP(), []int{0} +} + +type SMMessageIdE int32 + +const ( + SMMessageIdE__SMPing SMMessageIdE = 101 + SMMessageIdE__SMRpcError SMMessageIdE = 102 + SMMessageIdE__SMReconnect SMMessageIdE = 104 + SMMessageIdE__SMLogin SMMessageIdE = 103 +) + +// Enum value maps for SMMessageIdE. +var ( + SMMessageIdE_name = map[int32]string{ + 101: "_SMPing", + 102: "_SMRpcError", + 104: "_SMReconnect", + 103: "_SMLogin", + } + SMMessageIdE_value = map[string]int32{ + "_SMPing": 101, + "_SMRpcError": 102, + "_SMReconnect": 104, + "_SMLogin": 103, + } +) + +func (x SMMessageIdE) Enum() *SMMessageIdE { + p := new(SMMessageIdE) + *p = x + return p +} + +func (x SMMessageIdE) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (SMMessageIdE) Descriptor() protoreflect.EnumDescriptor { + return file_cs_msgid_proto_enumTypes[1].Descriptor() +} + +func (SMMessageIdE) Type() protoreflect.EnumType { + return &file_cs_msgid_proto_enumTypes[1] +} + +func (x SMMessageIdE) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Do not use. +func (x *SMMessageIdE) UnmarshalJSON(b []byte) error { + num, err := protoimpl.X.UnmarshalJSONEnum(x.Descriptor(), b) + if err != nil { + return err + } + *x = SMMessageIdE(num) + return nil +} + +// Deprecated: Use SMMessageIdE.Descriptor instead. +func (SMMessageIdE) EnumDescriptor() ([]byte, []int) { + return file_cs_msgid_proto_rawDescGZIP(), []int{1} +} + +var File_cs_msgid_proto protoreflect.FileDescriptor + +var file_cs_msgid_proto_rawDesc = []byte{ + 0x0a, 0x0e, 0x63, 0x73, 0x5f, 0x6d, 0x73, 0x67, 0x69, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x12, 0x02, 0x63, 0x73, 0x2a, 0x3c, 0x0a, 0x0d, 0x43, 0x4d, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, + 0x65, 0x49, 0x64, 0x5f, 0x65, 0x12, 0x0b, 0x0a, 0x07, 0x5f, 0x43, 0x4d, 0x50, 0x69, 0x6e, 0x67, + 0x10, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x5f, 0x43, 0x4d, 0x4c, 0x6f, 0x67, 0x69, 0x6e, 0x10, 0x67, + 0x12, 0x10, 0x0a, 0x0c, 0x5f, 0x43, 0x4d, 0x52, 0x65, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, + 0x10, 0x68, 0x2a, 0x4d, 0x0a, 0x0d, 0x53, 0x4d, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x49, + 0x64, 0x5f, 0x65, 0x12, 0x0b, 0x0a, 0x07, 0x5f, 0x53, 0x4d, 0x50, 0x69, 0x6e, 0x67, 0x10, 0x65, + 0x12, 0x0f, 0x0a, 0x0b, 0x5f, 0x53, 0x4d, 0x52, 0x70, 0x63, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x10, + 0x66, 0x12, 0x10, 0x0a, 0x0c, 0x5f, 0x53, 0x4d, 0x52, 0x65, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, + 0x74, 0x10, 0x68, 0x12, 0x0c, 0x0a, 0x08, 0x5f, 0x53, 0x4d, 0x4c, 0x6f, 0x67, 0x69, 0x6e, 0x10, + 0x67, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x3b, 0x63, 0x73, +} + +var ( + file_cs_msgid_proto_rawDescOnce sync.Once + file_cs_msgid_proto_rawDescData = file_cs_msgid_proto_rawDesc +) + +func file_cs_msgid_proto_rawDescGZIP() []byte { + file_cs_msgid_proto_rawDescOnce.Do(func() { + file_cs_msgid_proto_rawDescData = protoimpl.X.CompressGZIP(file_cs_msgid_proto_rawDescData) + }) + return file_cs_msgid_proto_rawDescData +} + +var file_cs_msgid_proto_enumTypes = make([]protoimpl.EnumInfo, 2) +var file_cs_msgid_proto_goTypes = []interface{}{ + (CMMessageIdE)(0), // 0: cs.CMMessageId_e + (SMMessageIdE)(0), // 1: cs.SMMessageId_e +} +var file_cs_msgid_proto_depIdxs = []int32{ + 0, // [0:0] is the sub-list for method output_type + 0, // [0:0] 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_cs_msgid_proto_init() } +func file_cs_msgid_proto_init() { + if File_cs_msgid_proto != nil { + return + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_cs_msgid_proto_rawDesc, + NumEnums: 2, + NumMessages: 0, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_cs_msgid_proto_goTypes, + DependencyIndexes: file_cs_msgid_proto_depIdxs, + EnumInfos: file_cs_msgid_proto_enumTypes, + }.Build() + File_cs_msgid_proto = out.File + file_cs_msgid_proto_rawDesc = nil + file_cs_msgid_proto_goTypes = nil + file_cs_msgid_proto_depIdxs = nil +} diff --git a/server/imserver/cs/cs_proto.pb.go b/server/imserver/cs/cs_proto.pb.go new file mode 100644 index 00000000..b25b2c45 --- /dev/null +++ b/server/imserver/cs/cs_proto.pb.go @@ -0,0 +1,1014 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.31.0 +// protoc v4.23.4 +// source: cs_proto.proto + +package cs + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +// 常量 +type ConstantE int32 + +const ( + ConstantE_ProtoVersion ConstantE = 2023051601 //系统版本 +) + +// Enum value maps for ConstantE. +var ( + ConstantE_name = map[int32]string{ + 2023051601: "ProtoVersion", + } + ConstantE_value = map[string]int32{ + "ProtoVersion": 2023051601, + } +) + +func (x ConstantE) Enum() *ConstantE { + p := new(ConstantE) + *p = x + return p +} + +func (x ConstantE) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (ConstantE) Descriptor() protoreflect.EnumDescriptor { + return file_cs_proto_proto_enumTypes[0].Descriptor() +} + +func (ConstantE) Type() protoreflect.EnumType { + return &file_cs_proto_proto_enumTypes[0] +} + +func (x ConstantE) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Do not use. +func (x *ConstantE) UnmarshalJSON(b []byte) error { + num, err := protoimpl.X.UnmarshalJSONEnum(x.Descriptor(), b) + if err != nil { + return err + } + *x = ConstantE(num) + return nil +} + +// Deprecated: Use ConstantE.Descriptor instead. +func (ConstantE) EnumDescriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{0} +} + +// 心跳 +type CMPing struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *CMPing) Reset() { + *x = CMPing{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *CMPing) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CMPing) ProtoMessage() {} + +func (x *CMPing) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_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) +} + +// Deprecated: Use CMPing.ProtoReflect.Descriptor instead. +func (*CMPing) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{0} +} + +type SMPing struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Param1 *int32 `protobuf:"varint,1,opt,name=param1" json:"param1,omitempty"` + Source *int32 `protobuf:"varint,2,opt,name=source,def=0" json:"source,omitempty"` //0:tcp 1:udp +} + +// Default values for SMPing fields. +const ( + Default_SMPing_Source = int32(0) +) + +func (x *SMPing) Reset() { + *x = SMPing{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SMPing) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SMPing) ProtoMessage() {} + +func (x *SMPing) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_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) +} + +// Deprecated: Use SMPing.ProtoReflect.Descriptor instead. +func (*SMPing) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{1} +} + +func (x *SMPing) GetParam1() int32 { + if x != nil && x.Param1 != nil { + return *x.Param1 + } + return 0 +} + +func (x *SMPing) GetSource() int32 { + if x != nil && x.Source != nil { + return *x.Source + } + return Default_SMPing_Source +} + +// rpc调用错误 +type SMRpcError struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ErrorCode *int32 `protobuf:"varint,1,opt,name=error_code,json=errorCode" json:"error_code,omitempty"` + ErrorMsg *string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg" json:"error_msg,omitempty"` + DebugMsg *string `protobuf:"bytes,3,opt,name=debug_msg,json=debugMsg" json:"debug_msg,omitempty"` + File *string `protobuf:"bytes,4,opt,name=file" json:"file,omitempty"` + Lineno *int32 `protobuf:"varint,5,opt,name=lineno" json:"lineno,omitempty"` + ErrorParam *int32 `protobuf:"varint,6,opt,name=error_param,json=errorParam" json:"error_param,omitempty"` +} + +func (x *SMRpcError) Reset() { + *x = SMRpcError{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SMRpcError) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SMRpcError) ProtoMessage() {} + +func (x *SMRpcError) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_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) +} + +// Deprecated: Use SMRpcError.ProtoReflect.Descriptor instead. +func (*SMRpcError) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{2} +} + +func (x *SMRpcError) GetErrorCode() int32 { + if x != nil && x.ErrorCode != nil { + return *x.ErrorCode + } + return 0 +} + +func (x *SMRpcError) GetErrorMsg() string { + if x != nil && x.ErrorMsg != nil { + return *x.ErrorMsg + } + return "" +} + +func (x *SMRpcError) GetDebugMsg() string { + if x != nil && x.DebugMsg != nil { + return *x.DebugMsg + } + return "" +} + +func (x *SMRpcError) GetFile() string { + if x != nil && x.File != nil { + return *x.File + } + return "" +} + +func (x *SMRpcError) GetLineno() int32 { + if x != nil && x.Lineno != nil { + return *x.Lineno + } + return 0 +} + +func (x *SMRpcError) GetErrorParam() int32 { + if x != nil && x.ErrorParam != nil { + return *x.ErrorParam + } + return 0 +} + +// int32键值对 +type MFPair struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *int32 `protobuf:"varint,1,opt,name=key" json:"key,omitempty"` //key + Value *int32 `protobuf:"varint,2,opt,name=value" json:"value,omitempty"` //val +} + +func (x *MFPair) Reset() { + *x = MFPair{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MFPair) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MFPair) ProtoMessage() {} + +func (x *MFPair) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_proto_msgTypes[3] + 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) +} + +// Deprecated: Use MFPair.ProtoReflect.Descriptor instead. +func (*MFPair) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{3} +} + +func (x *MFPair) GetKey() int32 { + if x != nil && x.Key != nil { + return *x.Key + } + return 0 +} + +func (x *MFPair) GetValue() int32 { + if x != nil && x.Value != nil { + return *x.Value + } + return 0 +} + +// int64键值对 +type MFPair64 struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Key *int64 `protobuf:"varint,1,opt,name=key" json:"key,omitempty"` //key + Value *int64 `protobuf:"varint,2,opt,name=value" json:"value,omitempty"` //val +} + +func (x *MFPair64) Reset() { + *x = MFPair64{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MFPair64) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MFPair64) ProtoMessage() {} + +func (x *MFPair64) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_proto_msgTypes[4] + 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) +} + +// Deprecated: Use MFPair64.ProtoReflect.Descriptor instead. +func (*MFPair64) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{4} +} + +func (x *MFPair64) GetKey() int64 { + if x != nil && x.Key != nil { + return *x.Key + } + return 0 +} + +func (x *MFPair64) GetValue() int64 { + if x != nil && x.Value != nil { + return *x.Value + } + return 0 +} + +// int32元组 +type MFTuple struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Values []int32 `protobuf:"varint,1,rep,name=values" json:"values,omitempty"` //values +} + +func (x *MFTuple) Reset() { + *x = MFTuple{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MFTuple) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MFTuple) ProtoMessage() {} + +func (x *MFTuple) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_proto_msgTypes[5] + 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) +} + +// Deprecated: Use MFTuple.ProtoReflect.Descriptor instead. +func (*MFTuple) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{5} +} + +func (x *MFTuple) GetValues() []int32 { + if x != nil { + return x.Values + } + return nil +} + +// string元组 +type MFTupleString struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Values []string `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"` //values +} + +func (x *MFTupleString) Reset() { + *x = MFTupleString{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[6] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *MFTupleString) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*MFTupleString) ProtoMessage() {} + +func (x *MFTupleString) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_proto_msgTypes[6] + 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) +} + +// Deprecated: Use MFTupleString.ProtoReflect.Descriptor instead. +func (*MFTupleString) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{6} +} + +func (x *MFTupleString) GetValues() []string { + if x != nil { + return x.Values + } + return nil +} + +// 登录 +type CMLogin struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ServerId *int32 `protobuf:"varint,1,opt,name=server_id,json=serverId" json:"server_id,omitempty"` //保留 + TeamUuid *string `protobuf:"bytes,2,opt,name=team_uuid,json=teamUuid" json:"team_uuid,omitempty"` //保留 + AccountId *string `protobuf:"bytes,3,opt,name=account_id,json=accountId" json:"account_id,omitempty"` //账号id + ProtoVersion *int32 `protobuf:"varint,5,opt,name=proto_version,json=protoVersion" json:"proto_version,omitempty"` //协议版本号Constant_e.ProtoVersion + SessionId *string `protobuf:"bytes,20,opt,name=session_id,json=sessionId" json:"session_id,omitempty"` //账号id +} + +func (x *CMLogin) Reset() { + *x = CMLogin{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[7] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *CMLogin) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CMLogin) ProtoMessage() {} + +func (x *CMLogin) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_proto_msgTypes[7] + 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) +} + +// Deprecated: Use CMLogin.ProtoReflect.Descriptor instead. +func (*CMLogin) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{7} +} + +func (x *CMLogin) GetServerId() int32 { + if x != nil && x.ServerId != nil { + return *x.ServerId + } + return 0 +} + +func (x *CMLogin) GetTeamUuid() string { + if x != nil && x.TeamUuid != nil { + return *x.TeamUuid + } + return "" +} + +func (x *CMLogin) GetAccountId() string { + if x != nil && x.AccountId != nil { + return *x.AccountId + } + return "" +} + +func (x *CMLogin) GetProtoVersion() int32 { + if x != nil && x.ProtoVersion != nil { + return *x.ProtoVersion + } + return 0 +} + +func (x *CMLogin) GetSessionId() string { + if x != nil && x.SessionId != nil { + return *x.SessionId + } + return "" +} + +// 登录回复 +type SMLogin struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ServerInfo *string `protobuf:"bytes,1,opt,name=server_info,json=serverInfo" json:"server_info,omitempty"` //服务器信息（重连时使用） + AccountId *string `protobuf:"bytes,2,opt,name=account_id,json=accountId" json:"account_id,omitempty"` +} + +func (x *SMLogin) Reset() { + *x = SMLogin{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[8] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SMLogin) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SMLogin) ProtoMessage() {} + +func (x *SMLogin) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_proto_msgTypes[8] + 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) +} + +// Deprecated: Use SMLogin.ProtoReflect.Descriptor instead. +func (*SMLogin) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{8} +} + +func (x *SMLogin) GetServerInfo() string { + if x != nil && x.ServerInfo != nil { + return *x.ServerInfo + } + return "" +} + +func (x *SMLogin) GetAccountId() string { + if x != nil && x.AccountId != nil { + return *x.AccountId + } + return "" +} + +// 断线重连 +type CMReconnect struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ServerId *int32 `protobuf:"varint,1,opt,name=server_id,json=serverId" json:"server_id,omitempty"` //保留 + TeamUuid *string `protobuf:"bytes,2,opt,name=team_uuid,json=teamUuid" json:"team_uuid,omitempty"` //保留 + AccountId *string `protobuf:"bytes,3,opt,name=account_id,json=accountId" json:"account_id,omitempty"` //账号id + SessionId *string `protobuf:"bytes,4,opt,name=session_id,json=sessionId" json:"session_id,omitempty"` //session_id + RoomUuid *string `protobuf:"bytes,5,opt,name=room_uuid,json=roomUuid" json:"room_uuid,omitempty"` //房间唯一id + ServerInfo *string `protobuf:"bytes,6,opt,name=server_info,json=serverInfo" json:"server_info,omitempty"` //服务器信息 +} + +func (x *CMReconnect) Reset() { + *x = CMReconnect{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[9] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *CMReconnect) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*CMReconnect) ProtoMessage() {} + +func (x *CMReconnect) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_proto_msgTypes[9] + 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) +} + +// Deprecated: Use CMReconnect.ProtoReflect.Descriptor instead. +func (*CMReconnect) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{9} +} + +func (x *CMReconnect) GetServerId() int32 { + if x != nil && x.ServerId != nil { + return *x.ServerId + } + return 0 +} + +func (x *CMReconnect) GetTeamUuid() string { + if x != nil && x.TeamUuid != nil { + return *x.TeamUuid + } + return "" +} + +func (x *CMReconnect) GetAccountId() string { + if x != nil && x.AccountId != nil { + return *x.AccountId + } + return "" +} + +func (x *CMReconnect) GetSessionId() string { + if x != nil && x.SessionId != nil { + return *x.SessionId + } + return "" +} + +func (x *CMReconnect) GetRoomUuid() string { + if x != nil && x.RoomUuid != nil { + return *x.RoomUuid + } + return "" +} + +func (x *CMReconnect) GetServerInfo() string { + if x != nil && x.ServerInfo != nil { + return *x.ServerInfo + } + return "" +} + +// 断线重连回复 +type SMReconnect struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + Errcode *int32 `protobuf:"varint,1,opt,name=errcode" json:"errcode,omitempty"` //错误码 0：成功 1:重连失败 + Errmsg *string `protobuf:"bytes,2,opt,name=errmsg" json:"errmsg,omitempty"` //错误描述 +} + +func (x *SMReconnect) Reset() { + *x = SMReconnect{} + if protoimpl.UnsafeEnabled { + mi := &file_cs_proto_proto_msgTypes[10] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SMReconnect) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SMReconnect) ProtoMessage() {} + +func (x *SMReconnect) ProtoReflect() protoreflect.Message { + mi := &file_cs_proto_proto_msgTypes[10] + 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) +} + +// Deprecated: Use SMReconnect.ProtoReflect.Descriptor instead. +func (*SMReconnect) Descriptor() ([]byte, []int) { + return file_cs_proto_proto_rawDescGZIP(), []int{10} +} + +func (x *SMReconnect) GetErrcode() int32 { + if x != nil && x.Errcode != nil { + return *x.Errcode + } + return 0 +} + +func (x *SMReconnect) GetErrmsg() string { + if x != nil && x.Errmsg != nil { + return *x.Errmsg + } + return "" +} + +var File_cs_proto_proto protoreflect.FileDescriptor + +var file_cs_proto_proto_rawDesc = []byte{ + 0x0a, 0x0e, 0x63, 0x73, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x12, 0x02, 0x63, 0x73, 0x22, 0x08, 0x0a, 0x06, 0x43, 0x4d, 0x50, 0x69, 0x6e, 0x67, 0x22, 0x3b, + 0x0a, 0x06, 0x53, 0x4d, 0x50, 0x69, 0x6e, 0x67, 0x12, 0x16, 0x0a, 0x06, 0x70, 0x61, 0x72, 0x61, + 0x6d, 0x31, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x31, + 0x12, 0x19, 0x0a, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, + 0x3a, 0x01, 0x30, 0x52, 0x06, 0x73, 0x6f, 0x75, 0x72, 0x63, 0x65, 0x22, 0xb2, 0x01, 0x0a, 0x0a, + 0x53, 0x4d, 0x52, 0x70, 0x63, 0x45, 0x72, 0x72, 0x6f, 0x72, 0x12, 0x1d, 0x0a, 0x0a, 0x65, 0x72, + 0x72, 0x6f, 0x72, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, + 0x65, 0x72, 0x72, 0x6f, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x65, 0x72, 0x72, + 0x6f, 0x72, 0x5f, 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x65, 0x72, + 0x72, 0x6f, 0x72, 0x4d, 0x73, 0x67, 0x12, 0x1b, 0x0a, 0x09, 0x64, 0x65, 0x62, 0x75, 0x67, 0x5f, + 0x6d, 0x73, 0x67, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x64, 0x65, 0x62, 0x75, 0x67, + 0x4d, 0x73, 0x67, 0x12, 0x12, 0x0a, 0x04, 0x66, 0x69, 0x6c, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x04, 0x66, 0x69, 0x6c, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x6c, 0x69, 0x6e, 0x65, 0x6e, + 0x6f, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x06, 0x6c, 0x69, 0x6e, 0x65, 0x6e, 0x6f, 0x12, + 0x1f, 0x0a, 0x0b, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x5f, 0x70, 0x61, 0x72, 0x61, 0x6d, 0x18, 0x06, + 0x20, 0x01, 0x28, 0x05, 0x52, 0x0a, 0x65, 0x72, 0x72, 0x6f, 0x72, 0x50, 0x61, 0x72, 0x61, 0x6d, + 0x22, 0x30, 0x0a, 0x06, 0x4d, 0x46, 0x50, 0x61, 0x69, 0x72, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, + 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x14, 0x0a, 0x05, + 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x05, 0x52, 0x05, 0x76, 0x61, 0x6c, + 0x75, 0x65, 0x22, 0x32, 0x0a, 0x08, 0x4d, 0x46, 0x50, 0x61, 0x69, 0x72, 0x36, 0x34, 0x12, 0x10, + 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x03, 0x6b, 0x65, 0x79, + 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x03, 0x52, + 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x21, 0x0a, 0x07, 0x4d, 0x46, 0x54, 0x75, 0x70, 0x6c, + 0x65, 0x12, 0x16, 0x0a, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, + 0x05, 0x52, 0x06, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x73, 0x22, 0x27, 0x0a, 0x0d, 0x4d, 0x46, 0x54, + 0x75, 0x70, 0x6c, 0x65, 0x53, 0x74, 0x72, 0x69, 0x6e, 0x67, 0x12, 0x16, 0x0a, 0x06, 0x76, 0x61, + 0x6c, 0x75, 0x65, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28, 0x09, 0x52, 0x06, 0x76, 0x61, 0x6c, 0x75, + 0x65, 0x73, 0x22, 0xa6, 0x01, 0x0a, 0x07, 0x43, 0x4d, 0x4c, 0x6f, 0x67, 0x69, 0x6e, 0x12, 0x1b, + 0x0a, 0x09, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, + 0x05, 0x52, 0x08, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x49, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x74, + 0x65, 0x61, 0x6d, 0x5f, 0x75, 0x75, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, + 0x74, 0x65, 0x61, 0x6d, 0x55, 0x75, 0x69, 0x64, 0x12, 0x1d, 0x0a, 0x0a, 0x61, 0x63, 0x63, 0x6f, + 0x75, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x61, 0x63, + 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0d, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x5f, 0x76, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0c, + 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x12, 0x1d, 0x0a, 0x0a, + 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x14, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x22, 0x49, 0x0a, 0x07, 0x53, + 0x4d, 0x4c, 0x6f, 0x67, 0x69, 0x6e, 0x12, 0x1f, 0x0a, 0x0b, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, + 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0a, 0x73, 0x65, 0x72, + 0x76, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x1d, 0x0a, 0x0a, 0x61, 0x63, 0x63, 0x6f, 0x75, + 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x61, 0x63, 0x63, + 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x64, 0x22, 0xc3, 0x01, 0x0a, 0x0b, 0x43, 0x4d, 0x52, 0x65, 0x63, + 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x12, 0x1b, 0x0a, 0x09, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, + 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x08, 0x73, 0x65, 0x72, 0x76, 0x65, + 0x72, 0x49, 0x64, 0x12, 0x1b, 0x0a, 0x09, 0x74, 0x65, 0x61, 0x6d, 0x5f, 0x75, 0x75, 0x69, 0x64, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x74, 0x65, 0x61, 0x6d, 0x55, 0x75, 0x69, 0x64, + 0x12, 0x1d, 0x0a, 0x0a, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x69, 0x64, 0x18, 0x03, + 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, 0x64, 0x12, + 0x1d, 0x0a, 0x0a, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x5f, 0x69, 0x64, 0x18, 0x04, 0x20, + 0x01, 0x28, 0x09, 0x52, 0x09, 0x73, 0x65, 0x73, 0x73, 0x69, 0x6f, 0x6e, 0x49, 0x64, 0x12, 0x1b, + 0x0a, 0x09, 0x72, 0x6f, 0x6f, 0x6d, 0x5f, 0x75, 0x75, 0x69, 0x64, 0x18, 0x05, 0x20, 0x01, 0x28, + 0x09, 0x52, 0x08, 0x72, 0x6f, 0x6f, 0x6d, 0x55, 0x75, 0x69, 0x64, 0x12, 0x1f, 0x0a, 0x0b, 0x73, + 0x65, 0x72, 0x76, 0x65, 0x72, 0x5f, 0x69, 0x6e, 0x66, 0x6f, 0x18, 0x06, 0x20, 0x01, 0x28, 0x09, + 0x52, 0x0a, 0x73, 0x65, 0x72, 0x76, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x22, 0x3f, 0x0a, 0x0b, + 0x53, 0x4d, 0x52, 0x65, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x12, 0x18, 0x0a, 0x07, 0x65, + 0x72, 0x72, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x07, 0x65, 0x72, + 0x72, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x16, 0x0a, 0x06, 0x65, 0x72, 0x72, 0x6d, 0x73, 0x67, 0x18, + 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x65, 0x72, 0x72, 0x6d, 0x73, 0x67, 0x2a, 0x22, 0x0a, + 0x0a, 0x43, 0x6f, 0x6e, 0x73, 0x74, 0x61, 0x6e, 0x74, 0x5f, 0x65, 0x12, 0x14, 0x0a, 0x0c, 0x50, + 0x72, 0x6f, 0x74, 0x6f, 0x56, 0x65, 0x72, 0x73, 0x69, 0x6f, 0x6e, 0x10, 0xd1, 0xa2, 0xd5, 0xc4, + 0x07, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x3b, 0x63, 0x73, +} + +var ( + file_cs_proto_proto_rawDescOnce sync.Once + file_cs_proto_proto_rawDescData = file_cs_proto_proto_rawDesc +) + +func file_cs_proto_proto_rawDescGZIP() []byte { + file_cs_proto_proto_rawDescOnce.Do(func() { + file_cs_proto_proto_rawDescData = protoimpl.X.CompressGZIP(file_cs_proto_proto_rawDescData) + }) + return file_cs_proto_proto_rawDescData +} + +var file_cs_proto_proto_enumTypes = make([]protoimpl.EnumInfo, 1) +var file_cs_proto_proto_msgTypes = make([]protoimpl.MessageInfo, 11) +var file_cs_proto_proto_goTypes = []interface{}{ + (ConstantE)(0), // 0: cs.Constant_e + (*CMPing)(nil), // 1: cs.CMPing + (*SMPing)(nil), // 2: cs.SMPing + (*SMRpcError)(nil), // 3: cs.SMRpcError + (*MFPair)(nil), // 4: cs.MFPair + (*MFPair64)(nil), // 5: cs.MFPair64 + (*MFTuple)(nil), // 6: cs.MFTuple + (*MFTupleString)(nil), // 7: cs.MFTupleString + (*CMLogin)(nil), // 8: cs.CMLogin + (*SMLogin)(nil), // 9: cs.SMLogin + (*CMReconnect)(nil), // 10: cs.CMReconnect + (*SMReconnect)(nil), // 11: cs.SMReconnect +} +var file_cs_proto_proto_depIdxs = []int32{ + 0, // [0:0] is the sub-list for method output_type + 0, // [0:0] 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_cs_proto_proto_init() } +func file_cs_proto_proto_init() { + if File_cs_proto_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_cs_proto_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*CMPing); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SMPing); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SMRpcError); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MFPair); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MFPair64); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MFTuple); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*MFTupleString); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*CMLogin); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SMLogin); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*CMReconnect); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_cs_proto_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SMReconnect); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_cs_proto_proto_rawDesc, + NumEnums: 1, + NumMessages: 11, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_cs_proto_proto_goTypes, + DependencyIndexes: file_cs_proto_proto_depIdxs, + EnumInfos: file_cs_proto_proto_enumTypes, + MessageInfos: file_cs_proto_proto_msgTypes, + }.Build() + File_cs_proto_proto = out.File + file_cs_proto_proto_rawDesc = nil + file_cs_proto_proto_goTypes = nil + file_cs_proto_proto_depIdxs = nil +} diff --git a/server/imserver/ss/ss_msgid.pb.go b/server/imserver/ss/ss_msgid.pb.go new file mode 100644 index 00000000..ee8ae9ad --- /dev/null +++ b/server/imserver/ss/ss_msgid.pb.go @@ -0,0 +1,157 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.31.0 +// protoc v4.23.4 +// source: ss_msgid.proto + +package ss + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +// 消息id定义 +type SSMessageIdE int32 + +const ( + SSMessageIdE__SS_Ping SSMessageIdE = 8 + SSMessageIdE__SS_Pong SSMessageIdE = 9 + SSMessageIdE__SS_WSP_SocketDisconnect SSMessageIdE = 10 + SSMessageIdE__SS_WSP_RequestTargetServer SSMessageIdE = 11 + SSMessageIdE__SS_MS_ResponseTargetServer SSMessageIdE = 12 + SSMessageIdE__SS_ForceCloseSocket SSMessageIdE = 13 +) + +// Enum value maps for SSMessageIdE. +var ( + SSMessageIdE_name = map[int32]string{ + 8: "_SS_Ping", + 9: "_SS_Pong", + 10: "_SS_WSP_SocketDisconnect", + 11: "_SS_WSP_RequestTargetServer", + 12: "_SS_MS_ResponseTargetServer", + 13: "_SS_ForceCloseSocket", + } + SSMessageIdE_value = map[string]int32{ + "_SS_Ping": 8, + "_SS_Pong": 9, + "_SS_WSP_SocketDisconnect": 10, + "_SS_WSP_RequestTargetServer": 11, + "_SS_MS_ResponseTargetServer": 12, + "_SS_ForceCloseSocket": 13, + } +) + +func (x SSMessageIdE) Enum() *SSMessageIdE { + p := new(SSMessageIdE) + *p = x + return p +} + +func (x SSMessageIdE) String() string { + return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x)) +} + +func (SSMessageIdE) Descriptor() protoreflect.EnumDescriptor { + return file_ss_msgid_proto_enumTypes[0].Descriptor() +} + +func (SSMessageIdE) Type() protoreflect.EnumType { + return &file_ss_msgid_proto_enumTypes[0] +} + +func (x SSMessageIdE) Number() protoreflect.EnumNumber { + return protoreflect.EnumNumber(x) +} + +// Deprecated: Do not use. +func (x *SSMessageIdE) UnmarshalJSON(b []byte) error { + num, err := protoimpl.X.UnmarshalJSONEnum(x.Descriptor(), b) + if err != nil { + return err + } + *x = SSMessageIdE(num) + return nil +} + +// Deprecated: Use SSMessageIdE.Descriptor instead. +func (SSMessageIdE) EnumDescriptor() ([]byte, []int) { + return file_ss_msgid_proto_rawDescGZIP(), []int{0} +} + +var File_ss_msgid_proto protoreflect.FileDescriptor + +var file_ss_msgid_proto_rawDesc = []byte{ + 0x0a, 0x0e, 0x73, 0x73, 0x5f, 0x6d, 0x73, 0x67, 0x69, 0x64, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x12, 0x02, 0x73, 0x73, 0x2a, 0xa5, 0x01, 0x0a, 0x0d, 0x53, 0x53, 0x4d, 0x65, 0x73, 0x73, 0x61, + 0x67, 0x65, 0x49, 0x64, 0x5f, 0x65, 0x12, 0x0c, 0x0a, 0x08, 0x5f, 0x53, 0x53, 0x5f, 0x50, 0x69, + 0x6e, 0x67, 0x10, 0x08, 0x12, 0x0c, 0x0a, 0x08, 0x5f, 0x53, 0x53, 0x5f, 0x50, 0x6f, 0x6e, 0x67, + 0x10, 0x09, 0x12, 0x1c, 0x0a, 0x18, 0x5f, 0x53, 0x53, 0x5f, 0x57, 0x53, 0x50, 0x5f, 0x53, 0x6f, + 0x63, 0x6b, 0x65, 0x74, 0x44, 0x69, 0x73, 0x63, 0x6f, 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x10, 0x0a, + 0x12, 0x1f, 0x0a, 0x1b, 0x5f, 0x53, 0x53, 0x5f, 0x57, 0x53, 0x50, 0x5f, 0x52, 0x65, 0x71, 0x75, + 0x65, 0x73, 0x74, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x10, + 0x0b, 0x12, 0x1f, 0x0a, 0x1b, 0x5f, 0x53, 0x53, 0x5f, 0x4d, 0x53, 0x5f, 0x52, 0x65, 0x73, 0x70, + 0x6f, 0x6e, 0x73, 0x65, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, + 0x10, 0x0c, 0x12, 0x18, 0x0a, 0x14, 0x5f, 0x53, 0x53, 0x5f, 0x46, 0x6f, 0x72, 0x63, 0x65, 0x43, + 0x6c, 0x6f, 0x73, 0x65, 0x53, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x10, 0x0d, 0x42, 0x06, 0x5a, 0x04, + 0x2e, 0x3b, 0x73, 0x73, +} + +var ( + file_ss_msgid_proto_rawDescOnce sync.Once + file_ss_msgid_proto_rawDescData = file_ss_msgid_proto_rawDesc +) + +func file_ss_msgid_proto_rawDescGZIP() []byte { + file_ss_msgid_proto_rawDescOnce.Do(func() { + file_ss_msgid_proto_rawDescData = protoimpl.X.CompressGZIP(file_ss_msgid_proto_rawDescData) + }) + return file_ss_msgid_proto_rawDescData +} + +var file_ss_msgid_proto_enumTypes = make([]protoimpl.EnumInfo, 1) +var file_ss_msgid_proto_goTypes = []interface{}{ + (SSMessageIdE)(0), // 0: ss.SSMessageId_e +} +var file_ss_msgid_proto_depIdxs = []int32{ + 0, // [0:0] is the sub-list for method output_type + 0, // [0:0] 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_ss_msgid_proto_init() } +func file_ss_msgid_proto_init() { + if File_ss_msgid_proto != nil { + return + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_ss_msgid_proto_rawDesc, + NumEnums: 1, + NumMessages: 0, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_ss_msgid_proto_goTypes, + DependencyIndexes: file_ss_msgid_proto_depIdxs, + EnumInfos: file_ss_msgid_proto_enumTypes, + }.Build() + File_ss_msgid_proto = out.File + file_ss_msgid_proto_rawDesc = nil + file_ss_msgid_proto_goTypes = nil + file_ss_msgid_proto_depIdxs = nil +} diff --git a/server/imserver/ss/ss_proto.pb.go b/server/imserver/ss/ss_proto.pb.go new file mode 100644 index 00000000..eedbe5b3 --- /dev/null +++ b/server/imserver/ss/ss_proto.pb.go @@ -0,0 +1,472 @@ +// Code generated by protoc-gen-go. DO NOT EDIT. +// versions: +// protoc-gen-go v1.31.0 +// protoc v4.23.4 +// source: ss_proto.proto + +package ss + +import ( + protoreflect "google.golang.org/protobuf/reflect/protoreflect" + protoimpl "google.golang.org/protobuf/runtime/protoimpl" + reflect "reflect" + sync "sync" +) + +const ( + // Verify that this generated code is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion) + // Verify that runtime/protoimpl is sufficiently up-to-date. + _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20) +) + +type SS_Ping struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *SS_Ping) Reset() { + *x = SS_Ping{} + if protoimpl.UnsafeEnabled { + mi := &file_ss_proto_proto_msgTypes[0] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SS_Ping) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SS_Ping) ProtoMessage() {} + +func (x *SS_Ping) ProtoReflect() protoreflect.Message { + mi := &file_ss_proto_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) +} + +// Deprecated: Use SS_Ping.ProtoReflect.Descriptor instead. +func (*SS_Ping) Descriptor() ([]byte, []int) { + return file_ss_proto_proto_rawDescGZIP(), []int{0} +} + +type SS_Pong struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *SS_Pong) Reset() { + *x = SS_Pong{} + if protoimpl.UnsafeEnabled { + mi := &file_ss_proto_proto_msgTypes[1] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SS_Pong) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SS_Pong) ProtoMessage() {} + +func (x *SS_Pong) ProtoReflect() protoreflect.Message { + mi := &file_ss_proto_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) +} + +// Deprecated: Use SS_Pong.ProtoReflect.Descriptor instead. +func (*SS_Pong) Descriptor() ([]byte, []int) { + return file_ss_proto_proto_rawDescGZIP(), []int{1} +} + +type SS_WSP_SocketDisconnect struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *SS_WSP_SocketDisconnect) Reset() { + *x = SS_WSP_SocketDisconnect{} + if protoimpl.UnsafeEnabled { + mi := &file_ss_proto_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SS_WSP_SocketDisconnect) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SS_WSP_SocketDisconnect) ProtoMessage() {} + +func (x *SS_WSP_SocketDisconnect) ProtoReflect() protoreflect.Message { + mi := &file_ss_proto_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) +} + +// Deprecated: Use SS_WSP_SocketDisconnect.ProtoReflect.Descriptor instead. +func (*SS_WSP_SocketDisconnect) Descriptor() ([]byte, []int) { + return file_ss_proto_proto_rawDescGZIP(), []int{2} +} + +type SS_WSP_RequestTargetServer struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ContextId *int64 `protobuf:"varint,1,opt,name=context_id,json=contextId" json:"context_id,omitempty"` + AccountId *string `protobuf:"bytes,2,opt,name=account_id,json=accountId" json:"account_id,omitempty"` + TeamId *string `protobuf:"bytes,3,opt,name=team_id,json=teamId" json:"team_id,omitempty"` +} + +func (x *SS_WSP_RequestTargetServer) Reset() { + *x = SS_WSP_RequestTargetServer{} + if protoimpl.UnsafeEnabled { + mi := &file_ss_proto_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SS_WSP_RequestTargetServer) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SS_WSP_RequestTargetServer) ProtoMessage() {} + +func (x *SS_WSP_RequestTargetServer) ProtoReflect() protoreflect.Message { + mi := &file_ss_proto_proto_msgTypes[3] + 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) +} + +// Deprecated: Use SS_WSP_RequestTargetServer.ProtoReflect.Descriptor instead. +func (*SS_WSP_RequestTargetServer) Descriptor() ([]byte, []int) { + return file_ss_proto_proto_rawDescGZIP(), []int{3} +} + +func (x *SS_WSP_RequestTargetServer) GetContextId() int64 { + if x != nil && x.ContextId != nil { + return *x.ContextId + } + return 0 +} + +func (x *SS_WSP_RequestTargetServer) GetAccountId() string { + if x != nil && x.AccountId != nil { + return *x.AccountId + } + return "" +} + +func (x *SS_WSP_RequestTargetServer) GetTeamId() string { + if x != nil && x.TeamId != nil { + return *x.TeamId + } + return "" +} + +type SS_MS_ResponseTargetServer struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields + + ErrorCode *int32 `protobuf:"varint,1,opt,name=error_code,json=errorCode" json:"error_code,omitempty"` + ErrorMsg *string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg" json:"error_msg,omitempty"` + ContextId *int64 `protobuf:"varint,3,opt,name=context_id,json=contextId" json:"context_id,omitempty"` + Host *string `protobuf:"bytes,4,opt,name=host" json:"host,omitempty"` + Port *int32 `protobuf:"varint,5,opt,name=port" json:"port,omitempty"` +} + +func (x *SS_MS_ResponseTargetServer) Reset() { + *x = SS_MS_ResponseTargetServer{} + if protoimpl.UnsafeEnabled { + mi := &file_ss_proto_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SS_MS_ResponseTargetServer) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SS_MS_ResponseTargetServer) ProtoMessage() {} + +func (x *SS_MS_ResponseTargetServer) ProtoReflect() protoreflect.Message { + mi := &file_ss_proto_proto_msgTypes[4] + 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) +} + +// Deprecated: Use SS_MS_ResponseTargetServer.ProtoReflect.Descriptor instead. +func (*SS_MS_ResponseTargetServer) Descriptor() ([]byte, []int) { + return file_ss_proto_proto_rawDescGZIP(), []int{4} +} + +func (x *SS_MS_ResponseTargetServer) GetErrorCode() int32 { + if x != nil && x.ErrorCode != nil { + return *x.ErrorCode + } + return 0 +} + +func (x *SS_MS_ResponseTargetServer) GetErrorMsg() string { + if x != nil && x.ErrorMsg != nil { + return *x.ErrorMsg + } + return "" +} + +func (x *SS_MS_ResponseTargetServer) GetContextId() int64 { + if x != nil && x.ContextId != nil { + return *x.ContextId + } + return 0 +} + +func (x *SS_MS_ResponseTargetServer) GetHost() string { + if x != nil && x.Host != nil { + return *x.Host + } + return "" +} + +func (x *SS_MS_ResponseTargetServer) GetPort() int32 { + if x != nil && x.Port != nil { + return *x.Port + } + return 0 +} + +type SS_ForceCloseSocket struct { + state protoimpl.MessageState + sizeCache protoimpl.SizeCache + unknownFields protoimpl.UnknownFields +} + +func (x *SS_ForceCloseSocket) Reset() { + *x = SS_ForceCloseSocket{} + if protoimpl.UnsafeEnabled { + mi := &file_ss_proto_proto_msgTypes[5] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) + } +} + +func (x *SS_ForceCloseSocket) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*SS_ForceCloseSocket) ProtoMessage() {} + +func (x *SS_ForceCloseSocket) ProtoReflect() protoreflect.Message { + mi := &file_ss_proto_proto_msgTypes[5] + 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) +} + +// Deprecated: Use SS_ForceCloseSocket.ProtoReflect.Descriptor instead. +func (*SS_ForceCloseSocket) Descriptor() ([]byte, []int) { + return file_ss_proto_proto_rawDescGZIP(), []int{5} +} + +var File_ss_proto_proto protoreflect.FileDescriptor + +var file_ss_proto_proto_rawDesc = []byte{ + 0x0a, 0x0e, 0x73, 0x73, 0x5f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x12, 0x02, 0x73, 0x73, 0x22, 0x09, 0x0a, 0x07, 0x53, 0x53, 0x5f, 0x50, 0x69, 0x6e, 0x67, 0x22, + 0x09, 0x0a, 0x07, 0x53, 0x53, 0x5f, 0x50, 0x6f, 0x6e, 0x67, 0x22, 0x19, 0x0a, 0x17, 0x53, 0x53, + 0x5f, 0x57, 0x53, 0x50, 0x5f, 0x53, 0x6f, 0x63, 0x6b, 0x65, 0x74, 0x44, 0x69, 0x73, 0x63, 0x6f, + 0x6e, 0x6e, 0x65, 0x63, 0x74, 0x22, 0x73, 0x0a, 0x1a, 0x53, 0x53, 0x5f, 0x57, 0x53, 0x50, 0x5f, + 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x53, 0x65, 0x72, + 0x76, 0x65, 0x72, 0x12, 0x1d, 0x0a, 0x0a, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x78, 0x74, 0x5f, 0x69, + 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x78, 0x74, + 0x49, 0x64, 0x12, 0x1d, 0x0a, 0x0a, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x5f, 0x69, 0x64, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x61, 0x63, 0x63, 0x6f, 0x75, 0x6e, 0x74, 0x49, + 0x64, 0x12, 0x17, 0x0a, 0x07, 0x74, 0x65, 0x61, 0x6d, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x06, 0x74, 0x65, 0x61, 0x6d, 0x49, 0x64, 0x22, 0x9f, 0x01, 0x0a, 0x1a, 0x53, + 0x53, 0x5f, 0x4d, 0x53, 0x5f, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x54, 0x61, 0x72, + 0x67, 0x65, 0x74, 0x53, 0x65, 0x72, 0x76, 0x65, 0x72, 0x12, 0x1d, 0x0a, 0x0a, 0x65, 0x72, 0x72, + 0x6f, 0x72, 0x5f, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x09, 0x65, + 0x72, 0x72, 0x6f, 0x72, 0x43, 0x6f, 0x64, 0x65, 0x12, 0x1b, 0x0a, 0x09, 0x65, 0x72, 0x72, 0x6f, + 0x72, 0x5f, 0x6d, 0x73, 0x67, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x65, 0x72, 0x72, + 0x6f, 0x72, 0x4d, 0x73, 0x67, 0x12, 0x1d, 0x0a, 0x0a, 0x63, 0x6f, 0x6e, 0x74, 0x65, 0x78, 0x74, + 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x63, 0x6f, 0x6e, 0x74, 0x65, + 0x78, 0x74, 0x49, 0x64, 0x12, 0x12, 0x0a, 0x04, 0x68, 0x6f, 0x73, 0x74, 0x18, 0x04, 0x20, 0x01, + 0x28, 0x09, 0x52, 0x04, 0x68, 0x6f, 0x73, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x70, 0x6f, 0x72, 0x74, + 0x18, 0x05, 0x20, 0x01, 0x28, 0x05, 0x52, 0x04, 0x70, 0x6f, 0x72, 0x74, 0x22, 0x15, 0x0a, 0x13, + 0x53, 0x53, 0x5f, 0x46, 0x6f, 0x72, 0x63, 0x65, 0x43, 0x6c, 0x6f, 0x73, 0x65, 0x53, 0x6f, 0x63, + 0x6b, 0x65, 0x74, 0x42, 0x06, 0x5a, 0x04, 0x2e, 0x3b, 0x73, 0x73, +} + +var ( + file_ss_proto_proto_rawDescOnce sync.Once + file_ss_proto_proto_rawDescData = file_ss_proto_proto_rawDesc +) + +func file_ss_proto_proto_rawDescGZIP() []byte { + file_ss_proto_proto_rawDescOnce.Do(func() { + file_ss_proto_proto_rawDescData = protoimpl.X.CompressGZIP(file_ss_proto_proto_rawDescData) + }) + return file_ss_proto_proto_rawDescData +} + +var file_ss_proto_proto_msgTypes = make([]protoimpl.MessageInfo, 6) +var file_ss_proto_proto_goTypes = []interface{}{ + (*SS_Ping)(nil), // 0: ss.SS_Ping + (*SS_Pong)(nil), // 1: ss.SS_Pong + (*SS_WSP_SocketDisconnect)(nil), // 2: ss.SS_WSP_SocketDisconnect + (*SS_WSP_RequestTargetServer)(nil), // 3: ss.SS_WSP_RequestTargetServer + (*SS_MS_ResponseTargetServer)(nil), // 4: ss.SS_MS_ResponseTargetServer + (*SS_ForceCloseSocket)(nil), // 5: ss.SS_ForceCloseSocket +} +var file_ss_proto_proto_depIdxs = []int32{ + 0, // [0:0] is the sub-list for method output_type + 0, // [0:0] 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_ss_proto_proto_init() } +func file_ss_proto_proto_init() { + if File_ss_proto_proto != nil { + return + } + if !protoimpl.UnsafeEnabled { + file_ss_proto_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SS_Ping); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_ss_proto_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SS_Pong); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_ss_proto_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SS_WSP_SocketDisconnect); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_ss_proto_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SS_WSP_RequestTargetServer); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_ss_proto_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SS_MS_ResponseTargetServer); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + file_ss_proto_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + switch v := v.(*SS_ForceCloseSocket); i { + case 0: + return &v.state + case 1: + return &v.sizeCache + case 2: + return &v.unknownFields + default: + return nil + } + } + } + type x struct{} + out := protoimpl.TypeBuilder{ + File: protoimpl.DescBuilder{ + GoPackagePath: reflect.TypeOf(x{}).PkgPath(), + RawDescriptor: file_ss_proto_proto_rawDesc, + NumEnums: 0, + NumMessages: 6, + NumExtensions: 0, + NumServices: 0, + }, + GoTypes: file_ss_proto_proto_goTypes, + DependencyIndexes: file_ss_proto_proto_depIdxs, + MessageInfos: file_ss_proto_proto_msgTypes, + }.Build() + File_ss_proto_proto = out.File + file_ss_proto_proto_rawDesc = nil + file_ss_proto_proto_goTypes = nil + file_ss_proto_proto_depIdxs = nil +} diff --git a/third_party/f5 b/third_party/f5 index 7e8d448e..d8e81401 160000 --- a/third_party/f5 +++ b/third_party/f5 @@ -1 +1 @@ -Subproject commit 7e8d448ef7ba407e6f663e25041f087282f90e61 +Subproject commit d8e8140172722a11e8754d08dc5b6d8874b06db1