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 ¶
var File_proto_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ClusterPacket ¶ added in v1.3.0
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 ¶ added in v1.3.6
func BuildClusterPacket(source, target, funcName string) *ClusterPacket
func GetClusterPacket ¶ added in v1.3.0
func GetClusterPacket() *ClusterPacket
func (*ClusterPacket) Descriptor
deprecated
added in
v1.3.0
func (*ClusterPacket) Descriptor() ([]byte, []int)
Deprecated: Use ClusterPacket.ProtoReflect.Descriptor instead.
func (*ClusterPacket) GetArgBytes ¶ added in v1.3.0
func (x *ClusterPacket) GetArgBytes() []byte
func (*ClusterPacket) GetBuildTime ¶ added in v1.3.1
func (x *ClusterPacket) GetBuildTime() int64
func (*ClusterPacket) GetFuncName ¶ added in v1.3.0
func (x *ClusterPacket) GetFuncName() string
func (*ClusterPacket) GetSession ¶ added in v1.3.0
func (x *ClusterPacket) GetSession() *Session
func (*ClusterPacket) GetSourcePath ¶ added in v1.3.0
func (x *ClusterPacket) GetSourcePath() string
func (*ClusterPacket) GetTargetPath ¶ added in v1.3.0
func (x *ClusterPacket) GetTargetPath() string
func (*ClusterPacket) PrintLog ¶ added in v1.3.0
func (x *ClusterPacket) PrintLog() string
func (*ClusterPacket) ProtoMessage ¶ added in v1.3.0
func (*ClusterPacket) ProtoMessage()
func (*ClusterPacket) ProtoReflect ¶ added in v1.3.4
func (x *ClusterPacket) ProtoReflect() protoreflect.Message
func (*ClusterPacket) Recycle ¶ added in v1.3.0
func (x *ClusterPacket) Recycle()
func (*ClusterPacket) Reset ¶ added in v1.3.0
func (x *ClusterPacket) Reset()
func (*ClusterPacket) String ¶ added in v1.3.0
func (x *ClusterPacket) String() string
type I32 ¶ added in v1.3.0
type I32 struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*I32) Descriptor
deprecated
added in
v1.3.0
func (*I32) ProtoMessage ¶ added in v1.3.0
func (*I32) ProtoMessage()
func (*I32) ProtoReflect ¶ added in v1.3.4
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 ¶ added in v1.3.4
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
added in
v1.3.4
func (*PomeloBroadcastPush) Descriptor() ([]byte, []int)
Deprecated: Use PomeloBroadcastPush.ProtoReflect.Descriptor instead.
func (*PomeloBroadcastPush) GetAllUID ¶ added in v1.3.4
func (x *PomeloBroadcastPush) GetAllUID() bool
func (*PomeloBroadcastPush) GetData ¶ added in v1.3.4
func (x *PomeloBroadcastPush) GetData() []byte
func (*PomeloBroadcastPush) GetRoute ¶ added in v1.3.4
func (x *PomeloBroadcastPush) GetRoute() string
func (*PomeloBroadcastPush) GetUidList ¶ added in v1.3.4
func (x *PomeloBroadcastPush) GetUidList() []int64
func (*PomeloBroadcastPush) ProtoMessage ¶ added in v1.3.4
func (*PomeloBroadcastPush) ProtoMessage()
func (*PomeloBroadcastPush) ProtoReflect ¶ added in v1.3.4
func (x *PomeloBroadcastPush) ProtoReflect() protoreflect.Message
func (*PomeloBroadcastPush) Reset ¶ added in v1.3.4
func (x *PomeloBroadcastPush) Reset()
func (*PomeloBroadcastPush) String ¶ added in v1.3.4
func (x *PomeloBroadcastPush) String() string
type PomeloKick ¶ added in v1.3.0
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
added in
v1.3.0
func (*PomeloKick) Descriptor() ([]byte, []int)
Deprecated: Use PomeloKick.ProtoReflect.Descriptor instead.
func (*PomeloKick) GetClose ¶ added in v1.3.0
func (x *PomeloKick) GetClose() bool
func (*PomeloKick) GetReason ¶ added in v1.3.0
func (x *PomeloKick) GetReason() []byte
func (*PomeloKick) GetSid ¶ added in v1.3.0
func (x *PomeloKick) GetSid() string
func (*PomeloKick) GetUid ¶ added in v1.3.0
func (x *PomeloKick) GetUid() int64
func (*PomeloKick) ProtoMessage ¶ added in v1.3.0
func (*PomeloKick) ProtoMessage()
func (*PomeloKick) ProtoReflect ¶ added in v1.3.4
func (x *PomeloKick) ProtoReflect() protoreflect.Message
func (*PomeloKick) Reset ¶ added in v1.3.0
func (x *PomeloKick) Reset()
func (*PomeloKick) String ¶ added in v1.3.0
func (x *PomeloKick) String() string
type PomeloPush ¶ added in v1.3.0
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
added in
v1.3.0
func (*PomeloPush) Descriptor() ([]byte, []int)
Deprecated: Use PomeloPush.ProtoReflect.Descriptor instead.
func (*PomeloPush) GetData ¶ added in v1.3.0
func (x *PomeloPush) GetData() []byte
func (*PomeloPush) GetRoute ¶ added in v1.3.0
func (x *PomeloPush) GetRoute() string
func (*PomeloPush) GetSid ¶ added in v1.3.0
func (x *PomeloPush) GetSid() string
func (*PomeloPush) ProtoMessage ¶ added in v1.3.0
func (*PomeloPush) ProtoMessage()
func (*PomeloPush) ProtoReflect ¶ added in v1.3.4
func (x *PomeloPush) ProtoReflect() protoreflect.Message
func (*PomeloPush) Reset ¶ added in v1.3.0
func (x *PomeloPush) Reset()
func (*PomeloPush) String ¶ added in v1.3.0
func (x *PomeloPush) String() string
type PomeloResponse ¶ added in v1.3.0
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
added in
v1.3.0
func (*PomeloResponse) Descriptor() ([]byte, []int)
Deprecated: Use PomeloResponse.ProtoReflect.Descriptor instead.
func (*PomeloResponse) GetCode ¶ added in v1.3.0
func (x *PomeloResponse) GetCode() int32
func (*PomeloResponse) GetData ¶ added in v1.3.0
func (x *PomeloResponse) GetData() []byte
func (*PomeloResponse) GetMid ¶ added in v1.3.0
func (x *PomeloResponse) GetMid() uint32
func (*PomeloResponse) GetSid ¶ added in v1.3.0
func (x *PomeloResponse) GetSid() string
func (*PomeloResponse) ProtoMessage ¶ added in v1.3.0
func (*PomeloResponse) ProtoMessage()
func (*PomeloResponse) ProtoReflect ¶ added in v1.3.4
func (x *PomeloResponse) ProtoReflect() protoreflect.Message
func (*PomeloResponse) Reset ¶ added in v1.3.0
func (x *PomeloResponse) Reset()
func (*PomeloResponse) String ¶ added in v1.3.0
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) Clear ¶ added in v1.3.0
func (x *Session) Clear()
Clear releases all settings related to current sc
func (*Session) Descriptor
deprecated
func (*Session) GetAgentPath ¶ added in v1.3.0
func (*Session) GetInt32 ¶ added in v1.3.0
GetInt32 returns the value associated with the key as a int32.
func (*Session) GetInt64 ¶ added in v1.3.0
GetInt64 returns the value associated with the key as a int64.
func (*Session) GetString ¶ added in v1.3.0
GetString returns the value associated with the key as a string.
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message