Documentation
¶
Index ¶
- Variables
- type CodeResult
- 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_proto_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type CodeResult ¶ added in v1.1.21
type CodeResult 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 (*CodeResult) Descriptor
deprecated
added in
v1.1.21
func (*CodeResult) Descriptor() ([]byte, []int)
Deprecated: Use CodeResult.ProtoReflect.Descriptor instead.
func (*CodeResult) GetCode ¶ added in v1.1.21
func (x *CodeResult) GetCode() int32
func (*CodeResult) GetMessage ¶ added in v1.1.21
func (x *CodeResult) GetMessage() string
func (*CodeResult) ProtoMessage ¶ added in v1.1.21
func (*CodeResult) ProtoMessage()
func (*CodeResult) ProtoReflect ¶ added in v1.1.21
func (x *CodeResult) ProtoReflect() protoreflect.Message
func (*CodeResult) Reset ¶ added in v1.1.21
func (x *CodeResult) Reset()
func (*CodeResult) String ¶ added in v1.1.21
func (x *CodeResult) 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 { 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"` // 自定义数据 // contains filtered or unexported fields }
响应结构
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"` // 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.