treaty

package
v2.6.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 14, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MinServerId       = 1000
	MessageHeaderSize = 20
)

Variables

View Source 
var (
	CodeType_name = map[int32]string{
		0: "CodeSuccess",
		1: "CodeFailed",
		2: "CodeChooseBackendLogin",
		3: "CodeLoginReconnect",
		4: "CodeCannotFindBackend",
		5: "CodeUndefinedDealMsg",
		6: "CodeNotLogin",
		7: "CodeNotRightConnector",
		8: "CodeNotLoginBackend",
	}
	CodeType_value = map[string]int32{
		"CodeSuccess":            0,
		"CodeFailed":             1,
		"CodeChooseBackendLogin": 2,
		"CodeLoginReconnect":     3,
		"CodeCannotFindBackend":  4,
		"CodeUndefinedDealMsg":   5,
		"CodeNotLogin":           6,
		"CodeNotRightConnector":  7,
		"CodeNotLoginBackend":    8,
	}
)

Enum value maps for CodeType.

View Source 
var (
	MsgId_name = map[int32]string{
		0: "Msg_None",
		1: "Msg_Login_Request",
		2: "Msg_Login_Response",
		3: "Msg_Multi_Login_Out",
		4: "Msg_Logout_Request",
		5: "Msg_Logout_Response",
		6: "Msg_Channel_Request",
		7: "Msg_Channel_Response",
	}
	MsgId_value = map[string]int32{
		"Msg_None":             0,
		"Msg_Login_Request":    1,
		"Msg_Login_Response":   2,
		"Msg_Multi_Login_Out":  3,
		"Msg_Logout_Request":   4,
		"Msg_Logout_Response":  5,
		"Msg_Channel_Request":  6,
		"Msg_Channel_Response": 7,
	}
)

Enum value maps for MsgId.

View Source 
var (
	RpcMsgId_name = map[int32]string{
		0: "RpcMsgNone",
		1: "RpcMsgMultiLoginOut",
		2: "RpcMsgBackendLogin",
		3: "RpcMsgBackendLogout",
		4: "RpcMsgChatTest",
	}
	RpcMsgId_value = map[string]int32{
		"RpcMsgNone":          0,
		"RpcMsgMultiLoginOut": 1,
		"RpcMsgBackendLogin":  2,
		"RpcMsgBackendLogout": 3,
		"RpcMsgChatTest":      4,
	}
)

Enum value maps for RpcMsgId.

View Source 
var File_treaty_proto protoreflect.FileDescriptor

Functions

func RegSerialize 

func RegSerialize(x *Server) string

func RegServerType 

func RegServerType(x *Server) string

func RegSeverItem 

func RegSeverItem(x *Server) string

func RegSeverQueue added in v2.0.3 

func RegSeverQueue(serverType, queue string) string

Types

type BalanceResult 

type BalanceResult struct {
	Code       CodeType `protobuf:"varint,1,opt,name=code,proto3,enum=treaty.CodeType" json:"code,omitempty"`         //0-成功 1-失败
	Connector  *Server  `protobuf:"bytes,2,opt,name=connector,proto3" json:"connector,omitempty"`                     //连接器
	Backend    *Server  `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`                         //服务器
	BackendPre *Server  `protobuf:"bytes,4,opt,name=backend_pre,json=backendPre,proto3" json:"backend_pre,omitempty"` //之前连接的服务器
	// contains filtered or unexported fields
}

func (*BalanceResult) Descriptor deprecated 

func (*BalanceResult) Descriptor() ([]byte, []int)

Deprecated: Use BalanceResult.ProtoReflect.Descriptor instead.

func (*BalanceResult) GetBackend 

func (x *BalanceResult) GetBackend() *Server

func (*BalanceResult) GetBackendPre 

func (x *BalanceResult) GetBackendPre() *Server

func (*BalanceResult) GetCode 

func (x *BalanceResult) GetCode() CodeType

func (*BalanceResult) GetConnector 

func (x *BalanceResult) GetConnector() *Server

func (*BalanceResult) ProtoMessage 

func (*BalanceResult) ProtoMessage()

func (*BalanceResult) ProtoReflect 

func (x *BalanceResult) ProtoReflect() protoreflect.Message

func (*BalanceResult) Reset 

func (x *BalanceResult) Reset()

func (*BalanceResult) String 

func (x *BalanceResult) String() string

type ChannelMsgRequest 

type ChannelMsgRequest struct {
	Uid     int32  `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`                       //用户ID
	MsgData string `protobuf:"bytes,2,opt,name=msg_data,json=msgData,proto3" json:"msg_data,omitempty"` //消息内容
	// contains filtered or unexported fields
}

func (*ChannelMsgRequest) Descriptor deprecated 

func (*ChannelMsgRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChannelMsgRequest.ProtoReflect.Descriptor instead.

func (*ChannelMsgRequest) GetMsgData 

func (x *ChannelMsgRequest) GetMsgData() string

func (*ChannelMsgRequest) GetUid 

func (x *ChannelMsgRequest) GetUid() int32

func (*ChannelMsgRequest) ProtoMessage 

func (*ChannelMsgRequest) ProtoMessage()

func (*ChannelMsgRequest) ProtoReflect 

func (x *ChannelMsgRequest) ProtoReflect() protoreflect.Message

func (*ChannelMsgRequest) Reset 

func (x *ChannelMsgRequest) Reset()

func (*ChannelMsgRequest) String 

func (x *ChannelMsgRequest) String() string

type ChannelMsgResponse 

type ChannelMsgResponse struct {
	Code      CodeType `protobuf:"varint,1,opt,name=code,proto3,enum=treaty.CodeType" json:"code,omitempty"` //通道消息结果
	Msg       string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`                         //通道消息消息
	MsgData   string   `protobuf:"bytes,3,opt,name=msg_data,json=msgData,proto3" json:"msg_data,omitempty"`  //通道返回内容
	Connector *Server  `protobuf:"bytes,4,opt,name=connector,proto3" json:"connector,omitempty"`             //绑定的connector
	// contains filtered or unexported fields
}

func (*ChannelMsgResponse) Descriptor deprecated 

func (*ChannelMsgResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChannelMsgResponse.ProtoReflect.Descriptor instead.

func (*ChannelMsgResponse) GetCode 

func (x *ChannelMsgResponse) GetCode() CodeType

func (*ChannelMsgResponse) GetConnector 

func (x *ChannelMsgResponse) GetConnector() *Server

func (*ChannelMsgResponse) GetMsg 

func (x *ChannelMsgResponse) GetMsg() string

func (*ChannelMsgResponse) GetMsgData 

func (x *ChannelMsgResponse) GetMsgData() string

func (*ChannelMsgResponse) ProtoMessage 

func (*ChannelMsgResponse) ProtoMessage()

func (*ChannelMsgResponse) ProtoReflect 

func (x *ChannelMsgResponse) ProtoReflect() protoreflect.Message

func (*ChannelMsgResponse) Reset 

func (x *ChannelMsgResponse) Reset()

func (*ChannelMsgResponse) String 

func (x *ChannelMsgResponse) String() string

type CodeType 

type CodeType int32
const (
	CodeType_CodeSuccess            CodeType = 0 //成功
	CodeType_CodeFailed             CodeType = 1 //失败
	CodeType_CodeChooseBackendLogin CodeType = 2 //选择后端服务器进行登录
	CodeType_CodeLoginReconnect     CodeType = 3 //进行重连
	CodeType_CodeCannotFindBackend  CodeType = 4 //找不到后端服务器
	CodeType_CodeUndefinedDealMsg   CodeType = 5 //未定义处理消息
	CodeType_CodeNotLogin           CodeType = 6 //未登录
	CodeType_CodeNotRightConnector  CodeType = 7 //请登录绑定connector
	CodeType_CodeNotLoginBackend    CodeType = 8 //没有登录后端服务器
)

func (CodeType) Descriptor 

func (CodeType) Descriptor() protoreflect.EnumDescriptor

func (CodeType) Enum 

func (x CodeType) Enum() *CodeType

func (CodeType) EnumDescriptor deprecated 

func (CodeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use CodeType.Descriptor instead.

func (CodeType) Number 

func (x CodeType) Number() protoreflect.EnumNumber

func (CodeType) String 

func (x CodeType) String() string

func (CodeType) Type 

func (CodeType) Type() protoreflect.EnumType

type GameChannel 

type GameChannel struct {
	Uid           int32   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`                                          //用户ID
	Connector     *Server `protobuf:"bytes,2,opt,name=connector,proto3" json:"connector,omitempty"`                               // 连接器
	Backend       *Server `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`                                   //服务器
	CreateTime    int64   `protobuf:"varint,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`          //创建时间
	ReconnectNum  int32   `protobuf:"varint,5,opt,name=reconnect_num,json=reconnectNum,proto3" json:"reconnect_num,omitempty"`    //重连次数
	ReconnectTime int64   `protobuf:"varint,6,opt,name=reconnect_time,json=reconnectTime,proto3" json:"reconnect_time,omitempty"` //重连时间
	// contains filtered or unexported fields
}

func (*GameChannel) Descriptor deprecated 

func (*GameChannel) Descriptor() ([]byte, []int)

Deprecated: Use GameChannel.ProtoReflect.Descriptor instead.

func (*GameChannel) GetBackend 

func (x *GameChannel) GetBackend() *Server

func (*GameChannel) GetConnector 

func (x *GameChannel) GetConnector() *Server

func (*GameChannel) GetCreateTime 

func (x *GameChannel) GetCreateTime() int64

func (*GameChannel) GetReconnectNum 

func (x *GameChannel) GetReconnectNum() int32

func (*GameChannel) GetReconnectTime 

func (x *GameChannel) GetReconnectTime() int64

func (*GameChannel) GetUid 

func (x *GameChannel) GetUid() int32

func (*GameChannel) ProtoMessage 

func (*GameChannel) ProtoMessage()

func (*GameChannel) ProtoReflect 

func (x *GameChannel) ProtoReflect() protoreflect.Message

func (*GameChannel) Reset 

func (x *GameChannel) Reset()

func (*GameChannel) String 

func (x *GameChannel) String() string

type LoginRequest 

type LoginRequest struct {
	Uid       int32   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`            //用户ID
	Nickname  string  `protobuf:"bytes,2,opt,name=nickname,proto3" json:"nickname,omitempty"`   //用户昵称
	Token     string  `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`         //用户token
	Backend   *Server `protobuf:"bytes,4,opt,name=backend,proto3" json:"backend,omitempty"`     //后端服务器
	Connector *Server `protobuf:"bytes,5,opt,name=connector,proto3" json:"connector,omitempty"` //客户端服务器
	// contains filtered or unexported fields
}

func (*LoginRequest) Descriptor deprecated 

func (*LoginRequest) Descriptor() ([]byte, []int)

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) GetBackend 

func (x *LoginRequest) GetBackend() *Server

func (*LoginRequest) GetConnector 

func (x *LoginRequest) GetConnector() *Server

func (*LoginRequest) GetNickname 

func (x *LoginRequest) GetNickname() string

func (*LoginRequest) GetToken 

func (x *LoginRequest) GetToken() string

func (*LoginRequest) GetUid 

func (x *LoginRequest) GetUid() int32

func (*LoginRequest) ProtoMessage 

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect 

func (x *LoginRequest) ProtoReflect() protoreflect.Message

func (*LoginRequest) Reset 

func (x *LoginRequest) Reset()

func (*LoginRequest) String 

func (x *LoginRequest) String() string

type LoginResponse 

type LoginResponse struct {
	Code    CodeType `protobuf:"varint,1,opt,name=code,proto3,enum=treaty.CodeType" json:"code,omitempty"` //登录结果
	Msg     string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`                         //登录消息
	Backend *Server  `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`                 //后端服务器
	TestInt uint64   `protobuf:"varint,4,opt,name=test_int,json=testInt,proto3" json:"test_int,omitempty"` //测试值
	// contains filtered or unexported fields
}

func (*LoginResponse) Descriptor deprecated 

func (*LoginResponse) Descriptor() ([]byte, []int)

Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.

func (*LoginResponse) GetBackend 

func (x *LoginResponse) GetBackend() *Server

func (*LoginResponse) GetCode 

func (x *LoginResponse) GetCode() CodeType

func (*LoginResponse) GetMsg 

func (x *LoginResponse) GetMsg() string

func (*LoginResponse) GetTestInt 

func (x *LoginResponse) GetTestInt() uint64

func (*LoginResponse) ProtoMessage 

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) ProtoReflect 

func (x *LoginResponse) ProtoReflect() protoreflect.Message

func (*LoginResponse) Reset 

func (x *LoginResponse) Reset()

func (*LoginResponse) String 

func (x *LoginResponse) String() string

type LogoutRequest 

type LogoutRequest struct {
	Uid     int32   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`        //用户ID
	Backend *Server `protobuf:"bytes,2,opt,name=backend,proto3" json:"backend,omitempty"` //登出服务器
	// contains filtered or unexported fields
}

func (*LogoutRequest) Descriptor deprecated 

func (*LogoutRequest) Descriptor() ([]byte, []int)

Deprecated: Use LogoutRequest.ProtoReflect.Descriptor instead.

func (*LogoutRequest) GetBackend 

func (x *LogoutRequest) GetBackend() *Server

func (*LogoutRequest) GetUid 

func (x *LogoutRequest) GetUid() int32

func (*LogoutRequest) ProtoMessage 

func (*LogoutRequest) ProtoMessage()

func (*LogoutRequest) ProtoReflect 

func (x *LogoutRequest) ProtoReflect() protoreflect.Message

func (*LogoutRequest) Reset 

func (x *LogoutRequest) Reset()

func (*LogoutRequest) String 

func (x *LogoutRequest) String() string

type LogoutResponse 

type LogoutResponse struct {
	Code CodeType `protobuf:"varint,1,opt,name=code,proto3,enum=treaty.CodeType" json:"code,omitempty"` //登出结果
	Msg  string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`                         //登出消息
	// contains filtered or unexported fields
}

func (*LogoutResponse) Descriptor deprecated 

func (*LogoutResponse) Descriptor() ([]byte, []int)

Deprecated: Use LogoutResponse.ProtoReflect.Descriptor instead.

func (*LogoutResponse) GetCode 

func (x *LogoutResponse) GetCode() CodeType

func (*LogoutResponse) GetMsg 

func (x *LogoutResponse) GetMsg() string

func (*LogoutResponse) ProtoMessage 

func (*LogoutResponse) ProtoMessage()

func (*LogoutResponse) ProtoReflect 

func (x *LogoutResponse) ProtoReflect() protoreflect.Message

func (*LogoutResponse) Reset 

func (x *LogoutResponse) Reset()

func (*LogoutResponse) String 

func (x *LogoutResponse) String() string

type MsgId 

type MsgId int32
const (
	MsgId_Msg_None             MsgId = 0
	MsgId_Msg_Login_Request    MsgId = 1 //登录请求
	MsgId_Msg_Login_Response   MsgId = 2 //登录回复
	MsgId_Msg_Multi_Login_Out  MsgId = 3 //多端登录退出
	MsgId_Msg_Logout_Request   MsgId = 4 //登出请求
	MsgId_Msg_Logout_Response  MsgId = 5 //登出回复
	MsgId_Msg_Channel_Request  MsgId = 6 //通道消息请求
	MsgId_Msg_Channel_Response MsgId = 7 //通道消息返回
)

func (MsgId) Descriptor 

func (MsgId) Descriptor() protoreflect.EnumDescriptor

func (MsgId) Enum 

func (x MsgId) Enum() *MsgId

func (MsgId) EnumDescriptor deprecated 

func (MsgId) EnumDescriptor() ([]byte, []int)

Deprecated: Use MsgId.Descriptor instead.

func (MsgId) Number 

func (x MsgId) Number() protoreflect.EnumNumber

func (MsgId) String 

func (x MsgId) String() string

func (MsgId) Type 

func (MsgId) Type() protoreflect.EnumType

type MultiLoginOut 

type MultiLoginOut struct {
	Uid int32 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` //用户ID
	// contains filtered or unexported fields
}

func (*MultiLoginOut) Descriptor deprecated 

func (*MultiLoginOut) Descriptor() ([]byte, []int)

Deprecated: Use MultiLoginOut.ProtoReflect.Descriptor instead.

func (*MultiLoginOut) GetUid 

func (x *MultiLoginOut) GetUid() int32

func (*MultiLoginOut) ProtoMessage 

func (*MultiLoginOut) ProtoMessage()

func (*MultiLoginOut) ProtoReflect 

func (x *MultiLoginOut) ProtoReflect() protoreflect.Message

func (*MultiLoginOut) Reset 

func (x *MultiLoginOut) Reset()

func (*MultiLoginOut) String 

func (x *MultiLoginOut) String() string

type RpcMsgId 

type RpcMsgId int32
const (
	RpcMsgId_RpcMsgNone          RpcMsgId = 0
	RpcMsgId_RpcMsgMultiLoginOut RpcMsgId = 1
	RpcMsgId_RpcMsgBackendLogin  RpcMsgId = 2
	RpcMsgId_RpcMsgBackendLogout RpcMsgId = 3
	RpcMsgId_RpcMsgChatTest      RpcMsgId = 4
)

func (RpcMsgId) Descriptor 

func (RpcMsgId) Descriptor() protoreflect.EnumDescriptor

func (RpcMsgId) Enum 

func (x RpcMsgId) Enum() *RpcMsgId

func (RpcMsgId) EnumDescriptor deprecated 

func (RpcMsgId) EnumDescriptor() ([]byte, []int)

Deprecated: Use RpcMsgId.Descriptor instead.

func (RpcMsgId) Number 

func (x RpcMsgId) Number() protoreflect.EnumNumber

func (RpcMsgId) String 

func (x RpcMsgId) String() string

func (RpcMsgId) Type 

func (RpcMsgId) Type() protoreflect.EnumType

type Server 

type Server struct {
	ServerId     string `protobuf:"bytes,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`              //服务器ID
	ServerType   string `protobuf:"bytes,2,opt,name=server_type,json=serverType,proto3" json:"server_type,omitempty"`        //服务器类型
	ServerName   string `protobuf:"bytes,3,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`        //服务器名字
	ServerIp     string `protobuf:"bytes,4,opt,name=server_ip,json=serverIp,proto3" json:"server_ip,omitempty"`              //服务器IP
	ClientPort   int32  `protobuf:"varint,5,opt,name=client_port,json=clientPort,proto3" json:"client_port,omitempty"`       //客户端端口
	ServerRoot   string `protobuf:"bytes,6,opt,name=server_root,json=serverRoot,proto3" json:"server_root,omitempty"`        //服务根目录
	IsLaunch     bool   `protobuf:"varint,7,opt,name=is_launch,json=isLaunch,proto3" json:"is_launch,omitempty"`             //是否加载
	Serial       bool   `protobuf:"varint,8,opt,name=serial,proto3" json:"serial,omitempty"`                                 //是否串行
	LaunchWeight int32  `protobuf:"varint,9,opt,name=launch_weight,json=launchWeight,proto3" json:"launch_weight,omitempty"` //启动权重 越大越晚
	ShutWeight   int32  `protobuf:"varint,10,opt,name=shut_weight,json=shutWeight,proto3" json:"shut_weight,omitempty"`      //关闭权重 越大越晚
	Load         int64  `protobuf:"varint,11,opt,name=load,proto3" json:"load,omitempty"`                                    //负载量
	Maintained   bool   `protobuf:"varint,12,opt,name=maintained,proto3" json:"maintained,omitempty"`                        //是否在维护中
	Silent       int32  `protobuf:"varint,13,opt,name=silent,proto3" json:"silent,omitempty"`                                //沉默注册
	Version      int64  `protobuf:"varint,14,opt,name=version,proto3" json:"version,omitempty"`                              //版本号
	// contains filtered or unexported fields
}

func RegUnSerialize 

func RegUnSerialize(s []byte) (*Server, error)

func (*Server) Descriptor deprecated 

func (*Server) Descriptor() ([]byte, []int)

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetClientPort 

func (x *Server) GetClientPort() int32

func (*Server) GetIsLaunch 

func (x *Server) GetIsLaunch() bool

func (*Server) GetLaunchWeight added in v2.0.3 

func (x *Server) GetLaunchWeight() int32

func (*Server) GetLoad added in v2.0.3 

func (x *Server) GetLoad() int64

func (*Server) GetMaintained added in v2.0.3 

func (x *Server) GetMaintained() bool

func (*Server) GetSerial added in v2.0.3 

func (x *Server) GetSerial() bool

func (*Server) GetServerId 

func (x *Server) GetServerId() string

func (*Server) GetServerIp 

func (x *Server) GetServerIp() string

func (*Server) GetServerName 

func (x *Server) GetServerName() string

func (*Server) GetServerRoot added in v2.4.8 

func (x *Server) GetServerRoot() string

func (*Server) GetServerType 

func (x *Server) GetServerType() string

func (*Server) GetShutWeight added in v2.0.3 

func (x *Server) GetShutWeight() int32

func (*Server) GetSilent added in v2.0.3 

func (x *Server) GetSilent() int32

func (*Server) GetVersion added in v2.6.5 

func (x *Server) GetVersion() int64

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect 

func (x *Server) ProtoReflect() protoreflect.Message

func (*Server) Reset 

func (x *Server) Reset()

func (*Server) String 

func (x *Server) String() string

type Session 

type Session struct {
	Uid       int32   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`            // 用户ID
	Connector *Server `protobuf:"bytes,2,opt,name=connector,proto3" json:"connector,omitempty"` // 连接器
	Backend   *Server `protobuf:"bytes,3,opt,name=backend,proto3" json:"backend,omitempty"`     //服务器
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

func (*Session) Descriptor() ([]byte, []int)

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetBackend 

func (x *Session) GetBackend() *Server

func (*Session) GetConnector 

func (x *Session) GetConnector() *Server

func (*Session) GetUid 

func (x *Session) GetUid() int32

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

func (x *Session) ProtoReflect() protoreflect.Message

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.