Documentation ¶
Index ¶
- type ClusterPacket
- func (*ClusterPacket) Descriptor() ([]byte, []int)
- func (m *ClusterPacket) GetArgBytes() []byte
- func (m *ClusterPacket) GetFuncName() string
- func (m *ClusterPacket) GetSession() *Session
- func (m *ClusterPacket) GetSourcePath() string
- func (m *ClusterPacket) GetTargetPath() string
- func (m *ClusterPacket) PrintLog() string
- func (*ClusterPacket) ProtoMessage()
- func (m *ClusterPacket) Recycle()
- func (m *ClusterPacket) Reset()
- func (m *ClusterPacket) String() string
- func (m *ClusterPacket) XXX_DiscardUnknown()
- func (m *ClusterPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterPacket) XXX_Merge(src proto.Message)
- func (m *ClusterPacket) XXX_Size() int
- func (m *ClusterPacket) XXX_Unmarshal(b []byte) error
- type I32
- func (*I32) Descriptor() ([]byte, []int)
- func (m *I32) GetValue() int32
- func (*I32) ProtoMessage()
- func (m *I32) Reset()
- func (m *I32) String() string
- func (m *I32) XXX_DiscardUnknown()
- func (m *I32) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *I32) XXX_Merge(src proto.Message)
- func (m *I32) XXX_Size() int
- func (m *I32) XXX_Unmarshal(b []byte) error
- type Member
- func (*Member) Descriptor() ([]byte, []int)
- func (m *Member) GetAddress() string
- func (m *Member) GetNodeId() string
- func (m *Member) GetNodeType() string
- func (m *Member) GetSettings() map[string]string
- func (*Member) ProtoMessage()
- func (m *Member) Reset()
- func (m *Member) String() string
- func (m *Member) XXX_DiscardUnknown()
- func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Member) XXX_Merge(src proto.Message)
- func (m *Member) XXX_Size() int
- func (m *Member) XXX_Unmarshal(b []byte) error
- type MemberList
- func (*MemberList) Descriptor() ([]byte, []int)
- func (m *MemberList) GetList() []*Member
- func (*MemberList) ProtoMessage()
- func (m *MemberList) Reset()
- func (m *MemberList) String() string
- func (m *MemberList) XXX_DiscardUnknown()
- func (m *MemberList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MemberList) XXX_Merge(src proto.Message)
- func (m *MemberList) XXX_Size() int
- func (m *MemberList) XXX_Unmarshal(b []byte) error
- type PomeloKick
- func (*PomeloKick) Descriptor() ([]byte, []int)
- func (m *PomeloKick) GetClose() bool
- func (m *PomeloKick) GetReason() []byte
- func (m *PomeloKick) GetSid() string
- func (m *PomeloKick) GetUid() int64
- func (*PomeloKick) ProtoMessage()
- func (m *PomeloKick) Reset()
- func (m *PomeloKick) String() string
- func (m *PomeloKick) XXX_DiscardUnknown()
- func (m *PomeloKick) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PomeloKick) XXX_Merge(src proto.Message)
- func (m *PomeloKick) XXX_Size() int
- func (m *PomeloKick) XXX_Unmarshal(b []byte) error
- type PomeloPush
- func (*PomeloPush) Descriptor() ([]byte, []int)
- func (m *PomeloPush) GetData() []byte
- func (m *PomeloPush) GetRoute() string
- func (m *PomeloPush) GetSid() string
- func (*PomeloPush) ProtoMessage()
- func (m *PomeloPush) Reset()
- func (m *PomeloPush) String() string
- func (m *PomeloPush) XXX_DiscardUnknown()
- func (m *PomeloPush) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PomeloPush) XXX_Merge(src proto.Message)
- func (m *PomeloPush) XXX_Size() int
- func (m *PomeloPush) XXX_Unmarshal(b []byte) error
- type PomeloResponse
- func (*PomeloResponse) Descriptor() ([]byte, []int)
- func (m *PomeloResponse) GetCode() int32
- func (m *PomeloResponse) GetData() []byte
- func (m *PomeloResponse) GetMid() uint32
- func (m *PomeloResponse) GetSid() string
- func (*PomeloResponse) ProtoMessage()
- func (m *PomeloResponse) Reset()
- func (m *PomeloResponse) String() string
- func (m *PomeloResponse) XXX_DiscardUnknown()
- func (m *PomeloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PomeloResponse) XXX_Merge(src proto.Message)
- func (m *PomeloResponse) XXX_Size() int
- func (m *PomeloResponse) XXX_Unmarshal(b []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetCode() int32
- func (m *Response) GetData() []byte
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) String() string
- func (m *Response) XXX_DiscardUnknown()
- func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Response) XXX_Merge(src proto.Message)
- func (m *Response) XXX_Size() int
- func (m *Response) XXX_Unmarshal(b []byte) error
- type Session
- func (m *Session) ActorPath() string
- func (m *Session) Add(key string, value interface{})
- func (m *Session) Clear()
- func (m *Session) Contains(key string) bool
- func (m *Session) Copy() Session
- func (*Session) Descriptor() ([]byte, []int)
- func (m *Session) GetAgentPath() string
- func (m *Session) GetData() map[string]string
- func (m *Session) GetInt(key string) int
- func (m *Session) GetInt32(key string) int32
- func (m *Session) GetInt64(key string) int64
- func (m *Session) GetIp() string
- func (m *Session) GetMid() uint32
- func (m *Session) GetPacketTime() int64
- func (m *Session) GetSid() string
- func (m *Session) GetString(key string) string
- func (m *Session) GetUid() int64
- func (m *Session) GetUint(key string) uint
- func (m *Session) ImportAll(data map[string]string)
- func (m *Session) IsBind() bool
- func (*Session) ProtoMessage()
- func (m *Session) Remove(key string)
- func (m *Session) Reset()
- func (m *Session) Restore(data map[string]string)
- func (m *Session) Set(key string, value string)
- func (m *Session) String() string
- func (m *Session) XXX_DiscardUnknown()
- func (m *Session) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Session) XXX_Merge(src proto.Message)
- func (m *Session) XXX_Size() int
- func (m *Session) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClusterPacket ¶ added in v1.3.0
type ClusterPacket struct { SourcePath string `protobuf:"bytes,1,opt,name=sourcePath,proto3" json:"sourcePath,omitempty"` TargetPath string `protobuf:"bytes,2,opt,name=targetPath,proto3" json:"targetPath,omitempty"` FuncName string `protobuf:"bytes,3,opt,name=funcName,proto3" json:"funcName,omitempty"` ArgBytes []byte `protobuf:"bytes,4,opt,name=argBytes,proto3" json:"argBytes,omitempty"` Session *Session `protobuf:"bytes,5,opt,name=session,proto3" json:"session,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func GetClusterPacket ¶ added in v1.3.0
func GetClusterPacket() *ClusterPacket
func (*ClusterPacket) Descriptor ¶ added in v1.3.0
func (*ClusterPacket) Descriptor() ([]byte, []int)
func (*ClusterPacket) GetArgBytes ¶ added in v1.3.0
func (m *ClusterPacket) GetArgBytes() []byte
func (*ClusterPacket) GetFuncName ¶ added in v1.3.0
func (m *ClusterPacket) GetFuncName() string
func (*ClusterPacket) GetSession ¶ added in v1.3.0
func (m *ClusterPacket) GetSession() *Session
func (*ClusterPacket) GetSourcePath ¶ added in v1.3.0
func (m *ClusterPacket) GetSourcePath() string
func (*ClusterPacket) GetTargetPath ¶ added in v1.3.0
func (m *ClusterPacket) GetTargetPath() string
func (*ClusterPacket) PrintLog ¶ added in v1.3.0
func (m *ClusterPacket) PrintLog() string
func (*ClusterPacket) ProtoMessage ¶ added in v1.3.0
func (*ClusterPacket) ProtoMessage()
func (*ClusterPacket) Recycle ¶ added in v1.3.0
func (m *ClusterPacket) Recycle()
func (*ClusterPacket) Reset ¶ added in v1.3.0
func (m *ClusterPacket) Reset()
func (*ClusterPacket) String ¶ added in v1.3.0
func (m *ClusterPacket) String() string
func (*ClusterPacket) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *ClusterPacket) XXX_DiscardUnknown()
func (*ClusterPacket) XXX_Marshal ¶ added in v1.3.0
func (m *ClusterPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterPacket) XXX_Merge ¶ added in v1.3.0
func (m *ClusterPacket) XXX_Merge(src proto.Message)
func (*ClusterPacket) XXX_Size ¶ added in v1.3.0
func (m *ClusterPacket) XXX_Size() int
func (*ClusterPacket) XXX_Unmarshal ¶ added in v1.3.0
func (m *ClusterPacket) XXX_Unmarshal(b []byte) error
type I32 ¶ added in v1.3.0
type I32 struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*I32) Descriptor ¶ added in v1.3.0
func (*I32) ProtoMessage ¶ added in v1.3.0
func (*I32) ProtoMessage()
func (*I32) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *I32) XXX_DiscardUnknown()
func (*I32) XXX_Marshal ¶ added in v1.3.0
func (*I32) XXX_Unmarshal ¶ added in v1.3.0
type Member ¶
type Member struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` NodeType string `protobuf:"bytes,2,opt,name=nodeType,proto3" json:"nodeType,omitempty"` Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` Settings map[string]string `` /* 157-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
member data
func (*Member) Descriptor ¶
func (*Member) GetAddress ¶
func (*Member) GetNodeType ¶
func (*Member) GetSettings ¶
func (*Member) ProtoMessage ¶
func (*Member) ProtoMessage()
func (*Member) XXX_DiscardUnknown ¶ added in v1.1.31
func (m *Member) XXX_DiscardUnknown()
func (*Member) XXX_Marshal ¶ added in v1.1.31
func (*Member) XXX_Unmarshal ¶ added in v1.1.31
type MemberList ¶
type MemberList struct { List []*Member `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
member list data
func (*MemberList) Descriptor ¶
func (*MemberList) Descriptor() ([]byte, []int)
func (*MemberList) GetList ¶
func (m *MemberList) GetList() []*Member
func (*MemberList) ProtoMessage ¶
func (*MemberList) ProtoMessage()
func (*MemberList) Reset ¶
func (m *MemberList) Reset()
func (*MemberList) String ¶
func (m *MemberList) String() string
func (*MemberList) XXX_DiscardUnknown ¶ added in v1.1.31
func (m *MemberList) XXX_DiscardUnknown()
func (*MemberList) XXX_Marshal ¶ added in v1.1.31
func (m *MemberList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MemberList) XXX_Merge ¶ added in v1.1.31
func (m *MemberList) XXX_Merge(src proto.Message)
func (*MemberList) XXX_Size ¶ added in v1.1.31
func (m *MemberList) XXX_Size() int
func (*MemberList) XXX_Unmarshal ¶ added in v1.1.31
func (m *MemberList) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PomeloKick) Descriptor ¶ added in v1.3.0
func (*PomeloKick) Descriptor() ([]byte, []int)
func (*PomeloKick) GetClose ¶ added in v1.3.0
func (m *PomeloKick) GetClose() bool
func (*PomeloKick) GetReason ¶ added in v1.3.0
func (m *PomeloKick) GetReason() []byte
func (*PomeloKick) GetSid ¶ added in v1.3.0
func (m *PomeloKick) GetSid() string
func (*PomeloKick) GetUid ¶ added in v1.3.0
func (m *PomeloKick) GetUid() int64
func (*PomeloKick) ProtoMessage ¶ added in v1.3.0
func (*PomeloKick) ProtoMessage()
func (*PomeloKick) Reset ¶ added in v1.3.0
func (m *PomeloKick) Reset()
func (*PomeloKick) String ¶ added in v1.3.0
func (m *PomeloKick) String() string
func (*PomeloKick) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *PomeloKick) XXX_DiscardUnknown()
func (*PomeloKick) XXX_Marshal ¶ added in v1.3.0
func (m *PomeloKick) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PomeloKick) XXX_Merge ¶ added in v1.3.0
func (m *PomeloKick) XXX_Merge(src proto.Message)
func (*PomeloKick) XXX_Size ¶ added in v1.3.0
func (m *PomeloKick) XXX_Size() int
func (*PomeloKick) XXX_Unmarshal ¶ added in v1.3.0
func (m *PomeloKick) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PomeloPush) Descriptor ¶ added in v1.3.0
func (*PomeloPush) Descriptor() ([]byte, []int)
func (*PomeloPush) GetData ¶ added in v1.3.0
func (m *PomeloPush) GetData() []byte
func (*PomeloPush) GetRoute ¶ added in v1.3.0
func (m *PomeloPush) GetRoute() string
func (*PomeloPush) GetSid ¶ added in v1.3.0
func (m *PomeloPush) GetSid() string
func (*PomeloPush) ProtoMessage ¶ added in v1.3.0
func (*PomeloPush) ProtoMessage()
func (*PomeloPush) Reset ¶ added in v1.3.0
func (m *PomeloPush) Reset()
func (*PomeloPush) String ¶ added in v1.3.0
func (m *PomeloPush) String() string
func (*PomeloPush) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *PomeloPush) XXX_DiscardUnknown()
func (*PomeloPush) XXX_Marshal ¶ added in v1.3.0
func (m *PomeloPush) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PomeloPush) XXX_Merge ¶ added in v1.3.0
func (m *PomeloPush) XXX_Merge(src proto.Message)
func (*PomeloPush) XXX_Size ¶ added in v1.3.0
func (m *PomeloPush) XXX_Size() int
func (*PomeloPush) XXX_Unmarshal ¶ added in v1.3.0
func (m *PomeloPush) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PomeloResponse) Descriptor ¶ added in v1.3.0
func (*PomeloResponse) Descriptor() ([]byte, []int)
func (*PomeloResponse) GetCode ¶ added in v1.3.0
func (m *PomeloResponse) GetCode() int32
func (*PomeloResponse) GetData ¶ added in v1.3.0
func (m *PomeloResponse) GetData() []byte
func (*PomeloResponse) GetMid ¶ added in v1.3.0
func (m *PomeloResponse) GetMid() uint32
func (*PomeloResponse) GetSid ¶ added in v1.3.0
func (m *PomeloResponse) GetSid() string
func (*PomeloResponse) ProtoMessage ¶ added in v1.3.0
func (*PomeloResponse) ProtoMessage()
func (*PomeloResponse) Reset ¶ added in v1.3.0
func (m *PomeloResponse) Reset()
func (*PomeloResponse) String ¶ added in v1.3.0
func (m *PomeloResponse) String() string
func (*PomeloResponse) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *PomeloResponse) XXX_DiscardUnknown()
func (*PomeloResponse) XXX_Marshal ¶ added in v1.3.0
func (m *PomeloResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PomeloResponse) XXX_Merge ¶ added in v1.3.0
func (m *PomeloResponse) XXX_Merge(src proto.Message)
func (*PomeloResponse) XXX_Size ¶ added in v1.3.0
func (m *PomeloResponse) XXX_Size() int
func (*PomeloResponse) XXX_Unmarshal ¶ added in v1.3.0
func (m *PomeloResponse) XXX_Unmarshal(b []byte) error
type Response ¶
type Response struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
cross node response data
func (*Response) Descriptor ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) XXX_DiscardUnknown ¶ added in v1.1.31
func (m *Response) XXX_DiscardUnknown()
func (*Response) XXX_Marshal ¶ added in v1.1.31
func (*Response) XXX_Unmarshal ¶ added in v1.1.31
type Session ¶
type Session 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"` AgentPath string `protobuf:"bytes,3,opt,name=agentPath,proto3" json:"agentPath,omitempty"` Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"` Mid uint32 `protobuf:"varint,5,opt,name=mid,proto3" json:"mid,omitempty"` PacketTime int64 `protobuf:"varint,6,opt,name=packetTime,proto3" json:"packetTime,omitempty"` Data map[string]string `` /* 149-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func NewSession ¶ added in v1.3.0
func (*Session) Clear ¶ added in v1.3.0
func (m *Session) Clear()
Clear releases all settings related to current sc
func (*Session) Descriptor ¶
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) GetPacketTime ¶ added in v1.3.0
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) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *Session) XXX_DiscardUnknown()
func (*Session) XXX_Marshal ¶ added in v1.3.0
func (*Session) XXX_Unmarshal ¶ added in v1.3.0
Click to show internal directories.
Click to hide internal directories.