proto

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2023 License: GPL-3.0 Imports: 9 Imported by: 0

README 

# generate a Go protocol buffer package
# 1. install protobuf
```
brew install protobuf
```
# 2. Install the protoc-gen-gofast binary
```
go get github.com/gogo/protobuf/protoc-gen-gofast
```
# 3. generate a Go protocol buffer package
```
protoc --gofast_out=plugins=grpc:. *.proto
```

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBroker        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBroker          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBroker = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthLogic        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogic          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogic = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var CodeEnum_name = map[int32]string{
	0: "Success",
	1: "ParamErr",
	2: "InternalErr",
	3: "UnknowErr",
	4: "NoDataFound",
}
View Source 
var CodeEnum_value = map[string]int32{
	"Success":     0,
	"ParamErr":    1,
	"InternalErr": 2,
	"UnknowErr":   3,
	"NoDataFound": 4,
}
View Source 
var MsgTypeEnum_name = map[int32]string{
	0: "Dialogue",
	1: "Signal",
}
View Source 
var MsgTypeEnum_value = map[string]int32{
	"Dialogue": 0,
	"Signal":   1,
}
View Source 
var SignalTypeEnum_name = map[int32]string{
	0: "PartnerExit",
	1: "NewSession",
	2: "DeleteMsg",
	3: "ViewedAck",
}
View Source 
var SignalTypeEnum_value = map[string]int32{
	"PartnerExit": 0,
	"NewSession":  1,
	"DeleteMsg":   2,
	"ViewedAck":   3,
}
View Source 
var StatusEnum_name = map[int32]string{
	0: "Deleted",
	1: "Normal",
}
View Source 
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) MarshalTo 

func (m *AccountInfo) MarshalTo(dAtA []byte) (int, 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 {
	// Receive data pushed by logic
	ReceiveMsgDialogue(ctx context.Context, in *PushDialogue, opts ...grpc.CallOption) (*PushResp, error)
	ReceiveMsgSignal(ctx context.Context, in *PushSignal, opts ...grpc.CallOption) (*PushResp, error)
	HealthCheck(ctx context.Context, in *HealthCheckReq, opts ...grpc.CallOption) (*HealthCheckResp, 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 {
	// Receive data pushed by logic
	ReceiveMsgDialogue(context.Context, *PushDialogue) (*PushResp, error)
	ReceiveMsgSignal(context.Context, *PushSignal) (*PushResp, error)
	HealthCheck(context.Context, *HealthCheckReq) (*HealthCheckResp, error)
}

BrokerServer is the server API for Broker service.

type CodeEnum 

type CodeEnum int32
const (
	CodeEnum_Success     CodeEnum = 0
	CodeEnum_ParamErr    CodeEnum = 1
	CodeEnum_InternalErr CodeEnum = 2
	CodeEnum_UnknowErr   CodeEnum = 3
	CodeEnum_NoDataFound CodeEnum = 4
)

func (CodeEnum) EnumDescriptor 

func (CodeEnum) EnumDescriptor() ([]byte, []int)

func (CodeEnum) String 

func (x CodeEnum) String() string

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 HealthCheckReq 

type HealthCheckReq struct {
	Asker                string   `protobuf:"bytes,1,opt,name=asker,proto3" json:"asker,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HealthCheckReq) Descriptor 

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

func (*HealthCheckReq) GetAsker 

func (m *HealthCheckReq) GetAsker() string

func (*HealthCheckReq) Marshal 

func (m *HealthCheckReq) Marshal() (dAtA []byte, err error)

func (*HealthCheckReq) MarshalTo 

func (m *HealthCheckReq) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheckReq) MarshalToSizedBuffer 

func (m *HealthCheckReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthCheckReq) ProtoMessage 

func (*HealthCheckReq) ProtoMessage()

func (*HealthCheckReq) Reset 

func (m *HealthCheckReq) Reset()

func (*HealthCheckReq) Size 

func (m *HealthCheckReq) Size() (n int)

func (*HealthCheckReq) String 

func (m *HealthCheckReq) String() string

func (*HealthCheckReq) Unmarshal 

func (m *HealthCheckReq) Unmarshal(dAtA []byte) error

func (*HealthCheckReq) XXX_DiscardUnknown 

func (m *HealthCheckReq) XXX_DiscardUnknown()

func (*HealthCheckReq) XXX_Marshal 

func (m *HealthCheckReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckReq) XXX_Merge 

func (m *HealthCheckReq) XXX_Merge(src proto.Message)

func (*HealthCheckReq) XXX_Size 

func (m *HealthCheckReq) XXX_Size() int

func (*HealthCheckReq) XXX_Unmarshal 

func (m *HealthCheckReq) XXX_Unmarshal(b []byte) error

type HealthCheckResp 

type HealthCheckResp 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 (*HealthCheckResp) Descriptor 

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

func (*HealthCheckResp) GetCode 

func (m *HealthCheckResp) GetCode() CodeEnum

func (*HealthCheckResp) GetMsg 

func (m *HealthCheckResp) GetMsg() string

func (*HealthCheckResp) Marshal 

func (m *HealthCheckResp) Marshal() (dAtA []byte, err error)

func (*HealthCheckResp) MarshalTo 

func (m *HealthCheckResp) MarshalTo(dAtA []byte) (int, error)

func (*HealthCheckResp) MarshalToSizedBuffer 

func (m *HealthCheckResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HealthCheckResp) ProtoMessage 

func (*HealthCheckResp) ProtoMessage()

func (*HealthCheckResp) Reset 

func (m *HealthCheckResp) Reset()

func (*HealthCheckResp) Size 

func (m *HealthCheckResp) Size() (n int)

func (*HealthCheckResp) String 

func (m *HealthCheckResp) String() string

func (*HealthCheckResp) Unmarshal 

func (m *HealthCheckResp) Unmarshal(dAtA []byte) error

func (*HealthCheckResp) XXX_DiscardUnknown 

func (m *HealthCheckResp) XXX_DiscardUnknown()

func (*HealthCheckResp) XXX_Marshal 

func (m *HealthCheckResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HealthCheckResp) XXX_Merge 

func (m *HealthCheckResp) XXX_Merge(src proto.Message)

func (*HealthCheckResp) XXX_Size 

func (m *HealthCheckResp) XXX_Size() int

func (*HealthCheckResp) XXX_Unmarshal 

func (m *HealthCheckResp) 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)
	Reconnect(ctx context.Context, in *ReConnectRequest, opts ...grpc.CallOption) (*ReConnectResponse, 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)
	Reconnect(context.Context, *ReConnectRequest) (*ReConnectResponse, 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"`
	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 (*LogoutRequest) Descriptor 

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

func (*LogoutRequest) GetAccountId 

func (m *LogoutRequest) GetAccountId() uint64

func (*LogoutRequest) GetBroker added in v0.1.0 

func (m *LogoutRequest) GetBroker() string

func (*LogoutRequest) Marshal 

func (m *LogoutRequest) Marshal() (dAtA []byte, err error)

func (*LogoutRequest) MarshalTo 

func (m *LogoutRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *LogoutResponse) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *MatchRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *MatchResponse) MarshalTo(dAtA []byte) (int, 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 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) MarshalTo 

func (m *PushDialogue) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PushRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*PushResp) GetCode 

func (m *PushResp) GetCode() CodeEnum

func (*PushResp) GetMsg 

func (m *PushResp) GetMsg() string

func (*PushResp) Marshal 

func (m *PushResp) Marshal() (dAtA []byte, err error)

func (*PushResp) MarshalTo 

func (m *PushResp) MarshalTo(dAtA []byte) (int, error)

func (*PushResp) MarshalToSizedBuffer 

func (m *PushResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushResp) ProtoMessage 

func (*PushResp) ProtoMessage()

func (*PushResp) Reset 

func (m *PushResp) Reset()

func (*PushResp) Size 

func (m *PushResp) Size() (n int)

func (*PushResp) String 

func (m *PushResp) String() string

func (*PushResp) Unmarshal 

func (m *PushResp) Unmarshal(dAtA []byte) error

func (*PushResp) XXX_DiscardUnknown 

func (m *PushResp) XXX_DiscardUnknown()

func (*PushResp) XXX_Marshal 

func (m *PushResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushResp) XXX_Merge 

func (m *PushResp) XXX_Merge(src proto.Message)

func (*PushResp) XXX_Size 

func (m *PushResp) XXX_Size() int

func (*PushResp) XXX_Unmarshal 

func (m *PushResp) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *PushSignal) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PushSignal_MsgId) MarshalTo(dAtA []byte) (int, error)

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 ReConnectRequest 

type ReConnectRequest struct {
	AccountId            uint64   `protobuf:"varint,1,opt,name=accountId,proto3" json:"accountId,omitempty"`
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Broker               string   `protobuf:"bytes,3,opt,name=broker,proto3" json:"broker,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReConnectRequest) Descriptor 

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

func (*ReConnectRequest) GetAccountId 

func (m *ReConnectRequest) GetAccountId() uint64

func (*ReConnectRequest) GetBroker 

func (m *ReConnectRequest) GetBroker() string

func (*ReConnectRequest) GetToken 

func (m *ReConnectRequest) GetToken() string

func (*ReConnectRequest) Marshal 

func (m *ReConnectRequest) Marshal() (dAtA []byte, err error)

func (*ReConnectRequest) MarshalTo 

func (m *ReConnectRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReConnectRequest) MarshalToSizedBuffer 

func (m *ReConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReConnectRequest) ProtoMessage 

func (*ReConnectRequest) ProtoMessage()

func (*ReConnectRequest) Reset 

func (m *ReConnectRequest) Reset()

func (*ReConnectRequest) Size 

func (m *ReConnectRequest) Size() (n int)

func (*ReConnectRequest) String 

func (m *ReConnectRequest) String() string

func (*ReConnectRequest) Unmarshal 

func (m *ReConnectRequest) Unmarshal(dAtA []byte) error

func (*ReConnectRequest) XXX_DiscardUnknown 

func (m *ReConnectRequest) XXX_DiscardUnknown()

func (*ReConnectRequest) XXX_Marshal 

func (m *ReConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReConnectRequest) XXX_Merge 

func (m *ReConnectRequest) XXX_Merge(src proto.Message)

func (*ReConnectRequest) XXX_Size 

func (m *ReConnectRequest) XXX_Size() int

func (*ReConnectRequest) XXX_Unmarshal 

func (m *ReConnectRequest) XXX_Unmarshal(b []byte) error

type ReConnectResponse 

type ReConnectResponse 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"`
	Nickname             string   `protobuf:"bytes,4,opt,name=nickname,proto3" json:"nickname,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReConnectResponse) Descriptor 

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

func (*ReConnectResponse) GetAccountId 

func (m *ReConnectResponse) GetAccountId() uint64

func (*ReConnectResponse) GetCode 

func (m *ReConnectResponse) GetCode() CodeEnum

func (*ReConnectResponse) GetMsg 

func (m *ReConnectResponse) GetMsg() string

func (*ReConnectResponse) GetNickname 

func (m *ReConnectResponse) GetNickname() string

func (*ReConnectResponse) Marshal 

func (m *ReConnectResponse) Marshal() (dAtA []byte, err error)

func (*ReConnectResponse) MarshalTo 

func (m *ReConnectResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReConnectResponse) MarshalToSizedBuffer 

func (m *ReConnectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReConnectResponse) ProtoMessage 

func (*ReConnectResponse) ProtoMessage()

func (*ReConnectResponse) Reset 

func (m *ReConnectResponse) Reset()

func (*ReConnectResponse) Size 

func (m *ReConnectResponse) Size() (n int)

func (*ReConnectResponse) String 

func (m *ReConnectResponse) String() string

func (*ReConnectResponse) Unmarshal 

func (m *ReConnectResponse) Unmarshal(dAtA []byte) error

func (*ReConnectResponse) XXX_DiscardUnknown 

func (m *ReConnectResponse) XXX_DiscardUnknown()

func (*ReConnectResponse) XXX_Marshal 

func (m *ReConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReConnectResponse) XXX_Merge 

func (m *ReConnectResponse) XXX_Merge(src proto.Message)

func (*ReConnectResponse) XXX_Size 

func (m *ReConnectResponse) XXX_Size() int

func (*ReConnectResponse) XXX_Unmarshal 

func (m *ReConnectResponse) XXX_Unmarshal(b []byte) error

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) MarshalTo 

func (m *SendMsgRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SendMsgResponse) MarshalTo(dAtA []byte) (int, 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) HealthCheck 

func (*UnimplementedBrokerServer) HealthCheck(ctx context.Context, req *HealthCheckReq) (*HealthCheckResp, error)

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) 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) Reconnect 

func (*UnimplementedLogicDealerServer) Reconnect(ctx context.Context, req *ReConnectRequest) (*ReConnectResponse, 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) MarshalTo 

func (m *ViewedAckRequest) MarshalTo(dAtA []byte) (int, 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

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.