Documentation ¶
Index ¶
- Variables
- func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)
- func RegisterLogicDealerServer(s *grpc.Server, srv LogicDealerServer)
- type AccountInfo
- func (*AccountInfo) Descriptor() ([]byte, []int)
- func (m *AccountInfo) GetAccountId() uint64
- func (m *AccountInfo) GetNickName() string
- func (m *AccountInfo) Marshal() (dAtA []byte, err error)
- func (m *AccountInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *AccountInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AccountInfo) ProtoMessage()
- func (m *AccountInfo) Reset()
- func (m *AccountInfo) Size() (n int)
- func (m *AccountInfo) String() string
- func (m *AccountInfo) Unmarshal(dAtA []byte) error
- func (m *AccountInfo) XXX_DiscardUnknown()
- func (m *AccountInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AccountInfo) XXX_Merge(src proto.Message)
- func (m *AccountInfo) XXX_Size() int
- func (m *AccountInfo) XXX_Unmarshal(b []byte) error
- type BrokerClient
- type BrokerServer
- type CodeEnum
- type CreateAccountRequest
- func (*CreateAccountRequest) Descriptor() ([]byte, []int)
- func (m *CreateAccountRequest) GetBroker() string
- func (m *CreateAccountRequest) GetNickname() string
- func (m *CreateAccountRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateAccountRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateAccountRequest) ProtoMessage()
- func (m *CreateAccountRequest) Reset()
- func (m *CreateAccountRequest) Size() (n int)
- func (m *CreateAccountRequest) String() string
- func (m *CreateAccountRequest) Unmarshal(dAtA []byte) error
- func (m *CreateAccountRequest) XXX_DiscardUnknown()
- func (m *CreateAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateAccountRequest) XXX_Merge(src proto.Message)
- func (m *CreateAccountRequest) XXX_Size() int
- func (m *CreateAccountRequest) XXX_Unmarshal(b []byte) error
- type CreateAccountResponse
- func (*CreateAccountResponse) Descriptor() ([]byte, []int)
- func (m *CreateAccountResponse) GetAccountId() uint64
- func (m *CreateAccountResponse) GetCode() CodeEnum
- func (m *CreateAccountResponse) GetMsg() string
- func (m *CreateAccountResponse) GetToken() string
- func (m *CreateAccountResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateAccountResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateAccountResponse) ProtoMessage()
- func (m *CreateAccountResponse) Reset()
- func (m *CreateAccountResponse) Size() (n int)
- func (m *CreateAccountResponse) String() string
- func (m *CreateAccountResponse) Unmarshal(dAtA []byte) error
- func (m *CreateAccountResponse) XXX_DiscardUnknown()
- func (m *CreateAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateAccountResponse) XXX_Merge(src proto.Message)
- func (m *CreateAccountResponse) XXX_Size() int
- func (m *CreateAccountResponse) XXX_Unmarshal(b []byte) error
- type LogicDealerClient
- type LogicDealerServer
- type LogoutRequest
- func (*LogoutRequest) Descriptor() ([]byte, []int)
- func (m *LogoutRequest) GetAccountId() uint64
- func (m *LogoutRequest) Marshal() (dAtA []byte, err error)
- func (m *LogoutRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LogoutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogoutRequest) ProtoMessage()
- func (m *LogoutRequest) Reset()
- func (m *LogoutRequest) Size() (n int)
- func (m *LogoutRequest) String() string
- func (m *LogoutRequest) Unmarshal(dAtA []byte) error
- func (m *LogoutRequest) XXX_DiscardUnknown()
- func (m *LogoutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogoutRequest) XXX_Merge(src proto.Message)
- func (m *LogoutRequest) XXX_Size() int
- func (m *LogoutRequest) XXX_Unmarshal(b []byte) error
- type LogoutResponse
- func (*LogoutResponse) Descriptor() ([]byte, []int)
- func (m *LogoutResponse) GetCode() CodeEnum
- func (m *LogoutResponse) GetMsg() string
- func (m *LogoutResponse) Marshal() (dAtA []byte, err error)
- func (m *LogoutResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *LogoutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LogoutResponse) ProtoMessage()
- func (m *LogoutResponse) Reset()
- func (m *LogoutResponse) Size() (n int)
- func (m *LogoutResponse) String() string
- func (m *LogoutResponse) Unmarshal(dAtA []byte) error
- func (m *LogoutResponse) XXX_DiscardUnknown()
- func (m *LogoutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogoutResponse) XXX_Merge(src proto.Message)
- func (m *LogoutResponse) XXX_Size() int
- func (m *LogoutResponse) XXX_Unmarshal(b []byte) error
- type MatchRequest
- func (*MatchRequest) Descriptor() ([]byte, []int)
- func (m *MatchRequest) GetAccountId() uint64
- func (m *MatchRequest) Marshal() (dAtA []byte, err error)
- func (m *MatchRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MatchRequest) ProtoMessage()
- func (m *MatchRequest) Reset()
- func (m *MatchRequest) Size() (n int)
- func (m *MatchRequest) String() string
- func (m *MatchRequest) Unmarshal(dAtA []byte) error
- func (m *MatchRequest) XXX_DiscardUnknown()
- func (m *MatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MatchRequest) XXX_Merge(src proto.Message)
- func (m *MatchRequest) XXX_Size() int
- func (m *MatchRequest) XXX_Unmarshal(b []byte) error
- type MatchResponse
- func (*MatchResponse) Descriptor() ([]byte, []int)
- func (m *MatchResponse) GetCode() CodeEnum
- func (m *MatchResponse) GetMsg() string
- func (m *MatchResponse) GetPartnerId() uint64
- func (m *MatchResponse) GetPartnerName() string
- func (m *MatchResponse) GetSessionId() uint64
- func (m *MatchResponse) Marshal() (dAtA []byte, err error)
- func (m *MatchResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MatchResponse) ProtoMessage()
- func (m *MatchResponse) Reset()
- func (m *MatchResponse) Size() (n int)
- func (m *MatchResponse) String() string
- func (m *MatchResponse) Unmarshal(dAtA []byte) error
- func (m *MatchResponse) XXX_DiscardUnknown()
- func (m *MatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MatchResponse) XXX_Merge(src proto.Message)
- func (m *MatchResponse) XXX_Size() int
- func (m *MatchResponse) XXX_Unmarshal(b []byte) error
- type MsgTypeEnum
- type OnlineRequest
- func (*OnlineRequest) Descriptor() ([]byte, []int)
- func (m *OnlineRequest) GetBroker() string
- func (m *OnlineRequest) Marshal() (dAtA []byte, err error)
- func (m *OnlineRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *OnlineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OnlineRequest) ProtoMessage()
- func (m *OnlineRequest) Reset()
- func (m *OnlineRequest) Size() (n int)
- func (m *OnlineRequest) String() string
- func (m *OnlineRequest) Unmarshal(dAtA []byte) error
- func (m *OnlineRequest) XXX_DiscardUnknown()
- func (m *OnlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OnlineRequest) XXX_Merge(src proto.Message)
- func (m *OnlineRequest) XXX_Size() int
- func (m *OnlineRequest) XXX_Unmarshal(b []byte) error
- type OnlineResponse
- func (*OnlineResponse) Descriptor() ([]byte, []int)
- func (m *OnlineResponse) GetCode() CodeEnum
- func (m *OnlineResponse) Marshal() (dAtA []byte, err error)
- func (m *OnlineResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *OnlineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*OnlineResponse) ProtoMessage()
- func (m *OnlineResponse) Reset()
- func (m *OnlineResponse) Size() (n int)
- func (m *OnlineResponse) String() string
- func (m *OnlineResponse) Unmarshal(dAtA []byte) error
- func (m *OnlineResponse) XXX_DiscardUnknown()
- func (m *OnlineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OnlineResponse) XXX_Merge(src proto.Message)
- func (m *OnlineResponse) XXX_Size() int
- func (m *OnlineResponse) XXX_Unmarshal(b []byte) error
- type PushDialogue
- func (*PushDialogue) Descriptor() ([]byte, []int)
- func (m *PushDialogue) GetContent() string
- func (m *PushDialogue) GetMsgId() uint64
- func (m *PushDialogue) GetReceiverId() uint64
- func (m *PushDialogue) GetSenderId() uint64
- func (m *PushDialogue) GetSessionId() uint64
- func (m *PushDialogue) Marshal() (dAtA []byte, err error)
- func (m *PushDialogue) MarshalTo(dAtA []byte) (int, error)
- func (m *PushDialogue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PushDialogue) ProtoMessage()
- func (m *PushDialogue) Reset()
- func (m *PushDialogue) Size() (n int)
- func (m *PushDialogue) String() string
- func (m *PushDialogue) Unmarshal(dAtA []byte) error
- func (m *PushDialogue) XXX_DiscardUnknown()
- func (m *PushDialogue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushDialogue) XXX_Merge(src proto.Message)
- func (m *PushDialogue) XXX_Size() int
- func (m *PushDialogue) XXX_Unmarshal(b []byte) error
- type PushRequest
- func (*PushRequest) Descriptor() ([]byte, []int)
- func (m *PushRequest) GetAccountId() uint64
- func (m *PushRequest) Marshal() (dAtA []byte, err error)
- func (m *PushRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PushRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PushRequest) ProtoMessage()
- func (m *PushRequest) Reset()
- func (m *PushRequest) Size() (n int)
- func (m *PushRequest) String() string
- func (m *PushRequest) Unmarshal(dAtA []byte) error
- func (m *PushRequest) XXX_DiscardUnknown()
- func (m *PushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushRequest) XXX_Merge(src proto.Message)
- func (m *PushRequest) XXX_Size() int
- func (m *PushRequest) XXX_Unmarshal(b []byte) error
- type PushResp
- func (*PushResp) Descriptor() ([]byte, []int)
- func (m *PushResp) GetCode() CodeEnum
- func (m *PushResp) GetMsg() string
- func (m *PushResp) Marshal() (dAtA []byte, err error)
- func (m *PushResp) MarshalTo(dAtA []byte) (int, error)
- func (m *PushResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PushResp) ProtoMessage()
- func (m *PushResp) Reset()
- func (m *PushResp) Size() (n int)
- func (m *PushResp) String() string
- func (m *PushResp) Unmarshal(dAtA []byte) error
- func (m *PushResp) XXX_DiscardUnknown()
- func (m *PushResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushResp) XXX_Merge(src proto.Message)
- func (m *PushResp) XXX_Size() int
- func (m *PushResp) XXX_Unmarshal(b []byte) error
- type PushSignal
- func (*PushSignal) Descriptor() ([]byte, []int)
- func (m *PushSignal) GetAccountId() uint64
- func (m *PushSignal) GetData() isPushSignal_Data
- func (m *PushSignal) GetMsgId() uint64
- func (m *PushSignal) GetPartner() *AccountInfo
- func (m *PushSignal) GetReceiverId() uint64
- func (m *PushSignal) GetSenderId() uint64
- func (m *PushSignal) GetSessionId() uint64
- func (m *PushSignal) GetSignalType() SignalTypeEnum
- func (m *PushSignal) Marshal() (dAtA []byte, err error)
- func (m *PushSignal) MarshalTo(dAtA []byte) (int, error)
- func (m *PushSignal) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PushSignal) ProtoMessage()
- func (m *PushSignal) Reset()
- func (m *PushSignal) Size() (n int)
- func (m *PushSignal) String() string
- func (m *PushSignal) Unmarshal(dAtA []byte) error
- func (m *PushSignal) XXX_DiscardUnknown()
- func (m *PushSignal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushSignal) XXX_Merge(src proto.Message)
- func (*PushSignal) XXX_OneofWrappers() []interface{}
- func (m *PushSignal) XXX_Size() int
- func (m *PushSignal) XXX_Unmarshal(b []byte) error
- type PushSignal_AccountId
- type PushSignal_MsgId
- type PushSignal_Partner
- type SendMsgRequest
- func (*SendMsgRequest) Descriptor() ([]byte, []int)
- func (m *SendMsgRequest) GetContent() string
- func (m *SendMsgRequest) GetMsgtype() MsgTypeEnum
- func (m *SendMsgRequest) GetSenderId() uint64
- func (m *SendMsgRequest) GetSessionId() uint64
- func (m *SendMsgRequest) Marshal() (dAtA []byte, err error)
- func (m *SendMsgRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SendMsgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SendMsgRequest) ProtoMessage()
- func (m *SendMsgRequest) Reset()
- func (m *SendMsgRequest) Size() (n int)
- func (m *SendMsgRequest) String() string
- func (m *SendMsgRequest) Unmarshal(dAtA []byte) error
- func (m *SendMsgRequest) XXX_DiscardUnknown()
- func (m *SendMsgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SendMsgRequest) XXX_Merge(src proto.Message)
- func (m *SendMsgRequest) XXX_Size() int
- func (m *SendMsgRequest) XXX_Unmarshal(b []byte) error
- type SendMsgResponse
- func (*SendMsgResponse) Descriptor() ([]byte, []int)
- func (m *SendMsgResponse) GetCode() CodeEnum
- func (m *SendMsgResponse) GetMsg() string
- func (m *SendMsgResponse) GetMsgId() uint64
- func (m *SendMsgResponse) Marshal() (dAtA []byte, err error)
- func (m *SendMsgResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SendMsgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SendMsgResponse) ProtoMessage()
- func (m *SendMsgResponse) Reset()
- func (m *SendMsgResponse) Size() (n int)
- func (m *SendMsgResponse) String() string
- func (m *SendMsgResponse) Unmarshal(dAtA []byte) error
- func (m *SendMsgResponse) XXX_DiscardUnknown()
- func (m *SendMsgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SendMsgResponse) XXX_Merge(src proto.Message)
- func (m *SendMsgResponse) XXX_Size() int
- func (m *SendMsgResponse) XXX_Unmarshal(b []byte) error
- type SignalTypeEnum
- type StatusEnum
- type UnimplementedBrokerServer
- type UnimplementedLogicDealerServer
- func (*UnimplementedLogicDealerServer) BrokerOnline(ctx context.Context, req *OnlineRequest) (*OnlineResponse, error)
- func (*UnimplementedLogicDealerServer) CreateAccount(ctx context.Context, req *CreateAccountRequest) (*CreateAccountResponse, error)
- func (*UnimplementedLogicDealerServer) Logout(ctx context.Context, req *LogoutRequest) (*LogoutResponse, error)
- func (*UnimplementedLogicDealerServer) Match(ctx context.Context, req *MatchRequest) (*MatchResponse, error)
- func (*UnimplementedLogicDealerServer) SendMsg(ctx context.Context, req *SendMsgRequest) (*SendMsgResponse, error)
- func (*UnimplementedLogicDealerServer) ViewedAck(ctx context.Context, req *ViewedAckRequest) (*ViewedAckResponse, error)
- type ViewedAckRequest
- func (*ViewedAckRequest) Descriptor() ([]byte, []int)
- func (m *ViewedAckRequest) GetAccountId() uint64
- func (m *ViewedAckRequest) GetMsgId() uint64
- func (m *ViewedAckRequest) GetSessionId() uint64
- func (m *ViewedAckRequest) Marshal() (dAtA []byte, err error)
- func (m *ViewedAckRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewedAckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewedAckRequest) ProtoMessage()
- func (m *ViewedAckRequest) Reset()
- func (m *ViewedAckRequest) Size() (n int)
- func (m *ViewedAckRequest) String() string
- func (m *ViewedAckRequest) Unmarshal(dAtA []byte) error
- func (m *ViewedAckRequest) XXX_DiscardUnknown()
- func (m *ViewedAckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewedAckRequest) XXX_Merge(src proto.Message)
- func (m *ViewedAckRequest) XXX_Size() int
- func (m *ViewedAckRequest) XXX_Unmarshal(b []byte) error
- type ViewedAckResponse
- func (*ViewedAckResponse) Descriptor() ([]byte, []int)
- func (m *ViewedAckResponse) GetCode() CodeEnum
- func (m *ViewedAckResponse) GetMsg() string
- func (m *ViewedAckResponse) Marshal() (dAtA []byte, err error)
- func (m *ViewedAckResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ViewedAckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ViewedAckResponse) ProtoMessage()
- func (m *ViewedAckResponse) Reset()
- func (m *ViewedAckResponse) Size() (n int)
- func (m *ViewedAckResponse) String() string
- func (m *ViewedAckResponse) Unmarshal(dAtA []byte) error
- func (m *ViewedAckResponse) XXX_DiscardUnknown()
- func (m *ViewedAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ViewedAckResponse) XXX_Merge(src proto.Message)
- func (m *ViewedAckResponse) XXX_Size() int
- func (m *ViewedAckResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthBroker = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowBroker = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupBroker = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthLogic = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowLogic = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupLogic = fmt.Errorf("proto: unexpected end of group") )
var CodeEnum_name = map[int32]string{
0: "C000",
1: "C001",
2: "C002",
3: "C003",
4: "C004",
}
var CodeEnum_value = map[string]int32{
"C000": 0,
"C001": 1,
"C002": 2,
"C003": 3,
"C004": 4,
}
var MsgTypeEnum_name = map[int32]string{
0: "Dialogue",
1: "Signal",
}
var MsgTypeEnum_value = map[string]int32{
"Dialogue": 0,
"Signal": 1,
}
var SignalTypeEnum_name = map[int32]string{
0: "PartnerExit",
1: "NewSession",
2: "DeleteMsg",
3: "ViewedAck",
}
var SignalTypeEnum_value = map[string]int32{
"PartnerExit": 0,
"NewSession": 1,
"DeleteMsg": 2,
"ViewedAck": 3,
}
var StatusEnum_name = map[int32]string{
0: "Deleted",
1: "Normal",
}
var StatusEnum_value = map[string]int32{
"Deleted": 0,
"Normal": 1,
}
Functions ¶
func RegisterBrokerServer ¶
func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)
func RegisterLogicDealerServer ¶
func RegisterLogicDealerServer(s *grpc.Server, srv LogicDealerServer)
Types ¶
type AccountInfo ¶
type AccountInfo struct { AccountId uint64 `protobuf:"varint,1,opt,name=accountId,proto3" json:"accountId,omitempty"` NickName string `protobuf:"bytes,2,opt,name=nickName,proto3" json:"nickName,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AccountInfo) Descriptor ¶
func (*AccountInfo) Descriptor() ([]byte, []int)
func (*AccountInfo) GetAccountId ¶
func (m *AccountInfo) GetAccountId() uint64
func (*AccountInfo) GetNickName ¶
func (m *AccountInfo) GetNickName() string
func (*AccountInfo) Marshal ¶
func (m *AccountInfo) Marshal() (dAtA []byte, err error)
func (*AccountInfo) MarshalToSizedBuffer ¶
func (m *AccountInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AccountInfo) ProtoMessage ¶
func (*AccountInfo) ProtoMessage()
func (*AccountInfo) Reset ¶
func (m *AccountInfo) Reset()
func (*AccountInfo) Size ¶
func (m *AccountInfo) Size() (n int)
func (*AccountInfo) String ¶
func (m *AccountInfo) String() string
func (*AccountInfo) Unmarshal ¶
func (m *AccountInfo) Unmarshal(dAtA []byte) error
func (*AccountInfo) XXX_DiscardUnknown ¶
func (m *AccountInfo) XXX_DiscardUnknown()
func (*AccountInfo) XXX_Marshal ¶
func (m *AccountInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AccountInfo) XXX_Merge ¶
func (m *AccountInfo) XXX_Merge(src proto.Message)
func (*AccountInfo) XXX_Size ¶
func (m *AccountInfo) XXX_Size() int
func (*AccountInfo) XXX_Unmarshal ¶
func (m *AccountInfo) XXX_Unmarshal(b []byte) error
type BrokerClient ¶
type BrokerClient interface { // 接收logic推送过来的数据 ReceiveMsgDialogue(ctx context.Context, in *PushDialogue, opts ...grpc.CallOption) (*PushResp, error) ReceiveMsgSignal(ctx context.Context, in *PushSignal, opts ...grpc.CallOption) (*PushResp, error) }
BrokerClient is the client API for Broker service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewBrokerClient ¶
func NewBrokerClient(cc *grpc.ClientConn) BrokerClient
type BrokerServer ¶
type BrokerServer interface { // 接收logic推送过来的数据 ReceiveMsgDialogue(context.Context, *PushDialogue) (*PushResp, error) ReceiveMsgSignal(context.Context, *PushSignal) (*PushResp, error) }
BrokerServer is the server API for Broker service.
type CreateAccountRequest ¶
type CreateAccountRequest struct { Nickname string `protobuf:"bytes,1,opt,name=nickname,proto3" json:"nickname,omitempty"` Broker string `protobuf:"bytes,2,opt,name=broker,proto3" json:"broker,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateAccountRequest) Descriptor ¶
func (*CreateAccountRequest) Descriptor() ([]byte, []int)
func (*CreateAccountRequest) GetBroker ¶
func (m *CreateAccountRequest) GetBroker() string
func (*CreateAccountRequest) GetNickname ¶
func (m *CreateAccountRequest) GetNickname() string
func (*CreateAccountRequest) Marshal ¶
func (m *CreateAccountRequest) Marshal() (dAtA []byte, err error)
func (*CreateAccountRequest) MarshalTo ¶
func (m *CreateAccountRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateAccountRequest) MarshalToSizedBuffer ¶
func (m *CreateAccountRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateAccountRequest) ProtoMessage ¶
func (*CreateAccountRequest) ProtoMessage()
func (*CreateAccountRequest) Reset ¶
func (m *CreateAccountRequest) Reset()
func (*CreateAccountRequest) Size ¶
func (m *CreateAccountRequest) Size() (n int)
func (*CreateAccountRequest) String ¶
func (m *CreateAccountRequest) String() string
func (*CreateAccountRequest) Unmarshal ¶
func (m *CreateAccountRequest) Unmarshal(dAtA []byte) error
func (*CreateAccountRequest) XXX_DiscardUnknown ¶
func (m *CreateAccountRequest) XXX_DiscardUnknown()
func (*CreateAccountRequest) XXX_Marshal ¶
func (m *CreateAccountRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateAccountRequest) XXX_Merge ¶
func (m *CreateAccountRequest) XXX_Merge(src proto.Message)
func (*CreateAccountRequest) XXX_Size ¶
func (m *CreateAccountRequest) XXX_Size() int
func (*CreateAccountRequest) XXX_Unmarshal ¶
func (m *CreateAccountRequest) XXX_Unmarshal(b []byte) error
type CreateAccountResponse ¶
type CreateAccountResponse struct { Code CodeEnum `protobuf:"varint,1,opt,name=code,proto3,enum=proto.CodeEnum" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` AccountId uint64 `protobuf:"varint,3,opt,name=accountId,proto3" json:"accountId,omitempty"` Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateAccountResponse) Descriptor ¶
func (*CreateAccountResponse) Descriptor() ([]byte, []int)
func (*CreateAccountResponse) GetAccountId ¶
func (m *CreateAccountResponse) GetAccountId() uint64
func (*CreateAccountResponse) GetCode ¶
func (m *CreateAccountResponse) GetCode() CodeEnum
func (*CreateAccountResponse) GetMsg ¶
func (m *CreateAccountResponse) GetMsg() string
func (*CreateAccountResponse) GetToken ¶
func (m *CreateAccountResponse) GetToken() string
func (*CreateAccountResponse) Marshal ¶
func (m *CreateAccountResponse) Marshal() (dAtA []byte, err error)
func (*CreateAccountResponse) MarshalTo ¶
func (m *CreateAccountResponse) MarshalTo(dAtA []byte) (int, error)
func (*CreateAccountResponse) MarshalToSizedBuffer ¶
func (m *CreateAccountResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateAccountResponse) ProtoMessage ¶
func (*CreateAccountResponse) ProtoMessage()
func (*CreateAccountResponse) Reset ¶
func (m *CreateAccountResponse) Reset()
func (*CreateAccountResponse) Size ¶
func (m *CreateAccountResponse) Size() (n int)
func (*CreateAccountResponse) String ¶
func (m *CreateAccountResponse) String() string
func (*CreateAccountResponse) Unmarshal ¶
func (m *CreateAccountResponse) Unmarshal(dAtA []byte) error
func (*CreateAccountResponse) XXX_DiscardUnknown ¶
func (m *CreateAccountResponse) XXX_DiscardUnknown()
func (*CreateAccountResponse) XXX_Marshal ¶
func (m *CreateAccountResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateAccountResponse) XXX_Merge ¶
func (m *CreateAccountResponse) XXX_Merge(src proto.Message)
func (*CreateAccountResponse) XXX_Size ¶
func (m *CreateAccountResponse) XXX_Size() int
func (*CreateAccountResponse) XXX_Unmarshal ¶
func (m *CreateAccountResponse) XXX_Unmarshal(b []byte) error
type LogicDealerClient ¶
type LogicDealerClient interface { CreateAccount(ctx context.Context, in *CreateAccountRequest, opts ...grpc.CallOption) (*CreateAccountResponse, error) Match(ctx context.Context, in *MatchRequest, opts ...grpc.CallOption) (*MatchResponse, error) SendMsg(ctx context.Context, in *SendMsgRequest, opts ...grpc.CallOption) (*SendMsgResponse, error) Logout(ctx context.Context, in *LogoutRequest, opts ...grpc.CallOption) (*LogoutResponse, error) ViewedAck(ctx context.Context, in *ViewedAckRequest, opts ...grpc.CallOption) (*ViewedAckResponse, error) BrokerOnline(ctx context.Context, in *OnlineRequest, opts ...grpc.CallOption) (*OnlineResponse, error) }
LogicDealerClient is the client API for LogicDealer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewLogicDealerClient ¶
func NewLogicDealerClient(cc *grpc.ClientConn) LogicDealerClient
type LogicDealerServer ¶
type LogicDealerServer interface { CreateAccount(context.Context, *CreateAccountRequest) (*CreateAccountResponse, error) Match(context.Context, *MatchRequest) (*MatchResponse, error) SendMsg(context.Context, *SendMsgRequest) (*SendMsgResponse, error) Logout(context.Context, *LogoutRequest) (*LogoutResponse, error) ViewedAck(context.Context, *ViewedAckRequest) (*ViewedAckResponse, error) BrokerOnline(context.Context, *OnlineRequest) (*OnlineResponse, error) }
LogicDealerServer is the server API for LogicDealer service.
type LogoutRequest ¶
type LogoutRequest struct { AccountId uint64 `protobuf:"varint,1,opt,name=accountId,proto3" json:"accountId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogoutRequest) Descriptor ¶
func (*LogoutRequest) Descriptor() ([]byte, []int)
func (*LogoutRequest) GetAccountId ¶
func (m *LogoutRequest) GetAccountId() uint64
func (*LogoutRequest) Marshal ¶
func (m *LogoutRequest) Marshal() (dAtA []byte, err error)
func (*LogoutRequest) MarshalToSizedBuffer ¶
func (m *LogoutRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogoutRequest) ProtoMessage ¶
func (*LogoutRequest) ProtoMessage()
func (*LogoutRequest) Reset ¶
func (m *LogoutRequest) Reset()
func (*LogoutRequest) Size ¶
func (m *LogoutRequest) Size() (n int)
func (*LogoutRequest) String ¶
func (m *LogoutRequest) String() string
func (*LogoutRequest) Unmarshal ¶
func (m *LogoutRequest) Unmarshal(dAtA []byte) error
func (*LogoutRequest) XXX_DiscardUnknown ¶
func (m *LogoutRequest) XXX_DiscardUnknown()
func (*LogoutRequest) XXX_Marshal ¶
func (m *LogoutRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogoutRequest) XXX_Merge ¶
func (m *LogoutRequest) XXX_Merge(src proto.Message)
func (*LogoutRequest) XXX_Size ¶
func (m *LogoutRequest) XXX_Size() int
func (*LogoutRequest) XXX_Unmarshal ¶
func (m *LogoutRequest) XXX_Unmarshal(b []byte) error
type LogoutResponse ¶
type LogoutResponse struct { Code CodeEnum `protobuf:"varint,1,opt,name=code,proto3,enum=proto.CodeEnum" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogoutResponse) Descriptor ¶
func (*LogoutResponse) Descriptor() ([]byte, []int)
func (*LogoutResponse) GetCode ¶
func (m *LogoutResponse) GetCode() CodeEnum
func (*LogoutResponse) GetMsg ¶
func (m *LogoutResponse) GetMsg() string
func (*LogoutResponse) Marshal ¶
func (m *LogoutResponse) Marshal() (dAtA []byte, err error)
func (*LogoutResponse) MarshalToSizedBuffer ¶
func (m *LogoutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*LogoutResponse) ProtoMessage ¶
func (*LogoutResponse) ProtoMessage()
func (*LogoutResponse) Reset ¶
func (m *LogoutResponse) Reset()
func (*LogoutResponse) Size ¶
func (m *LogoutResponse) Size() (n int)
func (*LogoutResponse) String ¶
func (m *LogoutResponse) String() string
func (*LogoutResponse) Unmarshal ¶
func (m *LogoutResponse) Unmarshal(dAtA []byte) error
func (*LogoutResponse) XXX_DiscardUnknown ¶
func (m *LogoutResponse) XXX_DiscardUnknown()
func (*LogoutResponse) XXX_Marshal ¶
func (m *LogoutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogoutResponse) XXX_Merge ¶
func (m *LogoutResponse) XXX_Merge(src proto.Message)
func (*LogoutResponse) XXX_Size ¶
func (m *LogoutResponse) XXX_Size() int
func (*LogoutResponse) XXX_Unmarshal ¶
func (m *LogoutResponse) XXX_Unmarshal(b []byte) error
type MatchRequest ¶
type MatchRequest struct { AccountId uint64 `protobuf:"varint,1,opt,name=accountId,proto3" json:"accountId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MatchRequest) Descriptor ¶
func (*MatchRequest) Descriptor() ([]byte, []int)
func (*MatchRequest) GetAccountId ¶
func (m *MatchRequest) GetAccountId() uint64
func (*MatchRequest) Marshal ¶
func (m *MatchRequest) Marshal() (dAtA []byte, err error)
func (*MatchRequest) MarshalToSizedBuffer ¶
func (m *MatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MatchRequest) ProtoMessage ¶
func (*MatchRequest) ProtoMessage()
func (*MatchRequest) Reset ¶
func (m *MatchRequest) Reset()
func (*MatchRequest) Size ¶
func (m *MatchRequest) Size() (n int)
func (*MatchRequest) String ¶
func (m *MatchRequest) String() string
func (*MatchRequest) Unmarshal ¶
func (m *MatchRequest) Unmarshal(dAtA []byte) error
func (*MatchRequest) XXX_DiscardUnknown ¶
func (m *MatchRequest) XXX_DiscardUnknown()
func (*MatchRequest) XXX_Marshal ¶
func (m *MatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MatchRequest) XXX_Merge ¶
func (m *MatchRequest) XXX_Merge(src proto.Message)
func (*MatchRequest) XXX_Size ¶
func (m *MatchRequest) XXX_Size() int
func (*MatchRequest) XXX_Unmarshal ¶
func (m *MatchRequest) XXX_Unmarshal(b []byte) error
type MatchResponse ¶
type MatchResponse struct { Code CodeEnum `protobuf:"varint,1,opt,name=code,proto3,enum=proto.CodeEnum" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` PartnerId uint64 `protobuf:"varint,3,opt,name=partnerId,proto3" json:"partnerId,omitempty"` PartnerName string `protobuf:"bytes,4,opt,name=partnerName,proto3" json:"partnerName,omitempty"` SessionId uint64 `protobuf:"varint,5,opt,name=sessionId,proto3" json:"sessionId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MatchResponse) Descriptor ¶
func (*MatchResponse) Descriptor() ([]byte, []int)
func (*MatchResponse) GetCode ¶
func (m *MatchResponse) GetCode() CodeEnum
func (*MatchResponse) GetMsg ¶
func (m *MatchResponse) GetMsg() string
func (*MatchResponse) GetPartnerId ¶
func (m *MatchResponse) GetPartnerId() uint64
func (*MatchResponse) GetPartnerName ¶
func (m *MatchResponse) GetPartnerName() string
func (*MatchResponse) GetSessionId ¶
func (m *MatchResponse) GetSessionId() uint64
func (*MatchResponse) Marshal ¶
func (m *MatchResponse) Marshal() (dAtA []byte, err error)
func (*MatchResponse) MarshalToSizedBuffer ¶
func (m *MatchResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MatchResponse) ProtoMessage ¶
func (*MatchResponse) ProtoMessage()
func (*MatchResponse) Reset ¶
func (m *MatchResponse) Reset()
func (*MatchResponse) Size ¶
func (m *MatchResponse) Size() (n int)
func (*MatchResponse) String ¶
func (m *MatchResponse) String() string
func (*MatchResponse) Unmarshal ¶
func (m *MatchResponse) Unmarshal(dAtA []byte) error
func (*MatchResponse) XXX_DiscardUnknown ¶
func (m *MatchResponse) XXX_DiscardUnknown()
func (*MatchResponse) XXX_Marshal ¶
func (m *MatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MatchResponse) XXX_Merge ¶
func (m *MatchResponse) XXX_Merge(src proto.Message)
func (*MatchResponse) XXX_Size ¶
func (m *MatchResponse) XXX_Size() int
func (*MatchResponse) XXX_Unmarshal ¶
func (m *MatchResponse) XXX_Unmarshal(b []byte) error
type MsgTypeEnum ¶
type MsgTypeEnum int32
const ( MsgTypeEnum_Dialogue MsgTypeEnum = 0 MsgTypeEnum_Signal MsgTypeEnum = 1 )
func (MsgTypeEnum) EnumDescriptor ¶
func (MsgTypeEnum) EnumDescriptor() ([]byte, []int)
func (MsgTypeEnum) String ¶
func (x MsgTypeEnum) String() string
type OnlineRequest ¶
type OnlineRequest struct { Broker string `protobuf:"bytes,1,opt,name=broker,proto3" json:"broker,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OnlineRequest) Descriptor ¶
func (*OnlineRequest) Descriptor() ([]byte, []int)
func (*OnlineRequest) GetBroker ¶
func (m *OnlineRequest) GetBroker() string
func (*OnlineRequest) Marshal ¶
func (m *OnlineRequest) Marshal() (dAtA []byte, err error)
func (*OnlineRequest) MarshalToSizedBuffer ¶
func (m *OnlineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OnlineRequest) ProtoMessage ¶
func (*OnlineRequest) ProtoMessage()
func (*OnlineRequest) Reset ¶
func (m *OnlineRequest) Reset()
func (*OnlineRequest) Size ¶
func (m *OnlineRequest) Size() (n int)
func (*OnlineRequest) String ¶
func (m *OnlineRequest) String() string
func (*OnlineRequest) Unmarshal ¶
func (m *OnlineRequest) Unmarshal(dAtA []byte) error
func (*OnlineRequest) XXX_DiscardUnknown ¶
func (m *OnlineRequest) XXX_DiscardUnknown()
func (*OnlineRequest) XXX_Marshal ¶
func (m *OnlineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OnlineRequest) XXX_Merge ¶
func (m *OnlineRequest) XXX_Merge(src proto.Message)
func (*OnlineRequest) XXX_Size ¶
func (m *OnlineRequest) XXX_Size() int
func (*OnlineRequest) XXX_Unmarshal ¶
func (m *OnlineRequest) XXX_Unmarshal(b []byte) error
type OnlineResponse ¶
type OnlineResponse struct { Code CodeEnum `protobuf:"varint,1,opt,name=code,proto3,enum=proto.CodeEnum" json:"code,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OnlineResponse) Descriptor ¶
func (*OnlineResponse) Descriptor() ([]byte, []int)
func (*OnlineResponse) GetCode ¶
func (m *OnlineResponse) GetCode() CodeEnum
func (*OnlineResponse) Marshal ¶
func (m *OnlineResponse) Marshal() (dAtA []byte, err error)
func (*OnlineResponse) MarshalToSizedBuffer ¶
func (m *OnlineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OnlineResponse) ProtoMessage ¶
func (*OnlineResponse) ProtoMessage()
func (*OnlineResponse) Reset ¶
func (m *OnlineResponse) Reset()
func (*OnlineResponse) Size ¶
func (m *OnlineResponse) Size() (n int)
func (*OnlineResponse) String ¶
func (m *OnlineResponse) String() string
func (*OnlineResponse) Unmarshal ¶
func (m *OnlineResponse) Unmarshal(dAtA []byte) error
func (*OnlineResponse) XXX_DiscardUnknown ¶
func (m *OnlineResponse) XXX_DiscardUnknown()
func (*OnlineResponse) XXX_Marshal ¶
func (m *OnlineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OnlineResponse) XXX_Merge ¶
func (m *OnlineResponse) XXX_Merge(src proto.Message)
func (*OnlineResponse) XXX_Size ¶
func (m *OnlineResponse) XXX_Size() int
func (*OnlineResponse) XXX_Unmarshal ¶
func (m *OnlineResponse) XXX_Unmarshal(b []byte) error
type PushDialogue ¶
type PushDialogue struct { SenderId uint64 `protobuf:"varint,1,opt,name=senderId,proto3" json:"senderId,omitempty"` SessionId uint64 `protobuf:"varint,2,opt,name=sessionId,proto3" json:"sessionId,omitempty"` ReceiverId uint64 `protobuf:"varint,3,opt,name=receiverId,proto3" json:"receiverId,omitempty"` Content string `protobuf:"bytes,4,opt,name=content,proto3" json:"content,omitempty"` MsgId uint64 `protobuf:"varint,5,opt,name=msgId,proto3" json:"msgId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushDialogue) Descriptor ¶
func (*PushDialogue) Descriptor() ([]byte, []int)
func (*PushDialogue) GetContent ¶
func (m *PushDialogue) GetContent() string
func (*PushDialogue) GetMsgId ¶
func (m *PushDialogue) GetMsgId() uint64
func (*PushDialogue) GetReceiverId ¶
func (m *PushDialogue) GetReceiverId() uint64
func (*PushDialogue) GetSenderId ¶
func (m *PushDialogue) GetSenderId() uint64
func (*PushDialogue) GetSessionId ¶
func (m *PushDialogue) GetSessionId() uint64
func (*PushDialogue) Marshal ¶
func (m *PushDialogue) Marshal() (dAtA []byte, err error)
func (*PushDialogue) MarshalToSizedBuffer ¶
func (m *PushDialogue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PushDialogue) ProtoMessage ¶
func (*PushDialogue) ProtoMessage()
func (*PushDialogue) Reset ¶
func (m *PushDialogue) Reset()
func (*PushDialogue) Size ¶
func (m *PushDialogue) Size() (n int)
func (*PushDialogue) String ¶
func (m *PushDialogue) String() string
func (*PushDialogue) Unmarshal ¶
func (m *PushDialogue) Unmarshal(dAtA []byte) error
func (*PushDialogue) XXX_DiscardUnknown ¶
func (m *PushDialogue) XXX_DiscardUnknown()
func (*PushDialogue) XXX_Marshal ¶
func (m *PushDialogue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushDialogue) XXX_Merge ¶
func (m *PushDialogue) XXX_Merge(src proto.Message)
func (*PushDialogue) XXX_Size ¶
func (m *PushDialogue) XXX_Size() int
func (*PushDialogue) XXX_Unmarshal ¶
func (m *PushDialogue) XXX_Unmarshal(b []byte) error
type PushRequest ¶
type PushRequest struct { AccountId uint64 `protobuf:"varint,1,opt,name=accountId,proto3" json:"accountId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushRequest) Descriptor ¶
func (*PushRequest) Descriptor() ([]byte, []int)
func (*PushRequest) GetAccountId ¶
func (m *PushRequest) GetAccountId() uint64
func (*PushRequest) Marshal ¶
func (m *PushRequest) Marshal() (dAtA []byte, err error)
func (*PushRequest) MarshalToSizedBuffer ¶
func (m *PushRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PushRequest) ProtoMessage ¶
func (*PushRequest) ProtoMessage()
func (*PushRequest) Reset ¶
func (m *PushRequest) Reset()
func (*PushRequest) Size ¶
func (m *PushRequest) Size() (n int)
func (*PushRequest) String ¶
func (m *PushRequest) String() string
func (*PushRequest) Unmarshal ¶
func (m *PushRequest) Unmarshal(dAtA []byte) error
func (*PushRequest) XXX_DiscardUnknown ¶
func (m *PushRequest) XXX_DiscardUnknown()
func (*PushRequest) XXX_Marshal ¶
func (m *PushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushRequest) XXX_Merge ¶
func (m *PushRequest) XXX_Merge(src proto.Message)
func (*PushRequest) XXX_Size ¶
func (m *PushRequest) XXX_Size() int
func (*PushRequest) XXX_Unmarshal ¶
func (m *PushRequest) XXX_Unmarshal(b []byte) error
type PushResp ¶
type PushResp struct { Code CodeEnum `protobuf:"varint,1,opt,name=code,proto3,enum=proto.CodeEnum" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushResp) Descriptor ¶
func (*PushResp) MarshalToSizedBuffer ¶
func (*PushResp) ProtoMessage ¶
func (*PushResp) ProtoMessage()
func (*PushResp) XXX_DiscardUnknown ¶
func (m *PushResp) XXX_DiscardUnknown()
func (*PushResp) XXX_Marshal ¶
func (*PushResp) XXX_Unmarshal ¶
type PushSignal ¶
type PushSignal struct { SignalType SignalTypeEnum `protobuf:"varint,1,opt,name=signalType,proto3,enum=proto.SignalTypeEnum" json:"signalType,omitempty"` SenderId uint64 `protobuf:"varint,2,opt,name=senderId,proto3" json:"senderId,omitempty"` ReceiverId uint64 `protobuf:"varint,3,opt,name=receiverId,proto3" json:"receiverId,omitempty"` SessionId uint64 `protobuf:"varint,4,opt,name=sessionId,proto3" json:"sessionId,omitempty"` // Types that are valid to be assigned to Data: // *PushSignal_Partner // *PushSignal_MsgId // *PushSignal_AccountId Data isPushSignal_Data `protobuf_oneof:"data"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PushSignal) Descriptor ¶
func (*PushSignal) Descriptor() ([]byte, []int)
func (*PushSignal) GetAccountId ¶
func (m *PushSignal) GetAccountId() uint64
func (*PushSignal) GetData ¶
func (m *PushSignal) GetData() isPushSignal_Data
func (*PushSignal) GetMsgId ¶
func (m *PushSignal) GetMsgId() uint64
func (*PushSignal) GetPartner ¶
func (m *PushSignal) GetPartner() *AccountInfo
func (*PushSignal) GetReceiverId ¶
func (m *PushSignal) GetReceiverId() uint64
func (*PushSignal) GetSenderId ¶
func (m *PushSignal) GetSenderId() uint64
func (*PushSignal) GetSessionId ¶
func (m *PushSignal) GetSessionId() uint64
func (*PushSignal) GetSignalType ¶
func (m *PushSignal) GetSignalType() SignalTypeEnum
func (*PushSignal) Marshal ¶
func (m *PushSignal) Marshal() (dAtA []byte, err error)
func (*PushSignal) MarshalToSizedBuffer ¶
func (m *PushSignal) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PushSignal) ProtoMessage ¶
func (*PushSignal) ProtoMessage()
func (*PushSignal) Reset ¶
func (m *PushSignal) Reset()
func (*PushSignal) Size ¶
func (m *PushSignal) Size() (n int)
func (*PushSignal) String ¶
func (m *PushSignal) String() string
func (*PushSignal) Unmarshal ¶
func (m *PushSignal) Unmarshal(dAtA []byte) error
func (*PushSignal) XXX_DiscardUnknown ¶
func (m *PushSignal) XXX_DiscardUnknown()
func (*PushSignal) XXX_Marshal ¶
func (m *PushSignal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushSignal) XXX_Merge ¶
func (m *PushSignal) XXX_Merge(src proto.Message)
func (*PushSignal) XXX_OneofWrappers ¶
func (*PushSignal) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*PushSignal) XXX_Size ¶
func (m *PushSignal) XXX_Size() int
func (*PushSignal) XXX_Unmarshal ¶
func (m *PushSignal) XXX_Unmarshal(b []byte) error
type PushSignal_AccountId ¶
type PushSignal_AccountId struct {
AccountId uint64 `protobuf:"varint,7,opt,name=accountId,proto3,oneof" json:"accountId,omitempty"`
}
func (*PushSignal_AccountId) MarshalTo ¶
func (m *PushSignal_AccountId) MarshalTo(dAtA []byte) (int, error)
func (*PushSignal_AccountId) MarshalToSizedBuffer ¶
func (m *PushSignal_AccountId) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PushSignal_AccountId) Size ¶
func (m *PushSignal_AccountId) Size() (n int)
type PushSignal_MsgId ¶
type PushSignal_MsgId struct {
MsgId uint64 `protobuf:"varint,6,opt,name=msgId,proto3,oneof" json:"msgId,omitempty"`
}
func (*PushSignal_MsgId) MarshalToSizedBuffer ¶
func (m *PushSignal_MsgId) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PushSignal_MsgId) Size ¶
func (m *PushSignal_MsgId) Size() (n int)
type PushSignal_Partner ¶
type PushSignal_Partner struct {
Partner *AccountInfo `protobuf:"bytes,5,opt,name=partner,proto3,oneof" json:"partner,omitempty"`
}
func (*PushSignal_Partner) MarshalTo ¶
func (m *PushSignal_Partner) MarshalTo(dAtA []byte) (int, error)
func (*PushSignal_Partner) MarshalToSizedBuffer ¶
func (m *PushSignal_Partner) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PushSignal_Partner) Size ¶
func (m *PushSignal_Partner) Size() (n int)
type SendMsgRequest ¶
type SendMsgRequest struct { SenderId uint64 `protobuf:"varint,2,opt,name=senderId,proto3" json:"senderId,omitempty"` SessionId uint64 `protobuf:"varint,3,opt,name=sessionId,proto3" json:"sessionId,omitempty"` Msgtype MsgTypeEnum `protobuf:"varint,4,opt,name=msgtype,proto3,enum=proto.MsgTypeEnum" json:"msgtype,omitempty"` Content string `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendMsgRequest) Descriptor ¶
func (*SendMsgRequest) Descriptor() ([]byte, []int)
func (*SendMsgRequest) GetContent ¶
func (m *SendMsgRequest) GetContent() string
func (*SendMsgRequest) GetMsgtype ¶
func (m *SendMsgRequest) GetMsgtype() MsgTypeEnum
func (*SendMsgRequest) GetSenderId ¶
func (m *SendMsgRequest) GetSenderId() uint64
func (*SendMsgRequest) GetSessionId ¶
func (m *SendMsgRequest) GetSessionId() uint64
func (*SendMsgRequest) Marshal ¶
func (m *SendMsgRequest) Marshal() (dAtA []byte, err error)
func (*SendMsgRequest) MarshalToSizedBuffer ¶
func (m *SendMsgRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SendMsgRequest) ProtoMessage ¶
func (*SendMsgRequest) ProtoMessage()
func (*SendMsgRequest) Reset ¶
func (m *SendMsgRequest) Reset()
func (*SendMsgRequest) Size ¶
func (m *SendMsgRequest) Size() (n int)
func (*SendMsgRequest) String ¶
func (m *SendMsgRequest) String() string
func (*SendMsgRequest) Unmarshal ¶
func (m *SendMsgRequest) Unmarshal(dAtA []byte) error
func (*SendMsgRequest) XXX_DiscardUnknown ¶
func (m *SendMsgRequest) XXX_DiscardUnknown()
func (*SendMsgRequest) XXX_Marshal ¶
func (m *SendMsgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendMsgRequest) XXX_Merge ¶
func (m *SendMsgRequest) XXX_Merge(src proto.Message)
func (*SendMsgRequest) XXX_Size ¶
func (m *SendMsgRequest) XXX_Size() int
func (*SendMsgRequest) XXX_Unmarshal ¶
func (m *SendMsgRequest) XXX_Unmarshal(b []byte) error
type SendMsgResponse ¶
type SendMsgResponse struct { Code CodeEnum `protobuf:"varint,1,opt,name=code,proto3,enum=proto.CodeEnum" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` MsgId uint64 `protobuf:"varint,3,opt,name=msgId,proto3" json:"msgId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendMsgResponse) Descriptor ¶
func (*SendMsgResponse) Descriptor() ([]byte, []int)
func (*SendMsgResponse) GetCode ¶
func (m *SendMsgResponse) GetCode() CodeEnum
func (*SendMsgResponse) GetMsg ¶
func (m *SendMsgResponse) GetMsg() string
func (*SendMsgResponse) GetMsgId ¶
func (m *SendMsgResponse) GetMsgId() uint64
func (*SendMsgResponse) Marshal ¶
func (m *SendMsgResponse) Marshal() (dAtA []byte, err error)
func (*SendMsgResponse) MarshalToSizedBuffer ¶
func (m *SendMsgResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SendMsgResponse) ProtoMessage ¶
func (*SendMsgResponse) ProtoMessage()
func (*SendMsgResponse) Reset ¶
func (m *SendMsgResponse) Reset()
func (*SendMsgResponse) Size ¶
func (m *SendMsgResponse) Size() (n int)
func (*SendMsgResponse) String ¶
func (m *SendMsgResponse) String() string
func (*SendMsgResponse) Unmarshal ¶
func (m *SendMsgResponse) Unmarshal(dAtA []byte) error
func (*SendMsgResponse) XXX_DiscardUnknown ¶
func (m *SendMsgResponse) XXX_DiscardUnknown()
func (*SendMsgResponse) XXX_Marshal ¶
func (m *SendMsgResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendMsgResponse) XXX_Merge ¶
func (m *SendMsgResponse) XXX_Merge(src proto.Message)
func (*SendMsgResponse) XXX_Size ¶
func (m *SendMsgResponse) XXX_Size() int
func (*SendMsgResponse) XXX_Unmarshal ¶
func (m *SendMsgResponse) XXX_Unmarshal(b []byte) error
type SignalTypeEnum ¶
type SignalTypeEnum int32
const ( SignalTypeEnum_PartnerExit SignalTypeEnum = 0 SignalTypeEnum_NewSession SignalTypeEnum = 1 SignalTypeEnum_DeleteMsg SignalTypeEnum = 2 SignalTypeEnum_ViewedAck SignalTypeEnum = 3 )
func (SignalTypeEnum) EnumDescriptor ¶
func (SignalTypeEnum) EnumDescriptor() ([]byte, []int)
func (SignalTypeEnum) String ¶
func (x SignalTypeEnum) String() string
type StatusEnum ¶
type StatusEnum int32
const ( StatusEnum_Deleted StatusEnum = 0 StatusEnum_Normal StatusEnum = 1 )
func (StatusEnum) EnumDescriptor ¶
func (StatusEnum) EnumDescriptor() ([]byte, []int)
func (StatusEnum) String ¶
func (x StatusEnum) String() string
type UnimplementedBrokerServer ¶
type UnimplementedBrokerServer struct { }
UnimplementedBrokerServer can be embedded to have forward compatible implementations.
func (*UnimplementedBrokerServer) ReceiveMsgDialogue ¶
func (*UnimplementedBrokerServer) ReceiveMsgDialogue(ctx context.Context, req *PushDialogue) (*PushResp, error)
func (*UnimplementedBrokerServer) ReceiveMsgSignal ¶
func (*UnimplementedBrokerServer) ReceiveMsgSignal(ctx context.Context, req *PushSignal) (*PushResp, error)
type UnimplementedLogicDealerServer ¶
type UnimplementedLogicDealerServer struct { }
UnimplementedLogicDealerServer can be embedded to have forward compatible implementations.
func (*UnimplementedLogicDealerServer) BrokerOnline ¶
func (*UnimplementedLogicDealerServer) BrokerOnline(ctx context.Context, req *OnlineRequest) (*OnlineResponse, error)
func (*UnimplementedLogicDealerServer) CreateAccount ¶
func (*UnimplementedLogicDealerServer) CreateAccount(ctx context.Context, req *CreateAccountRequest) (*CreateAccountResponse, error)
func (*UnimplementedLogicDealerServer) Logout ¶
func (*UnimplementedLogicDealerServer) Logout(ctx context.Context, req *LogoutRequest) (*LogoutResponse, error)
func (*UnimplementedLogicDealerServer) Match ¶
func (*UnimplementedLogicDealerServer) Match(ctx context.Context, req *MatchRequest) (*MatchResponse, error)
func (*UnimplementedLogicDealerServer) SendMsg ¶
func (*UnimplementedLogicDealerServer) SendMsg(ctx context.Context, req *SendMsgRequest) (*SendMsgResponse, error)
func (*UnimplementedLogicDealerServer) ViewedAck ¶
func (*UnimplementedLogicDealerServer) ViewedAck(ctx context.Context, req *ViewedAckRequest) (*ViewedAckResponse, error)
type ViewedAckRequest ¶
type ViewedAckRequest struct { SessionId uint64 `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"` AccountId uint64 `protobuf:"varint,2,opt,name=accountId,proto3" json:"accountId,omitempty"` MsgId uint64 `protobuf:"varint,3,opt,name=msgId,proto3" json:"msgId,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ViewedAckRequest) Descriptor ¶
func (*ViewedAckRequest) Descriptor() ([]byte, []int)
func (*ViewedAckRequest) GetAccountId ¶
func (m *ViewedAckRequest) GetAccountId() uint64
func (*ViewedAckRequest) GetMsgId ¶
func (m *ViewedAckRequest) GetMsgId() uint64
func (*ViewedAckRequest) GetSessionId ¶
func (m *ViewedAckRequest) GetSessionId() uint64
func (*ViewedAckRequest) Marshal ¶
func (m *ViewedAckRequest) Marshal() (dAtA []byte, err error)
func (*ViewedAckRequest) MarshalToSizedBuffer ¶
func (m *ViewedAckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewedAckRequest) ProtoMessage ¶
func (*ViewedAckRequest) ProtoMessage()
func (*ViewedAckRequest) Reset ¶
func (m *ViewedAckRequest) Reset()
func (*ViewedAckRequest) Size ¶
func (m *ViewedAckRequest) Size() (n int)
func (*ViewedAckRequest) String ¶
func (m *ViewedAckRequest) String() string
func (*ViewedAckRequest) Unmarshal ¶
func (m *ViewedAckRequest) Unmarshal(dAtA []byte) error
func (*ViewedAckRequest) XXX_DiscardUnknown ¶
func (m *ViewedAckRequest) XXX_DiscardUnknown()
func (*ViewedAckRequest) XXX_Marshal ¶
func (m *ViewedAckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewedAckRequest) XXX_Merge ¶
func (m *ViewedAckRequest) XXX_Merge(src proto.Message)
func (*ViewedAckRequest) XXX_Size ¶
func (m *ViewedAckRequest) XXX_Size() int
func (*ViewedAckRequest) XXX_Unmarshal ¶
func (m *ViewedAckRequest) XXX_Unmarshal(b []byte) error
type ViewedAckResponse ¶
type ViewedAckResponse struct { Code CodeEnum `protobuf:"varint,1,opt,name=code,proto3,enum=proto.CodeEnum" json:"code,omitempty"` Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ViewedAckResponse) Descriptor ¶
func (*ViewedAckResponse) Descriptor() ([]byte, []int)
func (*ViewedAckResponse) GetCode ¶
func (m *ViewedAckResponse) GetCode() CodeEnum
func (*ViewedAckResponse) GetMsg ¶
func (m *ViewedAckResponse) GetMsg() string
func (*ViewedAckResponse) Marshal ¶
func (m *ViewedAckResponse) Marshal() (dAtA []byte, err error)
func (*ViewedAckResponse) MarshalTo ¶
func (m *ViewedAckResponse) MarshalTo(dAtA []byte) (int, error)
func (*ViewedAckResponse) MarshalToSizedBuffer ¶
func (m *ViewedAckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ViewedAckResponse) ProtoMessage ¶
func (*ViewedAckResponse) ProtoMessage()
func (*ViewedAckResponse) Reset ¶
func (m *ViewedAckResponse) Reset()
func (*ViewedAckResponse) Size ¶
func (m *ViewedAckResponse) Size() (n int)
func (*ViewedAckResponse) String ¶
func (m *ViewedAckResponse) String() string
func (*ViewedAckResponse) Unmarshal ¶
func (m *ViewedAckResponse) Unmarshal(dAtA []byte) error
func (*ViewedAckResponse) XXX_DiscardUnknown ¶
func (m *ViewedAckResponse) XXX_DiscardUnknown()
func (*ViewedAckResponse) XXX_Marshal ¶
func (m *ViewedAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ViewedAckResponse) XXX_Merge ¶
func (m *ViewedAckResponse) XXX_Merge(src proto.Message)
func (*ViewedAckResponse) XXX_Size ¶
func (m *ViewedAckResponse) XXX_Size() int
func (*ViewedAckResponse) XXX_Unmarshal ¶
func (m *ViewedAckResponse) XXX_Unmarshal(b []byte) error