rpc

package
v0.0.0-...-b9a86dc Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 27, 2017 License: MIT Imports: 5 Imported by: 23

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files: 

access.proto
idgen.proto
logic.proto
manager.proto
notify.proto
register.proto

It has these top-level messages: 

ASSendP2PMsgReq
ASSendP2PMsgRes
ASSendP2PMsgFromJobReq
ASSendP2PMsgFromJobRes
ASSendNotifyReq
ASSendNotifyRes
Snowflake
LoginReq
LoginRes
PingReq
PingRes
SendP2PMsgReq
SendP2PMsgRes
SyncMsgReq
SyncMsgRes
AcceptP2PMsgAckReq
AcceptP2PMsgAckRes
SendGroupMsgReq
SendGroupMsgRes
MGExceptionMsgReq
MGExceptionMsgRes
MGSyncMsgReq
MGSyncMsgRes
NFNotifyMsgReq
NFNotifyMsgRes
RGRegisterReq
RGRegisterRes
RGLoginReq
RGLoginRes
RGAccessReq
RGAccessRes
RGAuthReq
RGAuthRes
RGPingReq
RGPingRes
RGOnlineReq
RGOnlineRes
RGGetUsersByGroupIDReq
RGGetUsersByGroupIDRes
RGCreateGroupReq
RGCreateGroupRes
RGJoinGroupReq
RGJoinGroupRes
RGQuitGroupReq
RGQuitGroupRes

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAccessServerRPCServer 

func RegisterAccessServerRPCServer(s *grpc.Server, srv AccessServerRPCServer)

func RegisterIDGenServerRPCServer 

func RegisterIDGenServerRPCServer(s *grpc.Server, srv IDGenServerRPCServer)

func RegisterLogicRPCServer 

func RegisterLogicRPCServer(s *grpc.Server, srv LogicRPCServer)

func RegisterManagerServerRPCServer 

func RegisterManagerServerRPCServer(s *grpc.Server, srv ManagerServerRPCServer)

func RegisterNotifyServerRPCServer 

func RegisterNotifyServerRPCServer(s *grpc.Server, srv NotifyServerRPCServer)

func RegisterRegisterServerRPCServer 

func RegisterRegisterServerRPCServer(s *grpc.Server, srv RegisterServerRPCServer)

Types

type ASSendNotifyReq 

type ASSendNotifyReq struct {
	UID              int64  `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
	CurrentID        int64  `protobuf:"varint,2,opt,name=currentID" json:"currentID,omitempty"`
	TotalID          int64  `protobuf:"varint,3,opt,name=totalID" json:"totalID,omitempty"`
	AccessServerAddr string `protobuf:"bytes,4,opt,name=accessServerAddr" json:"accessServerAddr,omitempty"`
}

func (*ASSendNotifyReq) Descriptor 

func (*ASSendNotifyReq) Descriptor() ([]byte, []int)

func (*ASSendNotifyReq) GetAccessServerAddr 

func (m *ASSendNotifyReq) GetAccessServerAddr() string

func (*ASSendNotifyReq) GetCurrentID 

func (m *ASSendNotifyReq) GetCurrentID() int64

func (*ASSendNotifyReq) GetTotalID 

func (m *ASSendNotifyReq) GetTotalID() int64

func (*ASSendNotifyReq) GetUID 

func (m *ASSendNotifyReq) GetUID() int64

func (*ASSendNotifyReq) ProtoMessage 

func (*ASSendNotifyReq) ProtoMessage()

func (*ASSendNotifyReq) Reset 

func (m *ASSendNotifyReq) Reset()

func (*ASSendNotifyReq) String 

func (m *ASSendNotifyReq) String() string

type ASSendNotifyRes 

type ASSendNotifyRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*ASSendNotifyRes) Descriptor 

func (*ASSendNotifyRes) Descriptor() ([]byte, []int)

func (*ASSendNotifyRes) GetErrCode 

func (m *ASSendNotifyRes) GetErrCode() uint32

func (*ASSendNotifyRes) GetErrStr 

func (m *ASSendNotifyRes) GetErrStr() string

func (*ASSendNotifyRes) ProtoMessage 

func (*ASSendNotifyRes) ProtoMessage()

func (*ASSendNotifyRes) Reset 

func (m *ASSendNotifyRes) Reset()

func (*ASSendNotifyRes) String 

func (m *ASSendNotifyRes) String() string

type ASSendP2PMsgFromJobReq 

type ASSendP2PMsgFromJobReq struct {
	SourceUID        int64  `protobuf:"varint,1,opt,name=sourceUID" json:"sourceUID,omitempty"`
	TargetUID        int64  `protobuf:"varint,2,opt,name=targetUID" json:"targetUID,omitempty"`
	MsgID            string `protobuf:"bytes,3,opt,name=msgID" json:"msgID,omitempty"`
	Msg              string `protobuf:"bytes,4,opt,name=msg" json:"msg,omitempty"`
	AccessServerAddr string `protobuf:"bytes,5,opt,name=accessServerAddr" json:"accessServerAddr,omitempty"`
}

func (*ASSendP2PMsgFromJobReq) Descriptor 

func (*ASSendP2PMsgFromJobReq) Descriptor() ([]byte, []int)

func (*ASSendP2PMsgFromJobReq) GetAccessServerAddr 

func (m *ASSendP2PMsgFromJobReq) GetAccessServerAddr() string

func (*ASSendP2PMsgFromJobReq) GetMsg 

func (m *ASSendP2PMsgFromJobReq) GetMsg() string

func (*ASSendP2PMsgFromJobReq) GetMsgID 

func (m *ASSendP2PMsgFromJobReq) GetMsgID() string

func (*ASSendP2PMsgFromJobReq) GetSourceUID 

func (m *ASSendP2PMsgFromJobReq) GetSourceUID() int64

func (*ASSendP2PMsgFromJobReq) GetTargetUID 

func (m *ASSendP2PMsgFromJobReq) GetTargetUID() int64

func (*ASSendP2PMsgFromJobReq) ProtoMessage 

func (*ASSendP2PMsgFromJobReq) ProtoMessage()

func (*ASSendP2PMsgFromJobReq) Reset 

func (m *ASSendP2PMsgFromJobReq) Reset()

func (*ASSendP2PMsgFromJobReq) String 

func (m *ASSendP2PMsgFromJobReq) String() string

type ASSendP2PMsgFromJobRes 

type ASSendP2PMsgFromJobRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*ASSendP2PMsgFromJobRes) Descriptor 

func (*ASSendP2PMsgFromJobRes) Descriptor() ([]byte, []int)

func (*ASSendP2PMsgFromJobRes) GetErrCode 

func (m *ASSendP2PMsgFromJobRes) GetErrCode() uint32

func (*ASSendP2PMsgFromJobRes) GetErrStr 

func (m *ASSendP2PMsgFromJobRes) GetErrStr() string

func (*ASSendP2PMsgFromJobRes) ProtoMessage 

func (*ASSendP2PMsgFromJobRes) ProtoMessage()

func (*ASSendP2PMsgFromJobRes) Reset 

func (m *ASSendP2PMsgFromJobRes) Reset()

func (*ASSendP2PMsgFromJobRes) String 

func (m *ASSendP2PMsgFromJobRes) String() string

type ASSendP2PMsgReq 

type ASSendP2PMsgReq struct {
	SourceUID int64  `protobuf:"varint,1,opt,name=sourceUID" json:"sourceUID,omitempty"`
	TargetUID int64  `protobuf:"varint,2,opt,name=targetUID" json:"targetUID,omitempty"`
	MsgID     string `protobuf:"bytes,3,opt,name=msgID" json:"msgID,omitempty"`
	Msg       string `protobuf:"bytes,4,opt,name=msg" json:"msg,omitempty"`
}

func (*ASSendP2PMsgReq) Descriptor 

func (*ASSendP2PMsgReq) Descriptor() ([]byte, []int)

func (*ASSendP2PMsgReq) GetMsg 

func (m *ASSendP2PMsgReq) GetMsg() string

func (*ASSendP2PMsgReq) GetMsgID 

func (m *ASSendP2PMsgReq) GetMsgID() string

func (*ASSendP2PMsgReq) GetSourceUID 

func (m *ASSendP2PMsgReq) GetSourceUID() int64

func (*ASSendP2PMsgReq) GetTargetUID 

func (m *ASSendP2PMsgReq) GetTargetUID() int64

func (*ASSendP2PMsgReq) ProtoMessage 

func (*ASSendP2PMsgReq) ProtoMessage()

func (*ASSendP2PMsgReq) Reset 

func (m *ASSendP2PMsgReq) Reset()

func (*ASSendP2PMsgReq) String 

func (m *ASSendP2PMsgReq) String() string

type ASSendP2PMsgRes 

type ASSendP2PMsgRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*ASSendP2PMsgRes) Descriptor 

func (*ASSendP2PMsgRes) Descriptor() ([]byte, []int)

func (*ASSendP2PMsgRes) GetErrCode 

func (m *ASSendP2PMsgRes) GetErrCode() uint32

func (*ASSendP2PMsgRes) GetErrStr 

func (m *ASSendP2PMsgRes) GetErrStr() string

func (*ASSendP2PMsgRes) ProtoMessage 

func (*ASSendP2PMsgRes) ProtoMessage()

func (*ASSendP2PMsgRes) Reset 

func (m *ASSendP2PMsgRes) Reset()

func (*ASSendP2PMsgRes) String 

func (m *ASSendP2PMsgRes) String() string

type AcceptP2PMsgAckReq 

type AcceptP2PMsgAckReq struct {
	SourceUID int64  `protobuf:"varint,1,opt,name=sourceUID" json:"sourceUID,omitempty"`
	TargetUID int64  `protobuf:"varint,2,opt,name=targetUID" json:"targetUID,omitempty"`
	MsgID     string `protobuf:"bytes,3,opt,name=msgID" json:"msgID,omitempty"`
}

p2p msg accept ack

func (*AcceptP2PMsgAckReq) Descriptor 

func (*AcceptP2PMsgAckReq) Descriptor() ([]byte, []int)

func (*AcceptP2PMsgAckReq) GetMsgID 

func (m *AcceptP2PMsgAckReq) GetMsgID() string

func (*AcceptP2PMsgAckReq) GetSourceUID 

func (m *AcceptP2PMsgAckReq) GetSourceUID() int64

func (*AcceptP2PMsgAckReq) GetTargetUID 

func (m *AcceptP2PMsgAckReq) GetTargetUID() int64

func (*AcceptP2PMsgAckReq) ProtoMessage 

func (*AcceptP2PMsgAckReq) ProtoMessage()

func (*AcceptP2PMsgAckReq) Reset 

func (m *AcceptP2PMsgAckReq) Reset()

func (*AcceptP2PMsgAckReq) String 

func (m *AcceptP2PMsgAckReq) String() string

type AcceptP2PMsgAckRes 

type AcceptP2PMsgAckRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*AcceptP2PMsgAckRes) Descriptor 

func (*AcceptP2PMsgAckRes) Descriptor() ([]byte, []int)

func (*AcceptP2PMsgAckRes) GetErrCode 

func (m *AcceptP2PMsgAckRes) GetErrCode() uint32

func (*AcceptP2PMsgAckRes) GetErrStr 

func (m *AcceptP2PMsgAckRes) GetErrStr() string

func (*AcceptP2PMsgAckRes) ProtoMessage 

func (*AcceptP2PMsgAckRes) ProtoMessage()

func (*AcceptP2PMsgAckRes) Reset 

func (m *AcceptP2PMsgAckRes) Reset()

func (*AcceptP2PMsgAckRes) String 

func (m *AcceptP2PMsgAckRes) String() string

type AccessServerRPCClient 

type AccessServerRPCClient interface {
	SendP2PMsgFromJob(ctx context.Context, in *ASSendP2PMsgFromJobReq, opts ...grpc.CallOption) (*ASSendP2PMsgFromJobRes, error)
	SendNotify(ctx context.Context, in *ASSendNotifyReq, opts ...grpc.CallOption) (*ASSendNotifyRes, error)
}

func NewAccessServerRPCClient 

func NewAccessServerRPCClient(cc *grpc.ClientConn) AccessServerRPCClient

type AccessServerRPCServer 

type AccessServerRPCServer interface {
	SendP2PMsgFromJob(context.Context, *ASSendP2PMsgFromJobReq) (*ASSendP2PMsgFromJobRes, error)
	SendNotify(context.Context, *ASSendNotifyReq) (*ASSendNotifyRes, error)
}

type IDGenServerRPCClient 

type IDGenServerRPCClient interface {
	Next(ctx context.Context, in *Snowflake_Key, opts ...grpc.CallOption) (*Snowflake_Value, error)
	GetUUID(ctx context.Context, in *Snowflake_NullRequest, opts ...grpc.CallOption) (*Snowflake_UUID, error)
}

func NewIDGenServerRPCClient 

func NewIDGenServerRPCClient(cc *grpc.ClientConn) IDGenServerRPCClient

type IDGenServerRPCServer 

type IDGenServerRPCServer interface {
	Next(context.Context, *Snowflake_Key) (*Snowflake_Value, error)
	GetUUID(context.Context, *Snowflake_NullRequest) (*Snowflake_UUID, error)
}

type LogicRPCClient 

type LogicRPCClient interface {
	Login(ctx context.Context, in *LoginReq, opts ...grpc.CallOption) (*LoginRes, error)
	Ping(ctx context.Context, in *PingReq, opts ...grpc.CallOption) (*PingRes, error)
	SendP2PMsg(ctx context.Context, in *SendP2PMsgReq, opts ...grpc.CallOption) (*SendP2PMsgRes, error)
	// client sync msg use current id
	SyncMsg(ctx context.Context, in *SyncMsgReq, opts ...grpc.CallOption) (*SyncMsgRes, error)
	AcceptP2PMsgAck(ctx context.Context, in *AcceptP2PMsgAckReq, opts ...grpc.CallOption) (*AcceptP2PMsgAckRes, error)
	SendGroupMsg(ctx context.Context, in *SendGroupMsgReq, opts ...grpc.CallOption) (*SendGroupMsgRes, error)
}

func NewLogicRPCClient 

func NewLogicRPCClient(cc *grpc.ClientConn) LogicRPCClient

type LogicRPCServer 

type LogicRPCServer interface {
	Login(context.Context, *LoginReq) (*LoginRes, error)
	Ping(context.Context, *PingReq) (*PingRes, error)
	SendP2PMsg(context.Context, *SendP2PMsgReq) (*SendP2PMsgRes, error)
	// client sync msg use current id
	SyncMsg(context.Context, *SyncMsgReq) (*SyncMsgRes, error)
	AcceptP2PMsgAck(context.Context, *AcceptP2PMsgAckReq) (*AcceptP2PMsgAckRes, error)
	SendGroupMsg(context.Context, *SendGroupMsgReq) (*SendGroupMsgRes, error)
}

type LoginReq 

type LoginReq struct {
	UID        int64  `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
	Token      string `protobuf:"bytes,2,opt,name=token" json:"token,omitempty"`
	AccessAddr string `protobuf:"bytes,3,opt,name=accessAddr" json:"accessAddr,omitempty"`
}

func (*LoginReq) Descriptor 

func (*LoginReq) Descriptor() ([]byte, []int)

func (*LoginReq) GetAccessAddr 

func (m *LoginReq) GetAccessAddr() string

func (*LoginReq) GetToken 

func (m *LoginReq) GetToken() string

func (*LoginReq) GetUID 

func (m *LoginReq) GetUID() int64

func (*LoginReq) ProtoMessage 

func (*LoginReq) ProtoMessage()

func (*LoginReq) Reset 

func (m *LoginReq) Reset()

func (*LoginReq) String 

func (m *LoginReq) String() string

type LoginRes 

type LoginRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*LoginRes) Descriptor 

func (*LoginRes) Descriptor() ([]byte, []int)

func (*LoginRes) GetErrCode 

func (m *LoginRes) GetErrCode() uint32

func (*LoginRes) GetErrStr 

func (m *LoginRes) GetErrStr() string

func (*LoginRes) ProtoMessage 

func (*LoginRes) ProtoMessage()

func (*LoginRes) Reset 

func (m *LoginRes) Reset()

func (*LoginRes) String 

func (m *LoginRes) String() string

type MGExceptionMsgReq 

type MGExceptionMsgReq struct {
	SourceUID int64  `protobuf:"varint,1,opt,name=sourceUID" json:"sourceUID,omitempty"`
	TargetUID int64  `protobuf:"varint,2,opt,name=targetUID" json:"targetUID,omitempty"`
	MsgID     string `protobuf:"bytes,3,opt,name=msgID" json:"msgID,omitempty"`
	Msg       string `protobuf:"bytes,4,opt,name=msg" json:"msg,omitempty"`
}

func (*MGExceptionMsgReq) Descriptor 

func (*MGExceptionMsgReq) Descriptor() ([]byte, []int)

func (*MGExceptionMsgReq) GetMsg 

func (m *MGExceptionMsgReq) GetMsg() string

func (*MGExceptionMsgReq) GetMsgID 

func (m *MGExceptionMsgReq) GetMsgID() string

func (*MGExceptionMsgReq) GetSourceUID 

func (m *MGExceptionMsgReq) GetSourceUID() int64

func (*MGExceptionMsgReq) GetTargetUID 

func (m *MGExceptionMsgReq) GetTargetUID() int64

func (*MGExceptionMsgReq) ProtoMessage 

func (*MGExceptionMsgReq) ProtoMessage()

func (*MGExceptionMsgReq) Reset 

func (m *MGExceptionMsgReq) Reset()

func (*MGExceptionMsgReq) String 

func (m *MGExceptionMsgReq) String() string

type MGExceptionMsgRes 

type MGExceptionMsgRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*MGExceptionMsgRes) Descriptor 

func (*MGExceptionMsgRes) Descriptor() ([]byte, []int)

func (*MGExceptionMsgRes) GetErrCode 

func (m *MGExceptionMsgRes) GetErrCode() uint32

func (*MGExceptionMsgRes) GetErrStr 

func (m *MGExceptionMsgRes) GetErrStr() string

func (*MGExceptionMsgRes) ProtoMessage 

func (*MGExceptionMsgRes) ProtoMessage()

func (*MGExceptionMsgRes) Reset 

func (m *MGExceptionMsgRes) Reset()

func (*MGExceptionMsgRes) String 

func (m *MGExceptionMsgRes) String() string

type MGSyncMsgReq 

type MGSyncMsgReq struct {
	UID       int64 `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
	CurrentID int64 `protobuf:"varint,2,opt,name=currentID" json:"currentID,omitempty"`
	TotalID   int64 `protobuf:"varint,3,opt,name=totalID" json:"totalID,omitempty"`
}

Sync

func (*MGSyncMsgReq) Descriptor 

func (*MGSyncMsgReq) Descriptor() ([]byte, []int)

func (*MGSyncMsgReq) GetCurrentID 

func (m *MGSyncMsgReq) GetCurrentID() int64

func (*MGSyncMsgReq) GetTotalID 

func (m *MGSyncMsgReq) GetTotalID() int64

func (*MGSyncMsgReq) GetUID 

func (m *MGSyncMsgReq) GetUID() int64

func (*MGSyncMsgReq) ProtoMessage 

func (*MGSyncMsgReq) ProtoMessage()

func (*MGSyncMsgReq) Reset 

func (m *MGSyncMsgReq) Reset()

func (*MGSyncMsgReq) String 

func (m *MGSyncMsgReq) String() string

type MGSyncMsgRes 

type MGSyncMsgRes struct {
	ErrCode   uint32                   `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr    string                   `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
	CurrentID int64                    `protobuf:"varint,3,opt,name=currentID" json:"currentID,omitempty"`
	Msgs      []*MGSyncMsgResOffsetMsg `protobuf:"bytes,4,rep,name=Msgs" json:"Msgs,omitempty"`
}

func (*MGSyncMsgRes) Descriptor 

func (*MGSyncMsgRes) Descriptor() ([]byte, []int)

func (*MGSyncMsgRes) GetCurrentID 

func (m *MGSyncMsgRes) GetCurrentID() int64

func (*MGSyncMsgRes) GetErrCode 

func (m *MGSyncMsgRes) GetErrCode() uint32

func (*MGSyncMsgRes) GetErrStr 

func (m *MGSyncMsgRes) GetErrStr() string

func (*MGSyncMsgRes) GetMsgs 

func (m *MGSyncMsgRes) GetMsgs() []*MGSyncMsgResOffsetMsg

func (*MGSyncMsgRes) ProtoMessage 

func (*MGSyncMsgRes) ProtoMessage()

func (*MGSyncMsgRes) Reset 

func (m *MGSyncMsgRes) Reset()

func (*MGSyncMsgRes) String 

func (m *MGSyncMsgRes) String() string

type MGSyncMsgResOffsetMsg 

type MGSyncMsgResOffsetMsg struct {
	SourceUID int64  `protobuf:"varint,1,opt,name=sourceUID" json:"sourceUID,omitempty"`
	TargetUID int64  `protobuf:"varint,2,opt,name=targetUID" json:"targetUID,omitempty"`
	GroupID   int64  `protobuf:"varint,3,opt,name=groupID" json:"groupID,omitempty"`
	MsgType   string `protobuf:"bytes,4,opt,name=msgType" json:"msgType,omitempty"`
	MsgID     string `protobuf:"bytes,5,opt,name=msgID" json:"msgID,omitempty"`
	Msg       string `protobuf:"bytes,6,opt,name=msg" json:"msg,omitempty"`
}

func (*MGSyncMsgResOffsetMsg) Descriptor 

func (*MGSyncMsgResOffsetMsg) Descriptor() ([]byte, []int)

func (*MGSyncMsgResOffsetMsg) GetGroupID 

func (m *MGSyncMsgResOffsetMsg) GetGroupID() int64

func (*MGSyncMsgResOffsetMsg) GetMsg 

func (m *MGSyncMsgResOffsetMsg) GetMsg() string

func (*MGSyncMsgResOffsetMsg) GetMsgID 

func (m *MGSyncMsgResOffsetMsg) GetMsgID() string

func (*MGSyncMsgResOffsetMsg) GetMsgType 

func (m *MGSyncMsgResOffsetMsg) GetMsgType() string

func (*MGSyncMsgResOffsetMsg) GetSourceUID 

func (m *MGSyncMsgResOffsetMsg) GetSourceUID() int64

func (*MGSyncMsgResOffsetMsg) GetTargetUID 

func (m *MGSyncMsgResOffsetMsg) GetTargetUID() int64

func (*MGSyncMsgResOffsetMsg) ProtoMessage 

func (*MGSyncMsgResOffsetMsg) ProtoMessage()

func (*MGSyncMsgResOffsetMsg) Reset 

func (m *MGSyncMsgResOffsetMsg) Reset()

func (*MGSyncMsgResOffsetMsg) String 

func (m *MGSyncMsgResOffsetMsg) String() string

type ManagerServerRPCClient 

type ManagerServerRPCClient interface {
	SetExceptionMsg(ctx context.Context, in *MGExceptionMsgReq, opts ...grpc.CallOption) (*MGExceptionMsgRes, error)
	// rpc GetOfflineMsgs (MGOfflineMsgReq) returns (MGOfflineMsgRes) {}
	Sync(ctx context.Context, in *MGSyncMsgReq, opts ...grpc.CallOption) (*MGSyncMsgRes, error)
}

func NewManagerServerRPCClient 

func NewManagerServerRPCClient(cc *grpc.ClientConn) ManagerServerRPCClient

type ManagerServerRPCServer 

type ManagerServerRPCServer interface {
	SetExceptionMsg(context.Context, *MGExceptionMsgReq) (*MGExceptionMsgRes, error)
	// rpc GetOfflineMsgs (MGOfflineMsgReq) returns (MGOfflineMsgRes) {}
	Sync(context.Context, *MGSyncMsgReq) (*MGSyncMsgRes, error)
}

type NFNotifyMsgReq 

type NFNotifyMsgReq struct {
	TargetUID        int64  `protobuf:"varint,1,opt,name=targetUID" json:"targetUID,omitempty"`
	TotalID          int64  `protobuf:"varint,2,opt,name=totalID" json:"totalID,omitempty"`
	AccessServerAddr string `protobuf:"bytes,3,opt,name=accessServerAddr" json:"accessServerAddr,omitempty"`
}

func (*NFNotifyMsgReq) Descriptor 

func (*NFNotifyMsgReq) Descriptor() ([]byte, []int)

func (*NFNotifyMsgReq) GetAccessServerAddr 

func (m *NFNotifyMsgReq) GetAccessServerAddr() string

func (*NFNotifyMsgReq) GetTargetUID 

func (m *NFNotifyMsgReq) GetTargetUID() int64

func (*NFNotifyMsgReq) GetTotalID 

func (m *NFNotifyMsgReq) GetTotalID() int64

func (*NFNotifyMsgReq) ProtoMessage 

func (*NFNotifyMsgReq) ProtoMessage()

func (*NFNotifyMsgReq) Reset 

func (m *NFNotifyMsgReq) Reset()

func (*NFNotifyMsgReq) String 

func (m *NFNotifyMsgReq) String() string

type NFNotifyMsgRes 

type NFNotifyMsgRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*NFNotifyMsgRes) Descriptor 

func (*NFNotifyMsgRes) Descriptor() ([]byte, []int)

func (*NFNotifyMsgRes) GetErrCode 

func (m *NFNotifyMsgRes) GetErrCode() uint32

func (*NFNotifyMsgRes) GetErrStr 

func (m *NFNotifyMsgRes) GetErrStr() string

func (*NFNotifyMsgRes) ProtoMessage 

func (*NFNotifyMsgRes) ProtoMessage()

func (*NFNotifyMsgRes) Reset 

func (m *NFNotifyMsgRes) Reset()

func (*NFNotifyMsgRes) String 

func (m *NFNotifyMsgRes) String() string

type NotifyServerRPCClient 

type NotifyServerRPCClient interface {
	Notify(ctx context.Context, in *NFNotifyMsgReq, opts ...grpc.CallOption) (*NFNotifyMsgRes, error)
}

func NewNotifyServerRPCClient 

func NewNotifyServerRPCClient(cc *grpc.ClientConn) NotifyServerRPCClient

type NotifyServerRPCServer 

type NotifyServerRPCServer interface {
	Notify(context.Context, *NFNotifyMsgReq) (*NFNotifyMsgRes, error)
}

type PingReq 

type PingReq struct {
	UID int64 `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
}

func (*PingReq) Descriptor 

func (*PingReq) Descriptor() ([]byte, []int)

func (*PingReq) GetUID 

func (m *PingReq) GetUID() int64

func (*PingReq) ProtoMessage 

func (*PingReq) ProtoMessage()

func (*PingReq) Reset 

func (m *PingReq) Reset()

func (*PingReq) String 

func (m *PingReq) String() string

type PingRes 

type PingRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*PingRes) Descriptor 

func (*PingRes) Descriptor() ([]byte, []int)

func (*PingRes) GetErrCode 

func (m *PingRes) GetErrCode() uint32

func (*PingRes) GetErrStr 

func (m *PingRes) GetErrStr() string

func (*PingRes) ProtoMessage 

func (*PingRes) ProtoMessage()

func (*PingRes) Reset 

func (m *PingRes) Reset()

func (*PingRes) String 

func (m *PingRes) String() string

type RGAccessReq 

type RGAccessReq struct {
	UID int64 `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
}

func (*RGAccessReq) Descriptor 

func (*RGAccessReq) Descriptor() ([]byte, []int)

func (*RGAccessReq) GetUID 

func (m *RGAccessReq) GetUID() int64

func (*RGAccessReq) ProtoMessage 

func (*RGAccessReq) ProtoMessage()

func (*RGAccessReq) Reset 

func (m *RGAccessReq) Reset()

func (*RGAccessReq) String 

func (m *RGAccessReq) String() string

type RGAccessRes 

type RGAccessRes struct {
	ErrCode    uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr     string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
	AccessAddr string `protobuf:"bytes,3,opt,name=accessAddr" json:"accessAddr,omitempty"`
}

func (*RGAccessRes) Descriptor 

func (*RGAccessRes) Descriptor() ([]byte, []int)

func (*RGAccessRes) GetAccessAddr 

func (m *RGAccessRes) GetAccessAddr() string

func (*RGAccessRes) GetErrCode 

func (m *RGAccessRes) GetErrCode() uint32

func (*RGAccessRes) GetErrStr 

func (m *RGAccessRes) GetErrStr() string

func (*RGAccessRes) ProtoMessage 

func (*RGAccessRes) ProtoMessage()

func (*RGAccessRes) Reset 

func (m *RGAccessRes) Reset()

func (*RGAccessRes) String 

func (m *RGAccessRes) String() string

type RGAuthReq 

type RGAuthReq struct {
	UID int64 `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
}

func (*RGAuthReq) Descriptor 

func (*RGAuthReq) Descriptor() ([]byte, []int)

func (*RGAuthReq) GetUID 

func (m *RGAuthReq) GetUID() int64

func (*RGAuthReq) ProtoMessage 

func (*RGAuthReq) ProtoMessage()

func (*RGAuthReq) Reset 

func (m *RGAuthReq) Reset()

func (*RGAuthReq) String 

func (m *RGAuthReq) String() string

type RGAuthRes 

type RGAuthRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
	Token   string `protobuf:"bytes,3,opt,name=token" json:"token,omitempty"`
}

func (*RGAuthRes) Descriptor 

func (*RGAuthRes) Descriptor() ([]byte, []int)

func (*RGAuthRes) GetErrCode 

func (m *RGAuthRes) GetErrCode() uint32

func (*RGAuthRes) GetErrStr 

func (m *RGAuthRes) GetErrStr() string

func (*RGAuthRes) GetToken 

func (m *RGAuthRes) GetToken() string

func (*RGAuthRes) ProtoMessage 

func (*RGAuthRes) ProtoMessage()

func (*RGAuthRes) Reset 

func (m *RGAuthRes) Reset()

func (*RGAuthRes) String 

func (m *RGAuthRes) String() string

type RGCreateGroupReq 

type RGCreateGroupReq struct {
	Gid       int64  `protobuf:"varint,1,opt,name=gid" json:"gid,omitempty"`
	Uid       int64  `protobuf:"varint,2,opt,name=uid" json:"uid,omitempty"`
	GroupName string `protobuf:"bytes,3,opt,name=groupName" json:"groupName,omitempty"`
}

group

func (*RGCreateGroupReq) Descriptor 

func (*RGCreateGroupReq) Descriptor() ([]byte, []int)

func (*RGCreateGroupReq) GetGid 

func (m *RGCreateGroupReq) GetGid() int64

func (*RGCreateGroupReq) GetGroupName 

func (m *RGCreateGroupReq) GetGroupName() string

func (*RGCreateGroupReq) GetUid 

func (m *RGCreateGroupReq) GetUid() int64

func (*RGCreateGroupReq) ProtoMessage 

func (*RGCreateGroupReq) ProtoMessage()

func (*RGCreateGroupReq) Reset 

func (m *RGCreateGroupReq) Reset()

func (*RGCreateGroupReq) String 

func (m *RGCreateGroupReq) String() string

type RGCreateGroupRes 

type RGCreateGroupRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*RGCreateGroupRes) Descriptor 

func (*RGCreateGroupRes) Descriptor() ([]byte, []int)

func (*RGCreateGroupRes) GetErrCode 

func (m *RGCreateGroupRes) GetErrCode() uint32

func (*RGCreateGroupRes) GetErrStr 

func (m *RGCreateGroupRes) GetErrStr() string

func (*RGCreateGroupRes) ProtoMessage 

func (*RGCreateGroupRes) ProtoMessage()

func (*RGCreateGroupRes) Reset 

func (m *RGCreateGroupRes) Reset()

func (*RGCreateGroupRes) String 

func (m *RGCreateGroupRes) String() string

type RGGetUsersByGroupIDReq 

type RGGetUsersByGroupIDReq struct {
	Gid int64 `protobuf:"varint,1,opt,name=gid" json:"gid,omitempty"`
}

func (*RGGetUsersByGroupIDReq) Descriptor 

func (*RGGetUsersByGroupIDReq) Descriptor() ([]byte, []int)

func (*RGGetUsersByGroupIDReq) GetGid 

func (m *RGGetUsersByGroupIDReq) GetGid() int64

func (*RGGetUsersByGroupIDReq) ProtoMessage 

func (*RGGetUsersByGroupIDReq) ProtoMessage()

func (*RGGetUsersByGroupIDReq) Reset 

func (m *RGGetUsersByGroupIDReq) Reset()

func (*RGGetUsersByGroupIDReq) String 

func (m *RGGetUsersByGroupIDReq) String() string

type RGGetUsersByGroupIDRes 

type RGGetUsersByGroupIDRes struct {
	ErrCode uint32  `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string  `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
	Uids    []int64 `protobuf:"varint,3,rep,packed,name=uids" json:"uids,omitempty"`
}

func (*RGGetUsersByGroupIDRes) Descriptor 

func (*RGGetUsersByGroupIDRes) Descriptor() ([]byte, []int)

func (*RGGetUsersByGroupIDRes) GetErrCode 

func (m *RGGetUsersByGroupIDRes) GetErrCode() uint32

func (*RGGetUsersByGroupIDRes) GetErrStr 

func (m *RGGetUsersByGroupIDRes) GetErrStr() string

func (*RGGetUsersByGroupIDRes) GetUids 

func (m *RGGetUsersByGroupIDRes) GetUids() []int64

func (*RGGetUsersByGroupIDRes) ProtoMessage 

func (*RGGetUsersByGroupIDRes) ProtoMessage()

func (*RGGetUsersByGroupIDRes) Reset 

func (m *RGGetUsersByGroupIDRes) Reset()

func (*RGGetUsersByGroupIDRes) String 

func (m *RGGetUsersByGroupIDRes) String() string

type RGJoinGroupReq 

type RGJoinGroupReq struct {
	Uid int64 `protobuf:"varint,1,opt,name=uid" json:"uid,omitempty"`
	Gid int64 `protobuf:"varint,2,opt,name=gid" json:"gid,omitempty"`
}

func (*RGJoinGroupReq) Descriptor 

func (*RGJoinGroupReq) Descriptor() ([]byte, []int)

func (*RGJoinGroupReq) GetGid 

func (m *RGJoinGroupReq) GetGid() int64

func (*RGJoinGroupReq) GetUid 

func (m *RGJoinGroupReq) GetUid() int64

func (*RGJoinGroupReq) ProtoMessage 

func (*RGJoinGroupReq) ProtoMessage()

func (*RGJoinGroupReq) Reset 

func (m *RGJoinGroupReq) Reset()

func (*RGJoinGroupReq) String 

func (m *RGJoinGroupReq) String() string

type RGJoinGroupRes 

type RGJoinGroupRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*RGJoinGroupRes) Descriptor 

func (*RGJoinGroupRes) Descriptor() ([]byte, []int)

func (*RGJoinGroupRes) GetErrCode 

func (m *RGJoinGroupRes) GetErrCode() uint32

func (*RGJoinGroupRes) GetErrStr 

func (m *RGJoinGroupRes) GetErrStr() string

func (*RGJoinGroupRes) ProtoMessage 

func (*RGJoinGroupRes) ProtoMessage()

func (*RGJoinGroupRes) Reset 

func (m *RGJoinGroupRes) Reset()

func (*RGJoinGroupRes) String 

func (m *RGJoinGroupRes) String() string

type RGLoginReq 

type RGLoginReq struct {
	UID        int64  `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
	Token      string `protobuf:"bytes,2,opt,name=token" json:"token,omitempty"`
	AccessAddr string `protobuf:"bytes,3,opt,name=accessAddr" json:"accessAddr,omitempty"`
}

func (*RGLoginReq) Descriptor 

func (*RGLoginReq) Descriptor() ([]byte, []int)

func (*RGLoginReq) GetAccessAddr 

func (m *RGLoginReq) GetAccessAddr() string

func (*RGLoginReq) GetToken 

func (m *RGLoginReq) GetToken() string

func (*RGLoginReq) GetUID 

func (m *RGLoginReq) GetUID() int64

func (*RGLoginReq) ProtoMessage 

func (*RGLoginReq) ProtoMessage()

func (*RGLoginReq) Reset 

func (m *RGLoginReq) Reset()

func (*RGLoginReq) String 

func (m *RGLoginReq) String() string

type RGLoginRes 

type RGLoginRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
	Token   string `protobuf:"bytes,3,opt,name=token" json:"token,omitempty"`
}

func (*RGLoginRes) Descriptor 

func (*RGLoginRes) Descriptor() ([]byte, []int)

func (*RGLoginRes) GetErrCode 

func (m *RGLoginRes) GetErrCode() uint32

func (*RGLoginRes) GetErrStr 

func (m *RGLoginRes) GetErrStr() string

func (*RGLoginRes) GetToken 

func (m *RGLoginRes) GetToken() string

func (*RGLoginRes) ProtoMessage 

func (*RGLoginRes) ProtoMessage()

func (*RGLoginRes) Reset 

func (m *RGLoginRes) Reset()

func (*RGLoginRes) String 

func (m *RGLoginRes) String() string

type RGOnlineReq 

type RGOnlineReq struct {
	UID int64 `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
}

func (*RGOnlineReq) Descriptor 

func (*RGOnlineReq) Descriptor() ([]byte, []int)

func (*RGOnlineReq) GetUID 

func (m *RGOnlineReq) GetUID() int64

func (*RGOnlineReq) ProtoMessage 

func (*RGOnlineReq) ProtoMessage()

func (*RGOnlineReq) Reset 

func (m *RGOnlineReq) Reset()

func (*RGOnlineReq) String 

func (m *RGOnlineReq) String() string

type RGOnlineRes 

type RGOnlineRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
	Online  bool   `protobuf:"varint,3,opt,name=online" json:"online,omitempty"`
}

func (*RGOnlineRes) Descriptor 

func (*RGOnlineRes) Descriptor() ([]byte, []int)

func (*RGOnlineRes) GetErrCode 

func (m *RGOnlineRes) GetErrCode() uint32

func (*RGOnlineRes) GetErrStr 

func (m *RGOnlineRes) GetErrStr() string

func (*RGOnlineRes) GetOnline 

func (m *RGOnlineRes) GetOnline() bool

func (*RGOnlineRes) ProtoMessage 

func (*RGOnlineRes) ProtoMessage()

func (*RGOnlineRes) Reset 

func (m *RGOnlineRes) Reset()

func (*RGOnlineRes) String 

func (m *RGOnlineRes) String() string

type RGPingReq 

type RGPingReq struct {
	UID int64 `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
}

func (*RGPingReq) Descriptor 

func (*RGPingReq) Descriptor() ([]byte, []int)

func (*RGPingReq) GetUID 

func (m *RGPingReq) GetUID() int64

func (*RGPingReq) ProtoMessage 

func (*RGPingReq) ProtoMessage()

func (*RGPingReq) Reset 

func (m *RGPingReq) Reset()

func (*RGPingReq) String 

func (m *RGPingReq) String() string

type RGPingRes 

type RGPingRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*RGPingRes) Descriptor 

func (*RGPingRes) Descriptor() ([]byte, []int)

func (*RGPingRes) GetErrCode 

func (m *RGPingRes) GetErrCode() uint32

func (*RGPingRes) GetErrStr 

func (m *RGPingRes) GetErrStr() string

func (*RGPingRes) ProtoMessage 

func (*RGPingRes) ProtoMessage()

func (*RGPingRes) Reset 

func (m *RGPingRes) Reset()

func (*RGPingRes) String 

func (m *RGPingRes) String() string

type RGQuitGroupReq 

type RGQuitGroupReq struct {
	Uid int64 `protobuf:"varint,1,opt,name=uid" json:"uid,omitempty"`
	Gid int64 `protobuf:"varint,2,opt,name=gid" json:"gid,omitempty"`
}

func (*RGQuitGroupReq) Descriptor 

func (*RGQuitGroupReq) Descriptor() ([]byte, []int)

func (*RGQuitGroupReq) GetGid 

func (m *RGQuitGroupReq) GetGid() int64

func (*RGQuitGroupReq) GetUid 

func (m *RGQuitGroupReq) GetUid() int64

func (*RGQuitGroupReq) ProtoMessage 

func (*RGQuitGroupReq) ProtoMessage()

func (*RGQuitGroupReq) Reset 

func (m *RGQuitGroupReq) Reset()

func (*RGQuitGroupReq) String 

func (m *RGQuitGroupReq) String() string

type RGQuitGroupRes 

type RGQuitGroupRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*RGQuitGroupRes) Descriptor 

func (*RGQuitGroupRes) Descriptor() ([]byte, []int)

func (*RGQuitGroupRes) GetErrCode 

func (m *RGQuitGroupRes) GetErrCode() uint32

func (*RGQuitGroupRes) GetErrStr 

func (m *RGQuitGroupRes) GetErrStr() string

func (*RGQuitGroupRes) ProtoMessage 

func (*RGQuitGroupRes) ProtoMessage()

func (*RGQuitGroupRes) Reset 

func (m *RGQuitGroupRes) Reset()

func (*RGQuitGroupRes) String 

func (m *RGQuitGroupRes) String() string

type RGRegisterReq 

type RGRegisterReq struct {
	UID      int64  `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Password string `protobuf:"bytes,3,opt,name=password" json:"password,omitempty"`
}

func (*RGRegisterReq) Descriptor 

func (*RGRegisterReq) Descriptor() ([]byte, []int)

func (*RGRegisterReq) GetName 

func (m *RGRegisterReq) GetName() string

func (*RGRegisterReq) GetPassword 

func (m *RGRegisterReq) GetPassword() string

func (*RGRegisterReq) GetUID 

func (m *RGRegisterReq) GetUID() int64

func (*RGRegisterReq) ProtoMessage 

func (*RGRegisterReq) ProtoMessage()

func (*RGRegisterReq) Reset 

func (m *RGRegisterReq) Reset()

func (*RGRegisterReq) String 

func (m *RGRegisterReq) String() string

type RGRegisterRes 

type RGRegisterRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*RGRegisterRes) Descriptor 

func (*RGRegisterRes) Descriptor() ([]byte, []int)

func (*RGRegisterRes) GetErrCode 

func (m *RGRegisterRes) GetErrCode() uint32

func (*RGRegisterRes) GetErrStr 

func (m *RGRegisterRes) GetErrStr() string

func (*RGRegisterRes) ProtoMessage 

func (*RGRegisterRes) ProtoMessage()

func (*RGRegisterRes) Reset 

func (m *RGRegisterRes) Reset()

func (*RGRegisterRes) String 

func (m *RGRegisterRes) String() string

type RegisterServerRPCClient 

type RegisterServerRPCClient interface {
	Register(ctx context.Context, in *RGRegisterReq, opts ...grpc.CallOption) (*RGRegisterRes, error)
	Login(ctx context.Context, in *RGLoginReq, opts ...grpc.CallOption) (*RGLoginRes, error)
	RouterAccess(ctx context.Context, in *RGAccessReq, opts ...grpc.CallOption) (*RGAccessRes, error)
	Auth(ctx context.Context, in *RGAuthReq, opts ...grpc.CallOption) (*RGAuthRes, error)
	Ping(ctx context.Context, in *RGPingReq, opts ...grpc.CallOption) (*RGPingRes, error)
	Online(ctx context.Context, in *RGOnlineReq, opts ...grpc.CallOption) (*RGOnlineRes, error)
	GetUsersByGroupID(ctx context.Context, in *RGGetUsersByGroupIDReq, opts ...grpc.CallOption) (*RGGetUsersByGroupIDRes, error)
	// group
	CreateGroup(ctx context.Context, in *RGCreateGroupReq, opts ...grpc.CallOption) (*RGCreateGroupRes, error)
	JoinGroup(ctx context.Context, in *RGJoinGroupReq, opts ...grpc.CallOption) (*RGJoinGroupRes, error)
	QuitGroup(ctx context.Context, in *RGQuitGroupReq, opts ...grpc.CallOption) (*RGQuitGroupRes, error)
}

func NewRegisterServerRPCClient 

func NewRegisterServerRPCClient(cc *grpc.ClientConn) RegisterServerRPCClient

type RegisterServerRPCServer 

type RegisterServerRPCServer interface {
	Register(context.Context, *RGRegisterReq) (*RGRegisterRes, error)
	Login(context.Context, *RGLoginReq) (*RGLoginRes, error)
	RouterAccess(context.Context, *RGAccessReq) (*RGAccessRes, error)
	Auth(context.Context, *RGAuthReq) (*RGAuthRes, error)
	Ping(context.Context, *RGPingReq) (*RGPingRes, error)
	Online(context.Context, *RGOnlineReq) (*RGOnlineRes, error)
	GetUsersByGroupID(context.Context, *RGGetUsersByGroupIDReq) (*RGGetUsersByGroupIDRes, error)
	// group
	CreateGroup(context.Context, *RGCreateGroupReq) (*RGCreateGroupRes, error)
	JoinGroup(context.Context, *RGJoinGroupReq) (*RGJoinGroupRes, error)
	QuitGroup(context.Context, *RGQuitGroupReq) (*RGQuitGroupRes, error)
}

type SendGroupMsgReq 

type SendGroupMsgReq struct {
	SourceUID int64  `protobuf:"varint,1,opt,name=sourceUID" json:"sourceUID,omitempty"`
	GroupID   int64  `protobuf:"varint,2,opt,name=groupID" json:"groupID,omitempty"`
	MsgType   string `protobuf:"bytes,3,opt,name=msgType" json:"msgType,omitempty"`
	MsgID     string `protobuf:"bytes,4,opt,name=msgID" json:"msgID,omitempty"`
	Msg       string `protobuf:"bytes,5,opt,name=msg" json:"msg,omitempty"`
}

group msg

func (*SendGroupMsgReq) Descriptor 

func (*SendGroupMsgReq) Descriptor() ([]byte, []int)

func (*SendGroupMsgReq) GetGroupID 

func (m *SendGroupMsgReq) GetGroupID() int64

func (*SendGroupMsgReq) GetMsg 

func (m *SendGroupMsgReq) GetMsg() string

func (*SendGroupMsgReq) GetMsgID 

func (m *SendGroupMsgReq) GetMsgID() string

func (*SendGroupMsgReq) GetMsgType 

func (m *SendGroupMsgReq) GetMsgType() string

func (*SendGroupMsgReq) GetSourceUID 

func (m *SendGroupMsgReq) GetSourceUID() int64

func (*SendGroupMsgReq) ProtoMessage 

func (*SendGroupMsgReq) ProtoMessage()

func (*SendGroupMsgReq) Reset 

func (m *SendGroupMsgReq) Reset()

func (*SendGroupMsgReq) String 

func (m *SendGroupMsgReq) String() string

type SendGroupMsgRes 

type SendGroupMsgRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*SendGroupMsgRes) Descriptor 

func (*SendGroupMsgRes) Descriptor() ([]byte, []int)

func (*SendGroupMsgRes) GetErrCode 

func (m *SendGroupMsgRes) GetErrCode() uint32

func (*SendGroupMsgRes) GetErrStr 

func (m *SendGroupMsgRes) GetErrStr() string

func (*SendGroupMsgRes) ProtoMessage 

func (*SendGroupMsgRes) ProtoMessage()

func (*SendGroupMsgRes) Reset 

func (m *SendGroupMsgRes) Reset()

func (*SendGroupMsgRes) String 

func (m *SendGroupMsgRes) String() string

type SendP2PMsgReq 

type SendP2PMsgReq struct {
	SourceUID int64  `protobuf:"varint,1,opt,name=sourceUID" json:"sourceUID,omitempty"`
	TargetUID int64  `protobuf:"varint,2,opt,name=targetUID" json:"targetUID,omitempty"`
	MsgID     string `protobuf:"bytes,3,opt,name=msgID" json:"msgID,omitempty"`
	MsgType   string `protobuf:"bytes,4,opt,name=msgType" json:"msgType,omitempty"`
	Msg       string `protobuf:"bytes,5,opt,name=msg" json:"msg,omitempty"`
}

func (*SendP2PMsgReq) Descriptor 

func (*SendP2PMsgReq) Descriptor() ([]byte, []int)

func (*SendP2PMsgReq) GetMsg 

func (m *SendP2PMsgReq) GetMsg() string

func (*SendP2PMsgReq) GetMsgID 

func (m *SendP2PMsgReq) GetMsgID() string

func (*SendP2PMsgReq) GetMsgType 

func (m *SendP2PMsgReq) GetMsgType() string

func (*SendP2PMsgReq) GetSourceUID 

func (m *SendP2PMsgReq) GetSourceUID() int64

func (*SendP2PMsgReq) GetTargetUID 

func (m *SendP2PMsgReq) GetTargetUID() int64

func (*SendP2PMsgReq) ProtoMessage 

func (*SendP2PMsgReq) ProtoMessage()

func (*SendP2PMsgReq) Reset 

func (m *SendP2PMsgReq) Reset()

func (*SendP2PMsgReq) String 

func (m *SendP2PMsgReq) String() string

type SendP2PMsgRes 

type SendP2PMsgRes struct {
	ErrCode uint32 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr  string `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
}

func (*SendP2PMsgRes) Descriptor 

func (*SendP2PMsgRes) Descriptor() ([]byte, []int)

func (*SendP2PMsgRes) GetErrCode 

func (m *SendP2PMsgRes) GetErrCode() uint32

func (*SendP2PMsgRes) GetErrStr 

func (m *SendP2PMsgRes) GetErrStr() string

func (*SendP2PMsgRes) ProtoMessage 

func (*SendP2PMsgRes) ProtoMessage()

func (*SendP2PMsgRes) Reset 

func (m *SendP2PMsgRes) Reset()

func (*SendP2PMsgRes) String 

func (m *SendP2PMsgRes) String() string

type Snowflake 

type Snowflake struct {
}

func (*Snowflake) Descriptor 

func (*Snowflake) Descriptor() ([]byte, []int)

func (*Snowflake) ProtoMessage 

func (*Snowflake) ProtoMessage()

func (*Snowflake) Reset 

func (m *Snowflake) Reset()

func (*Snowflake) String 

func (m *Snowflake) String() string

type Snowflake_Key 

type Snowflake_Key struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*Snowflake_Key) Descriptor 

func (*Snowflake_Key) Descriptor() ([]byte, []int)

func (*Snowflake_Key) GetName 

func (m *Snowflake_Key) GetName() string

func (*Snowflake_Key) ProtoMessage 

func (*Snowflake_Key) ProtoMessage()

func (*Snowflake_Key) Reset 

func (m *Snowflake_Key) Reset()

func (*Snowflake_Key) String 

func (m *Snowflake_Key) String() string

type Snowflake_NullRequest 

type Snowflake_NullRequest struct {
}

func (*Snowflake_NullRequest) Descriptor 

func (*Snowflake_NullRequest) Descriptor() ([]byte, []int)

func (*Snowflake_NullRequest) ProtoMessage 

func (*Snowflake_NullRequest) ProtoMessage()

func (*Snowflake_NullRequest) Reset 

func (m *Snowflake_NullRequest) Reset()

func (*Snowflake_NullRequest) String 

func (m *Snowflake_NullRequest) String() string

type Snowflake_UUID 

type Snowflake_UUID struct {
	Uuid uint64 `protobuf:"varint,1,opt,name=uuid" json:"uuid,omitempty"`
}

func (*Snowflake_UUID) Descriptor 

func (*Snowflake_UUID) Descriptor() ([]byte, []int)

func (*Snowflake_UUID) GetUuid 

func (m *Snowflake_UUID) GetUuid() uint64

func (*Snowflake_UUID) ProtoMessage 

func (*Snowflake_UUID) ProtoMessage()

func (*Snowflake_UUID) Reset 

func (m *Snowflake_UUID) Reset()

func (*Snowflake_UUID) String 

func (m *Snowflake_UUID) String() string

type Snowflake_Value 

type Snowflake_Value struct {
	Value int64 `protobuf:"varint,1,opt,name=value" json:"value,omitempty"`
}

func (*Snowflake_Value) Descriptor 

func (*Snowflake_Value) Descriptor() ([]byte, []int)

func (*Snowflake_Value) GetValue 

func (m *Snowflake_Value) GetValue() int64

func (*Snowflake_Value) ProtoMessage 

func (*Snowflake_Value) ProtoMessage()

func (*Snowflake_Value) Reset 

func (m *Snowflake_Value) Reset()

func (*Snowflake_Value) String 

func (m *Snowflake_Value) String() string

type SyncMsgReq 

type SyncMsgReq struct {
	UID       int64 `protobuf:"varint,1,opt,name=UID" json:"UID,omitempty"`
	CurrentID int64 `protobuf:"varint,2,opt,name=currentID" json:"currentID,omitempty"`
	TotalID   int64 `protobuf:"varint,3,opt,name=totalID" json:"totalID,omitempty"`
}

sync msg

func (*SyncMsgReq) Descriptor 

func (*SyncMsgReq) Descriptor() ([]byte, []int)

func (*SyncMsgReq) GetCurrentID 

func (m *SyncMsgReq) GetCurrentID() int64

func (*SyncMsgReq) GetTotalID 

func (m *SyncMsgReq) GetTotalID() int64

func (*SyncMsgReq) GetUID 

func (m *SyncMsgReq) GetUID() int64

func (*SyncMsgReq) ProtoMessage 

func (*SyncMsgReq) ProtoMessage()

func (*SyncMsgReq) Reset 

func (m *SyncMsgReq) Reset()

func (*SyncMsgReq) String 

func (m *SyncMsgReq) String() string

type SyncMsgRes 

type SyncMsgRes struct {
	ErrCode   uint32                 `protobuf:"varint,1,opt,name=errCode" json:"errCode,omitempty"`
	ErrStr    string                 `protobuf:"bytes,2,opt,name=errStr" json:"errStr,omitempty"`
	CurrentID int64                  `protobuf:"varint,3,opt,name=currentID" json:"currentID,omitempty"`
	Msgs      []*SyncMsgResOffsetMsg `protobuf:"bytes,4,rep,name=Msgs" json:"Msgs,omitempty"`
}

func (*SyncMsgRes) Descriptor 

func (*SyncMsgRes) Descriptor() ([]byte, []int)

func (*SyncMsgRes) GetCurrentID 

func (m *SyncMsgRes) GetCurrentID() int64

func (*SyncMsgRes) GetErrCode 

func (m *SyncMsgRes) GetErrCode() uint32

func (*SyncMsgRes) GetErrStr 

func (m *SyncMsgRes) GetErrStr() string

func (*SyncMsgRes) GetMsgs 

func (m *SyncMsgRes) GetMsgs() []*SyncMsgResOffsetMsg

func (*SyncMsgRes) ProtoMessage 

func (*SyncMsgRes) ProtoMessage()

func (*SyncMsgRes) Reset 

func (m *SyncMsgRes) Reset()

func (*SyncMsgRes) String 

func (m *SyncMsgRes) String() string

type SyncMsgResOffsetMsg 

type SyncMsgResOffsetMsg struct {
	SourceUID int64  `protobuf:"varint,1,opt,name=sourceUID" json:"sourceUID,omitempty"`
	TargetUID int64  `protobuf:"varint,2,opt,name=targetUID" json:"targetUID,omitempty"`
	GroupID   int64  `protobuf:"varint,3,opt,name=groupID" json:"groupID,omitempty"`
	MsgType   string `protobuf:"bytes,4,opt,name=msgType" json:"msgType,omitempty"`
	MsgID     string `protobuf:"bytes,5,opt,name=msgID" json:"msgID,omitempty"`
	Msg       string `protobuf:"bytes,6,opt,name=msg" json:"msg,omitempty"`
}

func (*SyncMsgResOffsetMsg) Descriptor 

func (*SyncMsgResOffsetMsg) Descriptor() ([]byte, []int)

func (*SyncMsgResOffsetMsg) GetGroupID 

func (m *SyncMsgResOffsetMsg) GetGroupID() int64

func (*SyncMsgResOffsetMsg) GetMsg 

func (m *SyncMsgResOffsetMsg) GetMsg() string

func (*SyncMsgResOffsetMsg) GetMsgID 

func (m *SyncMsgResOffsetMsg) GetMsgID() string

func (*SyncMsgResOffsetMsg) GetMsgType 

func (m *SyncMsgResOffsetMsg) GetMsgType() string

func (*SyncMsgResOffsetMsg) GetSourceUID 

func (m *SyncMsgResOffsetMsg) GetSourceUID() int64

func (*SyncMsgResOffsetMsg) GetTargetUID 

func (m *SyncMsgResOffsetMsg) GetTargetUID() int64

func (*SyncMsgResOffsetMsg) ProtoMessage 

func (*SyncMsgResOffsetMsg) ProtoMessage()

func (*SyncMsgResOffsetMsg) Reset 

func (m *SyncMsgResOffsetMsg) Reset()

func (*SyncMsgResOffsetMsg) String 

func (m *SyncMsgResOffsetMsg) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.