Documentation ¶
Index ¶
- Constants
- func RegisterPPRpcServer(s *grpc.Server, srv PPRpcServer)
- func RegisterService(s *pprpc.Service, hook Rpcer)
- type PPMQPingClient
- type PPRpcClient
- type PPRpcServer
- type Req
- func (*Req) Descriptor() ([]byte, []int)
- func (m *Req) GetIsSleep() bool
- func (*Req) ProtoMessage()
- func (m *Req) Reset()
- func (m *Req) String() string
- func (m *Req) XXX_DiscardUnknown()
- func (m *Req) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Req) XXX_Merge(src proto.Message)
- func (m *Req) XXX_Size() int
- func (m *Req) XXX_Unmarshal(b []byte) error
- type Resp
- func (*Resp) Descriptor() ([]byte, []int)
- func (m *Resp) GetOutsideIpaddr() string
- func (*Resp) ProtoMessage()
- func (m *Resp) Reset()
- func (m *Resp) String() string
- func (m *Resp) XXX_DiscardUnknown()
- func (m *Resp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Resp) XXX_Merge(src proto.Message)
- func (m *Resp) XXX_Size() int
- func (m *Resp) XXX_Unmarshal(b []byte) error
- type Rpcer
Constants ¶
View Source
const ( CmdID uint64 = 19 CmdName string = "PPMQPing" Module string = "ppmqd" )
Variables ¶
This section is empty.
Functions ¶
func RegisterPPRpcServer ¶
func RegisterPPRpcServer(s *grpc.Server, srv PPRpcServer)
Types ¶
type PPMQPingClient ¶
type PPMQPingClient interface {
PPCall(ctx context.Context, in *Req) (*Resp, *packets.CmdPacket, error)
}
func NewPPMQPingClient ¶
func NewPPMQPingClient(cc pprpc.RPCCliConn) PPMQPingClient
type PPRpcClient ¶
type PPRpcClient interface {
PCall(ctx context.Context, in *Req, opts ...grpc.CallOption) (*Resp, error)
}
PPRpcClient is the client API for PPRpc service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPPRpcClient ¶
func NewPPRpcClient(cc *grpc.ClientConn) PPRpcClient
type PPRpcServer ¶
PPRpcServer is the server API for PPRpc service.
type Req ¶
type Req struct { // 添加是否是睡眠心跳: false, 不是睡眠心跳; true 是睡眠心跳. (如果是睡眠心跳需要在建立连接前发送唤醒命令) IsSleep bool `protobuf:"varint,8,opt,name=is_sleep,json=isSleep,proto3" json:"is_sleep"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Reqest
func (*Req) Descriptor ¶
func (*Req) GetIsSleep ¶
func (*Req) ProtoMessage ¶
func (*Req) ProtoMessage()
func (*Req) XXX_DiscardUnknown ¶
func (m *Req) XXX_DiscardUnknown()
func (*Req) XXX_Unmarshal ¶
type Resp ¶
type Resp struct { OutsideIpaddr string `protobuf:"bytes,1,opt,name=outside_ipaddr,json=outsideIpaddr,proto3" json:"outside_ipaddr"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response
func (*Resp) Descriptor ¶
func (*Resp) GetOutsideIpaddr ¶
func (*Resp) ProtoMessage ¶
func (*Resp) ProtoMessage()
func (*Resp) XXX_DiscardUnknown ¶
func (m *Resp) XXX_DiscardUnknown()
func (*Resp) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.