Documentation
¶
Index ¶
- Variables
- type ErrorResponse
- func (*ErrorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ErrorResponse) GetCode() int32
- func (x *ErrorResponse) GetMessage() string
- func (*ErrorResponse) ProtoMessage()
- func (x *ErrorResponse) ProtoReflect() protoreflect.Message
- func (x *ErrorResponse) Reset()
- func (x *ErrorResponse) String() string
- type Int64
- type KickRequest
- type LocalPacket
- func (*LocalPacket) Descriptor() ([]byte, []int)deprecated
- func (x *LocalPacket) GetData() []byte
- func (x *LocalPacket) GetIsError() bool
- func (x *LocalPacket) GetMsgId() uint32
- func (x *LocalPacket) GetMsgType() int32
- func (x *LocalPacket) GetRoute() string
- func (x *LocalPacket) GetSession() *Session
- func (*LocalPacket) ProtoMessage()
- func (x *LocalPacket) ProtoReflect() protoreflect.Message
- func (x *LocalPacket) Reset()
- func (x *LocalPacket) String() string
- 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 PushRequest
- func (*PushRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PushRequest) GetData() []byte
- func (x *PushRequest) GetRoute() string
- func (x *PushRequest) GetUid() int64
- func (*PushRequest) ProtoMessage()
- func (x *PushRequest) ProtoReflect() protoreflect.Message
- func (x *PushRequest) Reset()
- func (x *PushRequest) String() string
- type RemotePacket
- func (*RemotePacket) Descriptor() ([]byte, []int)deprecated
- func (x *RemotePacket) GetData() []byte
- func (x *RemotePacket) GetRoute() string
- func (*RemotePacket) ProtoMessage()
- func (x *RemotePacket) ProtoReflect() protoreflect.Message
- func (x *RemotePacket) Reset()
- func (x *RemotePacket) String() string
- type Response
- type Session
- func (*Session) Descriptor() ([]byte, []int)deprecated
- func (x *Session) GetData() map[string]string
- func (x *Session) GetFrontendId() string
- func (x *Session) GetIp() string
- func (x *Session) GetSid() string
- func (x *Session) GetUid() int64
- func (*Session) ProtoMessage()
- func (x *Session) ProtoReflect() protoreflect.Message
- func (x *Session) Reset()
- func (x *Session) String() string
- type String
Constants ¶
This section is empty.
Variables ¶
View Source
var File_cluster_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ErrorResponse ¶ added in v1.1.16
type ErrorResponse struct {
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*ErrorResponse) Descriptor
deprecated
added in
v1.1.16
func (*ErrorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ErrorResponse.ProtoReflect.Descriptor instead.
func (*ErrorResponse) GetCode ¶ added in v1.1.16
func (x *ErrorResponse) GetCode() int32
func (*ErrorResponse) GetMessage ¶ added in v1.1.16
func (x *ErrorResponse) GetMessage() string
func (*ErrorResponse) ProtoMessage ¶ added in v1.1.16
func (*ErrorResponse) ProtoMessage()
func (*ErrorResponse) ProtoReflect ¶ added in v1.1.16
func (x *ErrorResponse) ProtoReflect() protoreflect.Message
func (*ErrorResponse) Reset ¶ added in v1.1.16
func (x *ErrorResponse) Reset()
func (*ErrorResponse) String ¶ added in v1.1.16
func (x *ErrorResponse) String() string
type Int64 ¶ added in v1.1.20
type Int64 struct {
Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
int64 type
func (*Int64) Descriptor
deprecated
added in
v1.1.20
func (*Int64) ProtoMessage ¶ added in v1.1.20
func (*Int64) ProtoMessage()
func (*Int64) ProtoReflect ¶ added in v1.1.20
func (x *Int64) ProtoReflect() protoreflect.Message
type KickRequest ¶ added in v1.1.20
type KickRequest struct {
Uid int64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` // 踢下线的uid
Reason []byte `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // 原因
// contains filtered or unexported fields
}
踢下线消息结构(推送到网关踢用户下线)
func (*KickRequest) Descriptor
deprecated
added in
v1.1.20
func (*KickRequest) Descriptor() ([]byte, []int)
Deprecated: Use KickRequest.ProtoReflect.Descriptor instead.
func (*KickRequest) GetReason ¶ added in v1.1.20
func (x *KickRequest) GetReason() []byte
func (*KickRequest) GetUid ¶ added in v1.1.20
func (x *KickRequest) GetUid() int64
func (*KickRequest) ProtoMessage ¶ added in v1.1.20
func (*KickRequest) ProtoMessage()
func (*KickRequest) ProtoReflect ¶ added in v1.1.20
func (x *KickRequest) ProtoReflect() protoreflect.Message
func (*KickRequest) Reset ¶ added in v1.1.20
func (x *KickRequest) Reset()
func (*KickRequest) String ¶ added in v1.1.20
func (x *KickRequest) String() string
type LocalPacket ¶ added in v1.1.20
type LocalPacket struct {
Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"` // session
MsgType int32 `protobuf:"varint,2,opt,name=msgType,proto3" json:"msgType,omitempty"` // 消息类型(request,notify,response,push)
MsgId uint32 `protobuf:"varint,3,opt,name=msgId,proto3" json:"msgId,omitempty"` // 消息序号id
Route string `protobuf:"bytes,4,opt,name=route,proto3" json:"route,omitempty"` // 路由
IsError bool `protobuf:"varint,5,opt,name=isError,proto3" json:"isError,omitempty"` // 是否返回错误
Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"` // 自定义数据
// contains filtered or unexported fields
}
本地消息包(适用于网关消息转发到当前节点执行localHandle的逻辑)
func (*LocalPacket) Descriptor
deprecated
added in
v1.1.20
func (*LocalPacket) Descriptor() ([]byte, []int)
Deprecated: Use LocalPacket.ProtoReflect.Descriptor instead.
func (*LocalPacket) GetData ¶ added in v1.1.20
func (x *LocalPacket) GetData() []byte
func (*LocalPacket) GetIsError ¶ added in v1.1.20
func (x *LocalPacket) GetIsError() bool
func (*LocalPacket) GetMsgId ¶ added in v1.1.20
func (x *LocalPacket) GetMsgId() uint32
func (*LocalPacket) GetMsgType ¶ added in v1.1.20
func (x *LocalPacket) GetMsgType() int32
func (*LocalPacket) GetRoute ¶ added in v1.1.20
func (x *LocalPacket) GetRoute() string
func (*LocalPacket) GetSession ¶ added in v1.1.20
func (x *LocalPacket) GetSession() *Session
func (*LocalPacket) ProtoMessage ¶ added in v1.1.20
func (*LocalPacket) ProtoMessage()
func (*LocalPacket) ProtoReflect ¶ added in v1.1.20
func (x *LocalPacket) ProtoReflect() protoreflect.Message
func (*LocalPacket) Reset ¶ added in v1.1.20
func (x *LocalPacket) Reset()
func (*LocalPacket) String ¶ added in v1.1.20
func (x *LocalPacket) String() string
type Member ¶
type Member struct {
NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` // 节点id
NodeType string `protobuf:"bytes,2,opt,name=nodeType,proto3" json:"nodeType,omitempty"` // 节点类型
Address string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // rpc连接地址
Settings map[string]string `` // 节点配置参数
/* 157-byte string literal not displayed */
// contains filtered or unexported fields
}
成员结构
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
}
成员列表结构
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 PushRequest ¶ added in v1.1.20
type PushRequest struct {
Route string `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"` // 路由
Uid int64 `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"` // session uid
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // 自定义数据
// contains filtered or unexported fields
}
推送消息结构(推送到网关转发到用户客户端)
func (*PushRequest) Descriptor
deprecated
added in
v1.1.20
func (*PushRequest) Descriptor() ([]byte, []int)
Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.
func (*PushRequest) GetData ¶ added in v1.1.20
func (x *PushRequest) GetData() []byte
func (*PushRequest) GetRoute ¶ added in v1.1.20
func (x *PushRequest) GetRoute() string
func (*PushRequest) GetUid ¶ added in v1.1.20
func (x *PushRequest) GetUid() int64
func (*PushRequest) ProtoMessage ¶ added in v1.1.20
func (*PushRequest) ProtoMessage()
func (*PushRequest) ProtoReflect ¶ added in v1.1.20
func (x *PushRequest) ProtoReflect() protoreflect.Message
func (*PushRequest) Reset ¶ added in v1.1.20
func (x *PushRequest) Reset()
func (*PushRequest) String ¶ added in v1.1.20
func (x *PushRequest) String() string
type RemotePacket ¶ added in v1.1.20
type RemotePacket struct {
Route string `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"` // 路由
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // 自定义数据
// contains filtered or unexported fields
}
远程消息包(用于RPC调用)
func (*RemotePacket) Descriptor
deprecated
added in
v1.1.20
func (*RemotePacket) Descriptor() ([]byte, []int)
Deprecated: Use RemotePacket.ProtoReflect.Descriptor instead.
func (*RemotePacket) GetData ¶ added in v1.1.20
func (x *RemotePacket) GetData() []byte
func (*RemotePacket) GetRoute ¶ added in v1.1.20
func (x *RemotePacket) GetRoute() string
func (*RemotePacket) ProtoMessage ¶ added in v1.1.20
func (*RemotePacket) ProtoMessage()
func (*RemotePacket) ProtoReflect ¶ added in v1.1.20
func (x *RemotePacket) ProtoReflect() protoreflect.Message
func (*RemotePacket) Reset ¶ added in v1.1.20
func (x *RemotePacket) Reset()
func (*RemotePacket) String ¶ added in v1.1.20
func (x *RemotePacket) String() string
type Response ¶
type Response struct {
Error *ErrorResponse `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // 自定义数据
// contains filtered or unexported fields
}
响应结构
func (*Response) Descriptor
deprecated
func (*Response) GetError ¶ added in v1.1.17
func (x *Response) GetError() *ErrorResponse
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"` // sid
Uid int64 `protobuf:"varint,2,opt,name=uid,proto3" json:"uid,omitempty"` // uid
FrontendId string `protobuf:"bytes,3,opt,name=frontendId,proto3" json:"frontendId,omitempty"` // 前端节点id
Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"` // client ip
Data map[string]string `` // 附带的参数
/* 149-byte string literal not displayed */
// contains filtered or unexported fields
}
Session
func (*Session) Descriptor
deprecated
func (*Session) GetFrontendId ¶ added in v1.1.17
func (*Session) ProtoMessage ¶
func (*Session) ProtoMessage()
func (*Session) ProtoReflect ¶
func (x *Session) ProtoReflect() protoreflect.Message
type String ¶ added in v1.1.20
type String struct {
Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
string type
func (*String) Descriptor
deprecated
added in
v1.1.20
func (*String) ProtoMessage ¶ added in v1.1.20
func (*String) ProtoMessage()
func (*String) ProtoReflect ¶ added in v1.1.20
func (x *String) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.