Documentation ¶
Index ¶
- Variables
- type ClusterPacket
- func (*ClusterPacket) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterPacket) GetArgBytes() []byte
- func (x *ClusterPacket) GetBuildTime() int64
- func (x *ClusterPacket) GetFuncName() string
- func (x *ClusterPacket) GetSession() *Session
- func (x *ClusterPacket) GetSourcePath() string
- func (x *ClusterPacket) GetTargetPath() string
- func (x *ClusterPacket) PrintLog() string
- func (*ClusterPacket) ProtoMessage()
- func (x *ClusterPacket) ProtoReflect() protoreflect.Message
- func (x *ClusterPacket) Recycle()
- func (x *ClusterPacket) Reset()
- func (x *ClusterPacket) String() string
- type I32
- type Member
- func (*Member) Descriptor() ([]byte, []int)deprecated
- func (x *Member) GetAddress() string
- func (x *Member) GetNodeId() string
- func (x *Member) GetNodeType() string
- func (x *Member) GetSettings() map[string]string
- func (*Member) ProtoMessage()
- func (x *Member) ProtoReflect() protoreflect.Message
- func (x *Member) Reset()
- func (x *Member) String() string
- type MemberList
- type PomeloBroadcastPush
- func (*PomeloBroadcastPush) Descriptor() ([]byte, []int)deprecated
- func (x *PomeloBroadcastPush) GetAllUID() bool
- func (x *PomeloBroadcastPush) GetData() []byte
- func (x *PomeloBroadcastPush) GetRoute() string
- func (x *PomeloBroadcastPush) GetUidList() []int64
- func (*PomeloBroadcastPush) ProtoMessage()
- func (x *PomeloBroadcastPush) ProtoReflect() protoreflect.Message
- func (x *PomeloBroadcastPush) Reset()
- func (x *PomeloBroadcastPush) String() string
- type PomeloKick
- func (*PomeloKick) Descriptor() ([]byte, []int)deprecated
- func (x *PomeloKick) GetClose() bool
- func (x *PomeloKick) GetReason() []byte
- func (x *PomeloKick) GetSid() string
- func (x *PomeloKick) GetUid() int64
- func (*PomeloKick) ProtoMessage()
- func (x *PomeloKick) ProtoReflect() protoreflect.Message
- func (x *PomeloKick) Reset()
- func (x *PomeloKick) String() string
- type PomeloPush
- func (*PomeloPush) Descriptor() ([]byte, []int)deprecated
- func (x *PomeloPush) GetData() []byte
- func (x *PomeloPush) GetRoute() string
- func (x *PomeloPush) GetSid() string
- func (*PomeloPush) ProtoMessage()
- func (x *PomeloPush) ProtoReflect() protoreflect.Message
- func (x *PomeloPush) Reset()
- func (x *PomeloPush) String() string
- type PomeloResponse
- func (*PomeloResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PomeloResponse) GetCode() int32
- func (x *PomeloResponse) GetData() []byte
- func (x *PomeloResponse) GetMid() uint32
- func (x *PomeloResponse) GetSid() string
- func (*PomeloResponse) ProtoMessage()
- func (x *PomeloResponse) ProtoReflect() protoreflect.Message
- func (x *PomeloResponse) Reset()
- func (x *PomeloResponse) String() string
- type Response
- type Session
- func (x *Session) ActorPath() string
- func (x *Session) Add(key string, value interface{})
- func (x *Session) Clear()
- func (x *Session) Contains(key string) bool
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetAgentPath() string
- func (x *Session) GetData() map[string]string
- func (x *Session) GetInt(key string) int
- func (x *Session) GetInt32(key string) int32
- func (x *Session) GetInt64(key string) int64
- func (x *Session) GetIp() string
- func (x *Session) GetMid() uint32
- func (x *Session) GetSid() string
- func (x *Session) GetString(key string) string
- func (x *Session) GetUid() int64
- func (x *Session) GetUint(key string) uint
- func (x *Session) ImportAll(data map[string]string)
- func (x *Session) IsBind() bool
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Remove(key string)
- func (x *Session) Reset()
- func (x *Session) Restore(data map[string]string)
- func (x *Session) Set(key string, value string)
- func (x *Session) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_proto_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ClusterPacket ¶
type ClusterPacket struct { BuildTime int64 `protobuf:"varint,1,opt,name=buildTime,proto3" json:"buildTime,omitempty"` SourcePath string `protobuf:"bytes,2,opt,name=sourcePath,proto3" json:"sourcePath,omitempty"` TargetPath string `protobuf:"bytes,3,opt,name=targetPath,proto3" json:"targetPath,omitempty"` FuncName string `protobuf:"bytes,4,opt,name=funcName,proto3" json:"funcName,omitempty"` ArgBytes []byte `protobuf:"bytes,5,opt,name=argBytes,proto3" json:"argBytes,omitempty"` Session *Session `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func BuildClusterPacket ¶
func BuildClusterPacket(source, target, funcName string) *ClusterPacket
func GetClusterPacket ¶
func GetClusterPacket() *ClusterPacket
func (*ClusterPacket) Descriptor
deprecated
func (*ClusterPacket) Descriptor() ([]byte, []int)
Deprecated: Use ClusterPacket.ProtoReflect.Descriptor instead.
func (*ClusterPacket) GetArgBytes ¶
func (x *ClusterPacket) GetArgBytes() []byte
func (*ClusterPacket) GetBuildTime ¶
func (x *ClusterPacket) GetBuildTime() int64
func (*ClusterPacket) GetFuncName ¶
func (x *ClusterPacket) GetFuncName() string
func (*ClusterPacket) GetSession ¶
func (x *ClusterPacket) GetSession() *Session
func (*ClusterPacket) GetSourcePath ¶
func (x *ClusterPacket) GetSourcePath() string
func (*ClusterPacket) GetTargetPath ¶
func (x *ClusterPacket) GetTargetPath() string
func (*ClusterPacket) PrintLog ¶
func (x *ClusterPacket) PrintLog() string
func (*ClusterPacket) ProtoMessage ¶
func (*ClusterPacket) ProtoMessage()
func (*ClusterPacket) ProtoReflect ¶
func (x *ClusterPacket) ProtoReflect() protoreflect.Message
func (*ClusterPacket) Recycle ¶
func (x *ClusterPacket) Recycle()
func (*ClusterPacket) Reset ¶
func (x *ClusterPacket) Reset()
func (*ClusterPacket) String ¶
func (x *ClusterPacket) String() string
type I32 ¶
type I32 struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*I32) Descriptor
deprecated
func (*I32) ProtoMessage ¶
func (*I32) ProtoMessage()
func (*I32) ProtoReflect ¶
func (x *I32) ProtoReflect() protoreflect.Message
type Member ¶
type Member struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` // node id NodeType string `protobuf:"bytes,2,opt,name=nodeType,proto3" json:"nodeType,omitempty"` // node type Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // rpc ip address Settings map[string]string `` // node settings data /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
member data
func (*Member) Descriptor
deprecated
func (*Member) GetAddress ¶
func (*Member) GetNodeType ¶
func (*Member) GetSettings ¶
func (*Member) ProtoMessage ¶
func (*Member) ProtoMessage()
func (*Member) ProtoReflect ¶
func (x *Member) ProtoReflect() protoreflect.Message
type MemberList ¶
type MemberList struct { List []*Member `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"` // contains filtered or unexported fields }
member list data
func (*MemberList) Descriptor
deprecated
func (*MemberList) Descriptor() ([]byte, []int)
Deprecated: Use MemberList.ProtoReflect.Descriptor instead.
func (*MemberList) GetList ¶
func (x *MemberList) GetList() []*Member
func (*MemberList) ProtoMessage ¶
func (*MemberList) ProtoMessage()
func (*MemberList) ProtoReflect ¶
func (x *MemberList) ProtoReflect() protoreflect.Message
func (*MemberList) Reset ¶
func (x *MemberList) Reset()
func (*MemberList) String ¶
func (x *MemberList) String() string
type PomeloBroadcastPush ¶
type PomeloBroadcastPush struct { UidList []int64 `protobuf:"varint,1,rep,packed,name=uidList,proto3" json:"uidList,omitempty"` // broadcast the uid list AllUID bool `protobuf:"varint,2,opt,name=allUID,proto3" json:"allUID,omitempty"` // broadcast all uid Route string `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"` // route Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // data // contains filtered or unexported fields }
func (*PomeloBroadcastPush) Descriptor
deprecated
func (*PomeloBroadcastPush) Descriptor() ([]byte, []int)
Deprecated: Use PomeloBroadcastPush.ProtoReflect.Descriptor instead.
func (*PomeloBroadcastPush) GetAllUID ¶
func (x *PomeloBroadcastPush) GetAllUID() bool
func (*PomeloBroadcastPush) GetData ¶
func (x *PomeloBroadcastPush) GetData() []byte
func (*PomeloBroadcastPush) GetRoute ¶
func (x *PomeloBroadcastPush) GetRoute() string
func (*PomeloBroadcastPush) GetUidList ¶
func (x *PomeloBroadcastPush) GetUidList() []int64
func (*PomeloBroadcastPush) ProtoMessage ¶
func (*PomeloBroadcastPush) ProtoMessage()
func (*PomeloBroadcastPush) ProtoReflect ¶
func (x *PomeloBroadcastPush) ProtoReflect() protoreflect.Message
func (*PomeloBroadcastPush) Reset ¶
func (x *PomeloBroadcastPush) Reset()
func (*PomeloBroadcastPush) String ¶
func (x *PomeloBroadcastPush) String() string
type PomeloKick ¶
type PomeloKick struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Uid int64 `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"` Reason []byte `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"` Close bool `protobuf:"varint,4,opt,name=close,proto3" json:"close,omitempty"` // contains filtered or unexported fields }
func (*PomeloKick) Descriptor
deprecated
func (*PomeloKick) Descriptor() ([]byte, []int)
Deprecated: Use PomeloKick.ProtoReflect.Descriptor instead.
func (*PomeloKick) GetClose ¶
func (x *PomeloKick) GetClose() bool
func (*PomeloKick) GetReason ¶
func (x *PomeloKick) GetReason() []byte
func (*PomeloKick) GetSid ¶
func (x *PomeloKick) GetSid() string
func (*PomeloKick) GetUid ¶
func (x *PomeloKick) GetUid() int64
func (*PomeloKick) ProtoMessage ¶
func (*PomeloKick) ProtoMessage()
func (*PomeloKick) ProtoReflect ¶
func (x *PomeloKick) ProtoReflect() protoreflect.Message
func (*PomeloKick) Reset ¶
func (x *PomeloKick) Reset()
func (*PomeloKick) String ¶
func (x *PomeloKick) String() string
type PomeloPush ¶
type PomeloPush struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Route string `protobuf:"bytes,2,opt,name=route,proto3" json:"route,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*PomeloPush) Descriptor
deprecated
func (*PomeloPush) Descriptor() ([]byte, []int)
Deprecated: Use PomeloPush.ProtoReflect.Descriptor instead.
func (*PomeloPush) GetData ¶
func (x *PomeloPush) GetData() []byte
func (*PomeloPush) GetRoute ¶
func (x *PomeloPush) GetRoute() string
func (*PomeloPush) GetSid ¶
func (x *PomeloPush) GetSid() string
func (*PomeloPush) ProtoMessage ¶
func (*PomeloPush) ProtoMessage()
func (*PomeloPush) ProtoReflect ¶
func (x *PomeloPush) ProtoReflect() protoreflect.Message
func (*PomeloPush) Reset ¶
func (x *PomeloPush) Reset()
func (*PomeloPush) String ¶
func (x *PomeloPush) String() string
type PomeloResponse ¶
type PomeloResponse struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` Mid uint32 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` Code int32 `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"` // contains filtered or unexported fields }
func (*PomeloResponse) Descriptor
deprecated
func (*PomeloResponse) Descriptor() ([]byte, []int)
Deprecated: Use PomeloResponse.ProtoReflect.Descriptor instead.
func (*PomeloResponse) GetCode ¶
func (x *PomeloResponse) GetCode() int32
func (*PomeloResponse) GetData ¶
func (x *PomeloResponse) GetData() []byte
func (*PomeloResponse) GetMid ¶
func (x *PomeloResponse) GetMid() uint32
func (*PomeloResponse) GetSid ¶
func (x *PomeloResponse) GetSid() string
func (*PomeloResponse) ProtoMessage ¶
func (*PomeloResponse) ProtoMessage()
func (*PomeloResponse) ProtoReflect ¶
func (x *PomeloResponse) ProtoReflect() protoreflect.Message
func (*PomeloResponse) Reset ¶
func (x *PomeloResponse) Reset()
func (*PomeloResponse) String ¶
func (x *PomeloResponse) String() string
type Response ¶
type Response struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` // message code Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // message data // contains filtered or unexported fields }
cross node response data
func (*Response) Descriptor
deprecated
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type Session ¶
type Session struct { Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"` // session unique id Uid int64 `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"` // user id AgentPath string `protobuf:"bytes,3,opt,name=agentPath,proto3" json:"agentPath,omitempty"` // frontend actor agent path Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"` // ip address Mid uint32 `protobuf:"varint,5,opt,name=mid,proto3" json:"mid,omitempty"` // message id build by client Data map[string]string `` // extend data /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Session) Descriptor
deprecated
func (*Session) GetAgentPath ¶
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.