1

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
+}

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
+}

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
+}

third_party/f5

@@ -1 +1 @@
-Subproject commit 7e8d448ef7ba407e6f663e25041f087282f90e61
+Subproject commit d8e8140172722a11e8754d08dc5b6d8874b06db1