Documentation
¶
Index ¶
- Variables
- type Kick
- 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 Push
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetData() []byte
- func (x *Request) GetFrontendId() string
- func (x *Request) GetIp() string
- func (x *Request) GetIsError() bool
- func (x *Request) GetMsgId() uint32
- func (x *Request) GetMsgType() int32
- func (x *Request) GetReply() string
- func (x *Request) GetRoute() string
- func (x *Request) GetSetting() map[string]string
- func (x *Request) GetSid() string
- func (x *Request) GetUid() int64
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Recycle()
- func (x *Request) Reset()
- func (x *Request) String() string
- type Response
Constants ¶
This section is empty.
Variables ¶
View Source
var File_proto_proto protoreflect.FileDescriptor
View Source
var (
StartTimeKey = "1"
)
Functions ¶
This section is empty.
Types ¶
type Kick ¶ added in v1.1.29
type Kick struct { Uid int64 `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"` // uid Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // 自定义数据 Close bool `protobuf:"varint,4,opt,name=close,proto3" json:"close,omitempty"` // 是否主动关闭连接 // contains filtered or unexported fields }
踢人
func (*Kick) Descriptor
deprecated
added in
v1.1.29
func (*Kick) ProtoMessage ¶ added in v1.1.29
func (*Kick) ProtoMessage()
func (*Kick) ProtoReflect ¶ added in v1.1.29
func (x *Kick) ProtoReflect() protoreflect.Message
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 Push ¶ added in v1.1.29
type Push 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"` // uid Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // 自定义数据 // contains filtered or unexported fields }
推送
func (*Push) Descriptor
deprecated
added in
v1.1.29
func (*Push) ProtoMessage ¶ added in v1.1.29
func (*Push) ProtoMessage()
func (*Push) ProtoReflect ¶ added in v1.1.29
func (x *Push) ProtoReflect() protoreflect.Message
type Request ¶ added in v1.1.29
type Request 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 Setting map[string]string `` // 附带的参数 /* 155-byte string literal not displayed */ MsgType int32 `protobuf:"varint,6,opt,name=msgType,proto3" json:"msgType,omitempty"` // 消息类型(request,notify,response,push) MsgId uint32 `protobuf:"varint,7,opt,name=msgId,proto3" json:"msgId,omitempty"` // 消息序号id Route string `protobuf:"bytes,8,opt,name=route,proto3" json:"route,omitempty"` // 路由 Data []byte `protobuf:"bytes,9,opt,name=data,proto3" json:"data,omitempty"` // 自定义数据 IsError bool `protobuf:"varint,10,opt,name=isError,proto3" json:"isError,omitempty"` // 是否返回错误 Reply string `protobuf:"bytes,11,opt,name=reply,proto3" json:"reply,omitempty"` // 回复标识 // contains filtered or unexported fields }
请求消息结构
func GetRequest ¶ added in v1.1.29
func GetRequest() *Request
func (*Request) Descriptor
deprecated
added in
v1.1.29
func (*Request) GetFrontendId ¶ added in v1.1.29
func (*Request) GetIsError ¶ added in v1.1.29
func (*Request) GetMsgType ¶ added in v1.1.29
func (*Request) GetSetting ¶ added in v1.1.29
func (*Request) ProtoMessage ¶ added in v1.1.29
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶ added in v1.1.29
func (x *Request) ProtoReflect() protoreflect.Message
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
Click to show internal directories.
Click to hide internal directories.