Versions in this module Expand all Collapse all v0 v0.1.1 May 10, 2023 v0.1.0 May 10, 2023 v0.0.9 May 10, 2023 v0.0.8 May 9, 2023 v0.0.7 May 9, 2023 v0.0.6 May 9, 2023 Changes in this version type SERVICE + const SERVICE_ZONE v0.0.5 May 9, 2023 v0.0.4 May 9, 2023 v0.0.3 May 9, 2023 v0.0.2 May 8, 2023 Changes in this version + var File_rpc_rpc3_proto protoreflect.FileDescriptor type SERVICE + const SERVICE_NUM v0.0.1 May 7, 2023 Changes in this version + var File_rpc3_proto protoreflect.FileDescriptor + var MAIL_name = map[int32]string + var MAIL_value = map[string]int32 + var SEND_name = map[int32]string + var SEND_value = map[string]int32 + var SERVICE_name = map[int32]string + var SERVICE_value = map[string]int32 + var STUB_name = map[int32]string + var STUB_value = map[string]int32 + func Route(head *RpcHead, funcName string) string + func Unmarshal(buff []byte) (*RpcPacket, RpcHead) + func UnmarshalBody(rpcPacket *RpcPacket, pFuncType reflect.Type) []interface + func UnmarshalBodyCall(rpcPacket *RpcPacket, pFuncType reflect.Type) (error, []interface{}) + func UnmarshalHead(buff []byte) (*RpcPacket, RpcHead) + type ClusterInfo struct + Ip string + Port int32 + SocketId uint32 + Type SERVICE + Weight int32 + func (*ClusterInfo) Descriptor() ([]byte, []int) + func (*ClusterInfo) ProtoMessage() + func (x *ClusterInfo) GetIp() string + func (x *ClusterInfo) GetPort() int32 + func (x *ClusterInfo) GetSocketId() uint32 + func (x *ClusterInfo) GetType() SERVICE + func (x *ClusterInfo) GetWeight() int32 + func (x *ClusterInfo) ProtoReflect() protoreflect.Message + func (x *ClusterInfo) Reset() + func (x *ClusterInfo) String() string + type ICluster interface + Call func(params ...interface{}) + Id func() uint32 + SendMsg func(head RpcHead, funcName string, params ...interface{}) + var MGR ICluster + type MAIL int32 + const MAIL_Player + func (MAIL) Descriptor() protoreflect.EnumDescriptor + func (MAIL) EnumDescriptor() ([]byte, []int) + func (MAIL) Type() protoreflect.EnumType + func (x MAIL) Enum() *MAIL + func (x MAIL) Number() protoreflect.EnumNumber + func (x MAIL) String() string + type MailBox struct + ClusterId uint32 + Id int64 + LeaseId int64 + MailType MAIL + func (*MailBox) Descriptor() ([]byte, []int) + func (*MailBox) ProtoMessage() + func (x *MailBox) GetClusterId() uint32 + func (x *MailBox) GetId() int64 + func (x *MailBox) GetLeaseId() int64 + func (x *MailBox) GetMailType() MAIL + func (x *MailBox) ProtoReflect() protoreflect.Message + func (x *MailBox) Reset() + func (x *MailBox) String() string + type Packet struct + Buff []byte + Id uint32 + Reply string + RpcPacket *RpcPacket + func Marshal(head *RpcHead, funcName *string, params ...interface{}) Packet + func (*Packet) Descriptor() ([]byte, []int) + func (*Packet) ProtoMessage() + func (x *Packet) GetBuff() []byte + func (x *Packet) GetId() uint32 + func (x *Packet) GetReply() string + func (x *Packet) GetRpcPacket() *RpcPacket + func (x *Packet) ProtoReflect() protoreflect.Message + func (x *Packet) Reset() + func (x *Packet) String() string + type RpcHead struct + ActorName string + ClusterId uint32 + DestServerType SERVICE + Id int64 + Reply string + SendType SEND + SocketId uint32 + SrcClusterId uint32 + func (*RpcHead) Descriptor() ([]byte, []int) + func (*RpcHead) ProtoMessage() + func (x *RpcHead) GetActorName() string + func (x *RpcHead) GetClusterId() uint32 + func (x *RpcHead) GetDestServerType() SERVICE + func (x *RpcHead) GetId() int64 + func (x *RpcHead) GetReply() string + func (x *RpcHead) GetSendType() SEND + func (x *RpcHead) GetSocketId() uint32 + func (x *RpcHead) GetSrcClusterId() uint32 + func (x *RpcHead) ProtoReflect() protoreflect.Message + func (x *RpcHead) Reset() + func (x *RpcHead) String() string + type RpcPacket struct + ArgLen int32 + FuncName string + RpcBody []byte + RpcHead *RpcHead + func (*RpcPacket) Descriptor() ([]byte, []int) + func (*RpcPacket) ProtoMessage() + func (x *RpcPacket) GetArgLen() int32 + func (x *RpcPacket) GetFuncName() string + func (x *RpcPacket) GetRpcBody() []byte + func (x *RpcPacket) GetRpcHead() *RpcHead + func (x *RpcPacket) ProtoReflect() protoreflect.Message + func (x *RpcPacket) Reset() + func (x *RpcPacket) String() string + type SEND int32 + const SEND_BOARD_CAST + const SEND_POINT + func (SEND) Descriptor() protoreflect.EnumDescriptor + func (SEND) EnumDescriptor() ([]byte, []int) + func (SEND) Type() protoreflect.EnumType + func (x SEND) Enum() *SEND + func (x SEND) Number() protoreflect.EnumNumber + func (x SEND) String() string + type SERVICE int32 + const SERVICE_CLIENT + const SERVICE_DB + const SERVICE_GAME + const SERVICE_GATE + const SERVICE_NONE + func (SERVICE) Descriptor() protoreflect.EnumDescriptor + func (SERVICE) EnumDescriptor() ([]byte, []int) + func (SERVICE) Type() protoreflect.EnumType + func (x SERVICE) Enum() *SERVICE + func (x SERVICE) Number() protoreflect.EnumNumber + func (x SERVICE) String() string + type STUB int32 + const STUB_AccountMgr + const STUB_ChatMgr + const STUB_END + const STUB_Master + const STUB_PlayerMgr + func (STUB) Descriptor() protoreflect.EnumDescriptor + func (STUB) EnumDescriptor() ([]byte, []int) + func (STUB) Type() protoreflect.EnumType + func (x STUB) Enum() *STUB + func (x STUB) Number() protoreflect.EnumNumber + func (x STUB) String() string + type StubMailBox struct + ClusterId uint32 + Id int64 + LeaseId int64 + StubType STUB + func (*StubMailBox) Descriptor() ([]byte, []int) + func (*StubMailBox) ProtoMessage() + func (x *StubMailBox) GetClusterId() uint32 + func (x *StubMailBox) GetId() int64 + func (x *StubMailBox) GetLeaseId() int64 + func (x *StubMailBox) GetStubType() STUB + func (x *StubMailBox) ProtoReflect() protoreflect.Message + func (x *StubMailBox) Reset() + func (x *StubMailBox) String() string
Go to main page