rpc

package
v0.0.0-...-1905027 Latest Latest
Warning

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

 Go to latest Published: Mar 30, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultRpcConnNum           = 1
	DefaultRpcLenMsgLen         = 4
	DefaultRpcMinMsgLen         = 2
	DefaultMaxCheckCallRpcCount = 1000
	DefaultMaxPendingWriteNum   = 200000

	DefaultConnectInterval             = 2 * time.Second
	DefaultCheckRpcCallTimeoutInterval = 5 * time.Second
	DefaultRpcTimeout                  = 15 * time.Second
)
View Source 
const Default_ReadWriteDeadline = 15 * time.Second

Variables

View Source 
var (
	ErrInvalidLengthDynamicdiscover        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDynamicdiscover          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDynamicdiscover = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGogorpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGogorpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGogorpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMessagequeue        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessagequeue          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessagequeue = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRank        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRank          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRank = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var LittleEndian bool
View Source 
var SubscribeMethod_name = map[int32]string{
	0: "Method_Custom",
	1: "Method_Last",
}
View Source 
var SubscribeMethod_value = map[string]int32{
	"Method_Custom": 0,
	"Method_Last":   1,
}
View Source 
var SubscribeType_name = map[int32]string{
	0: "Subscribe",
	1: "Unsubscribe",
}
View Source 
var SubscribeType_value = map[string]int32{
	"Subscribe":   0,
	"Unsubscribe": 1,
}

Functions

func AppendProcessor 

func AppendProcessor(rpcProcessor IRpcProcessor)

func GetProcessorType 

func GetProcessorType(param interface{}) (RpcProcessorType, IRpcProcessor)

func ReleaseCall 

func ReleaseCall(call *Call)

func ReleaseRpcRequest 

func ReleaseRpcRequest(rpcRequest *RpcRequest)

Types

type AddRankList 

type AddRankList struct {
	AddList              []*RankList `protobuf:"bytes,1,rep,name=AddList,proto3" json:"AddList,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

AddRankList 新增排行榜

func (*AddRankList) Descriptor 

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

func (*AddRankList) GetAddList 

func (m *AddRankList) GetAddList() []*RankList

func (*AddRankList) Marshal 

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

func (*AddRankList) MarshalTo 

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

func (*AddRankList) MarshalToSizedBuffer 

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

func (*AddRankList) ProtoMessage 

func (*AddRankList) ProtoMessage()

func (*AddRankList) Reset 

func (m *AddRankList) Reset()

func (*AddRankList) Size 

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

func (*AddRankList) String 

func (m *AddRankList) String() string

func (*AddRankList) Unmarshal 

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

func (*AddRankList) XXX_DiscardUnknown 

func (m *AddRankList) XXX_DiscardUnknown()

func (*AddRankList) XXX_Marshal 

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

func (*AddRankList) XXX_Merge 

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

func (*AddRankList) XXX_Size 

func (m *AddRankList) XXX_Size() int

func (*AddRankList) XXX_Unmarshal 

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

type Call 

type Call struct {
	Seq           uint64
	ServiceMethod string
	Reply         interface{}
	Response      *RpcResponse
	Err           error
	// contains filtered or unexported fields
}

func MakeCall 

func MakeCall() *Call

func (*Call) Clear 

func (call *Call) Clear() *Call

func (*Call) Done 

func (call *Call) Done() *Call

func (*Call) IsRef 

func (call *Call) IsRef() bool

func (*Call) Ref 

func (call *Call) Ref()

func (*Call) Reset 

func (call *Call) Reset()

func (*Call) UnRef 

func (call *Call) UnRef()

type Client 

type Client struct {
	IRealClient
	// contains filtered or unexported fields
}

func NewLClient 

func NewLClient(nodeId int) *Client

func NewRClient 

func NewRClient(nodeId int, addr string, maxRpcParamLen uint32, triggerRpcConnEvent TriggerRpcConnEvent) *Client

func (*Client) AddPending 

func (bc *Client) AddPending(call *Call)

func (*Client) FindPending 

func (bc *Client) FindPending(seq uint64) *Call

func (*Client) GetClientId 

func (client *Client) GetClientId() uint32

func (*Client) GetNodeId 

func (client *Client) GetNodeId() int

func (*Client) InitPending 

func (client *Client) InitPending()

func (*Client) NewClientAgent 

func (client *Client) NewClientAgent(conn *network.TCPConn) network.Agent

func (*Client) RemovePending 

func (bc *Client) RemovePending(seq uint64) *Call

type DBQueuePopReq 

type DBQueuePopReq struct {
	CustomerId           string   `protobuf:"bytes,1,opt,name=CustomerId,proto3" json:"CustomerId,omitempty"`
	QueueName            string   `protobuf:"bytes,2,opt,name=QueueName,proto3" json:"QueueName,omitempty"`
	PopStartPos          int32    `protobuf:"varint,3,opt,name=PopStartPos,proto3" json:"PopStartPos,omitempty"`
	PopNum               int32    `protobuf:"varint,4,opt,name=PopNum,proto3" json:"PopNum,omitempty"`
	PushData             []byte   `protobuf:"bytes,5,opt,name=pushData,proto3" json:"pushData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueuePopReq) Descriptor 

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

func (*DBQueuePopReq) GetCustomerId 

func (m *DBQueuePopReq) GetCustomerId() string

func (*DBQueuePopReq) GetPopNum 

func (m *DBQueuePopReq) GetPopNum() int32

func (*DBQueuePopReq) GetPopStartPos 

func (m *DBQueuePopReq) GetPopStartPos() int32

func (*DBQueuePopReq) GetPushData 

func (m *DBQueuePopReq) GetPushData() []byte

func (*DBQueuePopReq) GetQueueName 

func (m *DBQueuePopReq) GetQueueName() string

func (*DBQueuePopReq) Marshal 

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

func (*DBQueuePopReq) MarshalTo 

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

func (*DBQueuePopReq) MarshalToSizedBuffer 

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

func (*DBQueuePopReq) ProtoMessage 

func (*DBQueuePopReq) ProtoMessage()

func (*DBQueuePopReq) Reset 

func (m *DBQueuePopReq) Reset()

func (*DBQueuePopReq) Size 

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

func (*DBQueuePopReq) String 

func (m *DBQueuePopReq) String() string

func (*DBQueuePopReq) Unmarshal 

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

func (*DBQueuePopReq) XXX_DiscardUnknown 

func (m *DBQueuePopReq) XXX_DiscardUnknown()

func (*DBQueuePopReq) XXX_Marshal 

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

func (*DBQueuePopReq) XXX_Merge 

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

func (*DBQueuePopReq) XXX_Size 

func (m *DBQueuePopReq) XXX_Size() int

func (*DBQueuePopReq) XXX_Unmarshal 

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

type DBQueuePopRes 

type DBQueuePopRes struct {
	QueueName            string   `protobuf:"bytes,1,opt,name=QueueName,proto3" json:"QueueName,omitempty"`
	PushData             [][]byte `protobuf:"bytes,2,rep,name=pushData,proto3" json:"pushData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueuePopRes) Descriptor 

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

func (*DBQueuePopRes) GetPushData 

func (m *DBQueuePopRes) GetPushData() [][]byte

func (*DBQueuePopRes) GetQueueName 

func (m *DBQueuePopRes) GetQueueName() string

func (*DBQueuePopRes) Marshal 

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

func (*DBQueuePopRes) MarshalTo 

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

func (*DBQueuePopRes) MarshalToSizedBuffer 

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

func (*DBQueuePopRes) ProtoMessage 

func (*DBQueuePopRes) ProtoMessage()

func (*DBQueuePopRes) Reset 

func (m *DBQueuePopRes) Reset()

func (*DBQueuePopRes) Size 

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

func (*DBQueuePopRes) String 

func (m *DBQueuePopRes) String() string

func (*DBQueuePopRes) Unmarshal 

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

func (*DBQueuePopRes) XXX_DiscardUnknown 

func (m *DBQueuePopRes) XXX_DiscardUnknown()

func (*DBQueuePopRes) XXX_Marshal 

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

func (*DBQueuePopRes) XXX_Merge 

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

func (*DBQueuePopRes) XXX_Size 

func (m *DBQueuePopRes) XXX_Size() int

func (*DBQueuePopRes) XXX_Unmarshal 

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

type DBQueuePublishReq 

type DBQueuePublishReq struct {
	TopicName            string   `protobuf:"bytes,1,opt,name=TopicName,proto3" json:"TopicName,omitempty"`
	PushData             [][]byte `protobuf:"bytes,2,rep,name=pushData,proto3" json:"pushData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueuePublishReq) Descriptor 

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

func (*DBQueuePublishReq) GetPushData 

func (m *DBQueuePublishReq) GetPushData() [][]byte

func (*DBQueuePublishReq) GetTopicName 

func (m *DBQueuePublishReq) GetTopicName() string

func (*DBQueuePublishReq) Marshal 

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

func (*DBQueuePublishReq) MarshalTo 

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

func (*DBQueuePublishReq) MarshalToSizedBuffer 

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

func (*DBQueuePublishReq) ProtoMessage 

func (*DBQueuePublishReq) ProtoMessage()

func (*DBQueuePublishReq) Reset 

func (m *DBQueuePublishReq) Reset()

func (*DBQueuePublishReq) Size 

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

func (*DBQueuePublishReq) String 

func (m *DBQueuePublishReq) String() string

func (*DBQueuePublishReq) Unmarshal 

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

func (*DBQueuePublishReq) XXX_DiscardUnknown 

func (m *DBQueuePublishReq) XXX_DiscardUnknown()

func (*DBQueuePublishReq) XXX_Marshal 

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

func (*DBQueuePublishReq) XXX_Merge 

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

func (*DBQueuePublishReq) XXX_Size 

func (m *DBQueuePublishReq) XXX_Size() int

func (*DBQueuePublishReq) XXX_Unmarshal 

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

type DBQueuePublishRes 

type DBQueuePublishRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueuePublishRes) Descriptor 

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

func (*DBQueuePublishRes) Marshal 

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

func (*DBQueuePublishRes) MarshalTo 

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

func (*DBQueuePublishRes) MarshalToSizedBuffer 

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

func (*DBQueuePublishRes) ProtoMessage 

func (*DBQueuePublishRes) ProtoMessage()

func (*DBQueuePublishRes) Reset 

func (m *DBQueuePublishRes) Reset()

func (*DBQueuePublishRes) Size 

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

func (*DBQueuePublishRes) String 

func (m *DBQueuePublishRes) String() string

func (*DBQueuePublishRes) Unmarshal 

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

func (*DBQueuePublishRes) XXX_DiscardUnknown 

func (m *DBQueuePublishRes) XXX_DiscardUnknown()

func (*DBQueuePublishRes) XXX_Marshal 

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

func (*DBQueuePublishRes) XXX_Merge 

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

func (*DBQueuePublishRes) XXX_Size 

func (m *DBQueuePublishRes) XXX_Size() int

func (*DBQueuePublishRes) XXX_Unmarshal 

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

type DBQueueSubscribeReq 

type DBQueueSubscribeReq struct {
	SubType              SubscribeType   `protobuf:"varint,1,opt,name=SubType,proto3,enum=SubscribeType" json:"SubType,omitempty"`
	Method               SubscribeMethod `protobuf:"varint,2,opt,name=Method,proto3,enum=SubscribeMethod" json:"Method,omitempty"`
	CustomerId           string          `protobuf:"bytes,3,opt,name=CustomerId,proto3" json:"CustomerId,omitempty"`
	FromNodeId           int32           `protobuf:"varint,4,opt,name=FromNodeId,proto3" json:"FromNodeId,omitempty"`
	RpcMethod            string          `protobuf:"bytes,5,opt,name=RpcMethod,proto3" json:"RpcMethod,omitempty"`
	TopicName            string          `protobuf:"bytes,6,opt,name=TopicName,proto3" json:"TopicName,omitempty"`
	StartIndex           uint64          `protobuf:"varint,7,opt,name=StartIndex,proto3" json:"StartIndex,omitempty"`
	OneBatchQuantity     int32           `protobuf:"varint,8,opt,name=OneBatchQuantity,proto3" json:"OneBatchQuantity,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

订阅

func (*DBQueueSubscribeReq) Descriptor 

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

func (*DBQueueSubscribeReq) GetCustomerId 

func (m *DBQueueSubscribeReq) GetCustomerId() string

func (*DBQueueSubscribeReq) GetFromNodeId 

func (m *DBQueueSubscribeReq) GetFromNodeId() int32

func (*DBQueueSubscribeReq) GetMethod 

func (m *DBQueueSubscribeReq) GetMethod() SubscribeMethod

func (*DBQueueSubscribeReq) GetOneBatchQuantity 

func (m *DBQueueSubscribeReq) GetOneBatchQuantity() int32

func (*DBQueueSubscribeReq) GetRpcMethod 

func (m *DBQueueSubscribeReq) GetRpcMethod() string

func (*DBQueueSubscribeReq) GetStartIndex 

func (m *DBQueueSubscribeReq) GetStartIndex() uint64

func (*DBQueueSubscribeReq) GetSubType 

func (m *DBQueueSubscribeReq) GetSubType() SubscribeType

func (*DBQueueSubscribeReq) GetTopicName 

func (m *DBQueueSubscribeReq) GetTopicName() string

func (*DBQueueSubscribeReq) Marshal 

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

func (*DBQueueSubscribeReq) MarshalTo 

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

func (*DBQueueSubscribeReq) MarshalToSizedBuffer 

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

func (*DBQueueSubscribeReq) ProtoMessage 

func (*DBQueueSubscribeReq) ProtoMessage()

func (*DBQueueSubscribeReq) Reset 

func (m *DBQueueSubscribeReq) Reset()

func (*DBQueueSubscribeReq) Size 

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

func (*DBQueueSubscribeReq) String 

func (m *DBQueueSubscribeReq) String() string

func (*DBQueueSubscribeReq) Unmarshal 

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

func (*DBQueueSubscribeReq) XXX_DiscardUnknown 

func (m *DBQueueSubscribeReq) XXX_DiscardUnknown()

func (*DBQueueSubscribeReq) XXX_Marshal 

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

func (*DBQueueSubscribeReq) XXX_Merge 

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

func (*DBQueueSubscribeReq) XXX_Size 

func (m *DBQueueSubscribeReq) XXX_Size() int

func (*DBQueueSubscribeReq) XXX_Unmarshal 

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

type DBQueueSubscribeRes 

type DBQueueSubscribeRes struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DBQueueSubscribeRes) Descriptor 

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

func (*DBQueueSubscribeRes) Marshal 

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

func (*DBQueueSubscribeRes) MarshalTo 

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

func (*DBQueueSubscribeRes) MarshalToSizedBuffer 

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

func (*DBQueueSubscribeRes) ProtoMessage 

func (*DBQueueSubscribeRes) ProtoMessage()

func (*DBQueueSubscribeRes) Reset 

func (m *DBQueueSubscribeRes) Reset()

func (*DBQueueSubscribeRes) Size 

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

func (*DBQueueSubscribeRes) String 

func (m *DBQueueSubscribeRes) String() string

func (*DBQueueSubscribeRes) Unmarshal 

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

func (*DBQueueSubscribeRes) XXX_DiscardUnknown 

func (m *DBQueueSubscribeRes) XXX_DiscardUnknown()

func (*DBQueueSubscribeRes) XXX_Marshal 

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

func (*DBQueueSubscribeRes) XXX_Merge 

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

func (*DBQueueSubscribeRes) XXX_Size 

func (m *DBQueueSubscribeRes) XXX_Size() int

func (*DBQueueSubscribeRes) XXX_Unmarshal 

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

type DeleteByKey 

type DeleteByKey struct {
	RankId               uint64   `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`
	KeyList              []uint64 `protobuf:"varint,2,rep,packed,name=KeyList,proto3" json:"KeyList,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeleteByKey 删除排行榜数据

func (*DeleteByKey) Descriptor 

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

func (*DeleteByKey) GetKeyList 

func (m *DeleteByKey) GetKeyList() []uint64

func (*DeleteByKey) GetRankId 

func (m *DeleteByKey) GetRankId() uint64

func (*DeleteByKey) Marshal 

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

func (*DeleteByKey) MarshalTo 

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

func (*DeleteByKey) MarshalToSizedBuffer 

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

func (*DeleteByKey) ProtoMessage 

func (*DeleteByKey) ProtoMessage()

func (*DeleteByKey) Reset 

func (m *DeleteByKey) Reset()

func (*DeleteByKey) Size 

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

func (*DeleteByKey) String 

func (m *DeleteByKey) String() string

func (*DeleteByKey) Unmarshal 

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

func (*DeleteByKey) XXX_DiscardUnknown 

func (m *DeleteByKey) XXX_DiscardUnknown()

func (*DeleteByKey) XXX_Marshal 

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

func (*DeleteByKey) XXX_Merge 

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

func (*DeleteByKey) XXX_Size 

func (m *DeleteByKey) XXX_Size() int

func (*DeleteByKey) XXX_Unmarshal 

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

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Master->Client

func (*Empty) Descriptor 

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

func (*Empty) Marshal 

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

func (*Empty) MarshalTo 

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

func (*Empty) MarshalToSizedBuffer 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

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

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) Unmarshal 

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

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type ExtendIncData 

type ExtendIncData struct {
	InitValue            int64    `protobuf:"varint,1,opt,name=InitValue,proto3" json:"InitValue,omitempty"`
	IncreaseValue        int64    `protobuf:"varint,2,opt,name=IncreaseValue,proto3" json:"IncreaseValue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExtendIncData) Descriptor 

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

func (*ExtendIncData) GetIncreaseValue 

func (m *ExtendIncData) GetIncreaseValue() int64

func (*ExtendIncData) GetInitValue 

func (m *ExtendIncData) GetInitValue() int64

func (*ExtendIncData) Marshal 

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

func (*ExtendIncData) MarshalTo 

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

func (*ExtendIncData) MarshalToSizedBuffer 

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

func (*ExtendIncData) ProtoMessage 

func (*ExtendIncData) ProtoMessage()

func (*ExtendIncData) Reset 

func (m *ExtendIncData) Reset()

func (*ExtendIncData) Size 

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

func (*ExtendIncData) String 

func (m *ExtendIncData) String() string

func (*ExtendIncData) Unmarshal 

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

func (*ExtendIncData) XXX_DiscardUnknown 

func (m *ExtendIncData) XXX_DiscardUnknown()

func (*ExtendIncData) XXX_Marshal 

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

func (*ExtendIncData) XXX_Merge 

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

func (*ExtendIncData) XXX_Size 

func (m *ExtendIncData) XXX_Size() int

func (*ExtendIncData) XXX_Unmarshal 

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

type FindRankDataByKey 

type FindRankDataByKey struct {
	RankId               uint64   `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`
	Key                  uint64   `protobuf:"varint,2,opt,name=Key,proto3" json:"Key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FindRankDataByKey 查找排行信息

func (*FindRankDataByKey) Descriptor 

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

func (*FindRankDataByKey) GetKey 

func (m *FindRankDataByKey) GetKey() uint64

func (*FindRankDataByKey) GetRankId 

func (m *FindRankDataByKey) GetRankId() uint64

func (*FindRankDataByKey) Marshal 

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

func (*FindRankDataByKey) MarshalTo 

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

func (*FindRankDataByKey) MarshalToSizedBuffer 

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

func (*FindRankDataByKey) ProtoMessage 

func (*FindRankDataByKey) ProtoMessage()

func (*FindRankDataByKey) Reset 

func (m *FindRankDataByKey) Reset()

func (*FindRankDataByKey) Size 

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

func (*FindRankDataByKey) String 

func (m *FindRankDataByKey) String() string

func (*FindRankDataByKey) Unmarshal 

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

func (*FindRankDataByKey) XXX_DiscardUnknown 

func (m *FindRankDataByKey) XXX_DiscardUnknown()

func (*FindRankDataByKey) XXX_Marshal 

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

func (*FindRankDataByKey) XXX_Merge 

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

func (*FindRankDataByKey) XXX_Size 

func (m *FindRankDataByKey) XXX_Size() int

func (*FindRankDataByKey) XXX_Unmarshal 

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

type FindRankDataByRank 

type FindRankDataByRank struct {
	RankId               uint64   `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`
	Rank                 uint64   `protobuf:"varint,2,opt,name=Rank,proto3" json:"Rank,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FindRankDataByRank 查找排行信息

func (*FindRankDataByRank) Descriptor 

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

func (*FindRankDataByRank) GetRank 

func (m *FindRankDataByRank) GetRank() uint64

func (*FindRankDataByRank) GetRankId 

func (m *FindRankDataByRank) GetRankId() uint64

func (*FindRankDataByRank) Marshal 

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

func (*FindRankDataByRank) MarshalTo 

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

func (*FindRankDataByRank) MarshalToSizedBuffer 

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

func (*FindRankDataByRank) ProtoMessage 

func (*FindRankDataByRank) ProtoMessage()

func (*FindRankDataByRank) Reset 

func (m *FindRankDataByRank) Reset()

func (*FindRankDataByRank) Size 

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

func (*FindRankDataByRank) String 

func (m *FindRankDataByRank) String() string

func (*FindRankDataByRank) Unmarshal 

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

func (*FindRankDataByRank) XXX_DiscardUnknown 

func (m *FindRankDataByRank) XXX_DiscardUnknown()

func (*FindRankDataByRank) XXX_Marshal 

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

func (*FindRankDataByRank) XXX_Merge 

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

func (*FindRankDataByRank) XXX_Size 

func (m *FindRankDataByRank) XXX_Size() int

func (*FindRankDataByRank) XXX_Unmarshal 

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

type FindRankDataList 

type FindRankDataList struct {
	RankId               uint64   `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`
	StartRank            uint64   `protobuf:"varint,2,opt,name=StartRank,proto3" json:"StartRank,omitempty"`
	Count                uint64   `protobuf:"varint,3,opt,name=Count,proto3" json:"Count,omitempty"`
	Key                  uint64   `protobuf:"varint,4,opt,name=Key,proto3" json:"Key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

FindRankDataList 查找排行信息

func (*FindRankDataList) Descriptor 

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

func (*FindRankDataList) GetCount 

func (m *FindRankDataList) GetCount() uint64

func (*FindRankDataList) GetKey 

func (m *FindRankDataList) GetKey() uint64

func (*FindRankDataList) GetRankId 

func (m *FindRankDataList) GetRankId() uint64

func (*FindRankDataList) GetStartRank 

func (m *FindRankDataList) GetStartRank() uint64

func (*FindRankDataList) Marshal 

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

func (*FindRankDataList) MarshalTo 

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

func (*FindRankDataList) MarshalToSizedBuffer 

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

func (*FindRankDataList) ProtoMessage 

func (*FindRankDataList) ProtoMessage()

func (*FindRankDataList) Reset 

func (m *FindRankDataList) Reset()

func (*FindRankDataList) Size 

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

func (*FindRankDataList) String 

func (m *FindRankDataList) String() string

func (*FindRankDataList) Unmarshal 

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

func (*FindRankDataList) XXX_DiscardUnknown 

func (m *FindRankDataList) XXX_DiscardUnknown()

func (*FindRankDataList) XXX_Marshal 

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

func (*FindRankDataList) XXX_Merge 

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

func (*FindRankDataList) XXX_Size 

func (m *FindRankDataList) XXX_Size() int

func (*FindRankDataList) XXX_Unmarshal 

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

type FuncRpcClient 

type FuncRpcClient func(nodeId int, serviceMethod string, client []*Client) (error, int)

type FuncRpcServer 

type FuncRpcServer func() *Server

type GoGoPBProcessor 

type GoGoPBProcessor struct {
}

func (*GoGoPBProcessor) Clone 

func (slf *GoGoPBProcessor) Clone(src interface{}) (interface{}, error)

func (*GoGoPBProcessor) GetProcessorType 

func (slf *GoGoPBProcessor) GetProcessorType() RpcProcessorType

func (*GoGoPBProcessor) IsParse 

func (slf *GoGoPBProcessor) IsParse(param interface{}) bool

func (*GoGoPBProcessor) MakeRpcRequest 

func (slf *GoGoPBProcessor) MakeRpcRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, inParam []byte) IRpcRequestData

func (*GoGoPBProcessor) MakeRpcResponse 

func (slf *GoGoPBProcessor) MakeRpcResponse(seq uint64, err RpcError, reply []byte) IRpcResponseData

func (*GoGoPBProcessor) Marshal 

func (slf *GoGoPBProcessor) Marshal(v interface{}) ([]byte, error)

func (*GoGoPBProcessor) ReleaseRpcRequest 

func (slf *GoGoPBProcessor) ReleaseRpcRequest(rpcRequestData IRpcRequestData)

func (*GoGoPBProcessor) ReleaseRpcResponse 

func (slf *GoGoPBProcessor) ReleaseRpcResponse(rpcResponseData IRpcResponseData)

func (*GoGoPBProcessor) Unmarshal 

func (slf *GoGoPBProcessor) Unmarshal(data []byte, msg interface{}) error

type GoGoPBRpcRequestData 

type GoGoPBRpcRequestData struct {
	Seq                  uint64   `protobuf:"varint,1,opt,name=Seq,proto3" json:"Seq,omitempty"`
	RpcMethodId          uint32   `protobuf:"varint,2,opt,name=RpcMethodId,proto3" json:"RpcMethodId,omitempty"`
	ServiceMethod        string   `protobuf:"bytes,3,opt,name=ServiceMethod,proto3" json:"ServiceMethod,omitempty"`
	NoReply              bool     `protobuf:"varint,4,opt,name=NoReply,proto3" json:"NoReply,omitempty"`
	InParam              []byte   `protobuf:"bytes,5,opt,name=InParam,proto3" json:"InParam,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GoGoPBRpcRequestData) Descriptor 

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

func (*GoGoPBRpcRequestData) GetInParam 

func (m *GoGoPBRpcRequestData) GetInParam() []byte

func (*GoGoPBRpcRequestData) GetNoReply 

func (m *GoGoPBRpcRequestData) GetNoReply() bool

func (*GoGoPBRpcRequestData) GetRpcMethodId 

func (m *GoGoPBRpcRequestData) GetRpcMethodId() uint32

func (*GoGoPBRpcRequestData) GetSeq 

func (m *GoGoPBRpcRequestData) GetSeq() uint64

func (*GoGoPBRpcRequestData) GetServiceMethod 

func (m *GoGoPBRpcRequestData) GetServiceMethod() string

func (*GoGoPBRpcRequestData) IsNoReply 

func (slf *GoGoPBRpcRequestData) IsNoReply() bool

func (*GoGoPBRpcRequestData) MakeRequest 

func (slf *GoGoPBRpcRequestData) MakeRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, inParam []byte) *GoGoPBRpcRequestData

func (*GoGoPBRpcRequestData) Marshal 

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

func (*GoGoPBRpcRequestData) MarshalTo 

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

func (*GoGoPBRpcRequestData) MarshalToSizedBuffer 

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

func (*GoGoPBRpcRequestData) ProtoMessage 

func (*GoGoPBRpcRequestData) ProtoMessage()

func (*GoGoPBRpcRequestData) Reset 

func (m *GoGoPBRpcRequestData) Reset()

func (*GoGoPBRpcRequestData) Size 

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

func (*GoGoPBRpcRequestData) String 

func (m *GoGoPBRpcRequestData) String() string

func (*GoGoPBRpcRequestData) Unmarshal 

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

func (*GoGoPBRpcRequestData) XXX_DiscardUnknown 

func (m *GoGoPBRpcRequestData) XXX_DiscardUnknown()

func (*GoGoPBRpcRequestData) XXX_Marshal 

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

func (*GoGoPBRpcRequestData) XXX_Merge 

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

func (*GoGoPBRpcRequestData) XXX_Size 

func (m *GoGoPBRpcRequestData) XXX_Size() int

func (*GoGoPBRpcRequestData) XXX_Unmarshal 

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

type GoGoPBRpcResponseData 

type GoGoPBRpcResponseData struct {
	Seq                  uint64   `protobuf:"varint,1,opt,name=Seq,proto3" json:"Seq,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	Reply                []byte   `protobuf:"bytes,3,opt,name=Reply,proto3" json:"Reply,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GoGoPBRpcResponseData) Descriptor 

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

func (*GoGoPBRpcResponseData) GetErr 

func (slf *GoGoPBRpcResponseData) GetErr() *RpcError

func (*GoGoPBRpcResponseData) GetError 

func (m *GoGoPBRpcResponseData) GetError() string

func (*GoGoPBRpcResponseData) GetReply 

func (m *GoGoPBRpcResponseData) GetReply() []byte

func (*GoGoPBRpcResponseData) GetSeq 

func (m *GoGoPBRpcResponseData) GetSeq() uint64

func (*GoGoPBRpcResponseData) MakeRespone 

func (slf *GoGoPBRpcResponseData) MakeRespone(seq uint64, err RpcError, reply []byte) *GoGoPBRpcResponseData

func (*GoGoPBRpcResponseData) Marshal 

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

func (*GoGoPBRpcResponseData) MarshalTo 

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

func (*GoGoPBRpcResponseData) MarshalToSizedBuffer 

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

func (*GoGoPBRpcResponseData) ProtoMessage 

func (*GoGoPBRpcResponseData) ProtoMessage()

func (*GoGoPBRpcResponseData) Reset 

func (m *GoGoPBRpcResponseData) Reset()

func (*GoGoPBRpcResponseData) Size 

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

func (*GoGoPBRpcResponseData) String 

func (m *GoGoPBRpcResponseData) String() string

func (*GoGoPBRpcResponseData) Unmarshal 

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

func (*GoGoPBRpcResponseData) XXX_DiscardUnknown 

func (m *GoGoPBRpcResponseData) XXX_DiscardUnknown()

func (*GoGoPBRpcResponseData) XXX_Marshal 

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

func (*GoGoPBRpcResponseData) XXX_Merge 

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

func (*GoGoPBRpcResponseData) XXX_Size 

func (m *GoGoPBRpcResponseData) XXX_Size() int

func (*GoGoPBRpcResponseData) XXX_Unmarshal 

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

type IDiscoveryServiceListener 

type IDiscoveryServiceListener interface {
	OnDiscoveryService(nodeId int, serviceName []string)
	OnUnDiscoveryService(nodeId int, serviceName []string)
}

type INodeListener 

type INodeListener interface {
	OnNodeConnected(nodeId int)
	OnNodeDisconnect(nodeId int)
}

type IRealClient 

type IRealClient interface {
	SetConn(conn *network.TCPConn)
	Close(waitDone bool)

	AsyncCall(rpcHandler IRpcHandler, serviceMethod string, callback reflect.Value, args interface{}, replyParam interface{}) error
	Go(rpcHandler IRpcHandler, noReply bool, serviceMethod string, args interface{}, reply interface{}) *Call
	RawGo(rpcHandler IRpcHandler, processor IRpcProcessor, noReply bool, rpcMethodId uint32, serviceMethod string, rawArgs []byte, reply interface{}) *Call
	IsConnected() bool

	Run()
	OnClose()
}

type IRpcHandler 

type IRpcHandler interface {
	IRpcHandlerChannel
	GetName() string
	InitRpcHandler(rpcHandler IRpcHandler, getClientFun FuncRpcClient, getServerFun FuncRpcServer, rpcHandlerChannel IRpcHandlerChannel)
	GetRpcHandler() IRpcHandler
	HandlerRpcRequest(request *RpcRequest)
	HandlerRpcResponseCB(call *Call)
	CallMethod(client *Client, ServiceMethod string, param interface{}, callBack reflect.Value, reply interface{}) error
	AsyncCall(serviceMethod string, args interface{}, callback interface{}) error
	Call(serviceMethod string, args interface{}, reply interface{}) error
	Go(serviceMethod string, args interface{}) error
	AsyncCallNode(nodeId int, serviceMethod string, args interface{}, callback interface{}) error
	CallNode(nodeId int, serviceMethod string, args interface{}, reply interface{}) error
	GoNode(nodeId int, serviceMethod string, args interface{}) error
	RawGoNode(rpcProcessorType RpcProcessorType, nodeId int, rpcMethodId uint32, serviceName string, rawArgs []byte) error
	CastGo(serviceMethod string, args interface{}) error
	IsSingleCoroutine() bool
	UnmarshalInParam(rpcProcessor IRpcProcessor, serviceMethod string, rawRpcMethodId uint32, inParam []byte) (interface{}, error)
	GetRpcServer() FuncRpcServer
}

type IRpcHandlerChannel 

type IRpcHandlerChannel interface {
	PushRpcResponse(call *Call) error
	PushRpcRequest(rpcRequest *RpcRequest) error
}

type IRpcProcessor 

type IRpcProcessor interface {
	Clone(src interface{}) (interface{}, error)
	Marshal(v interface{}) ([]byte, error) //b表示自定义缓冲区，可以填nil，由系统自动分配
	Unmarshal(data []byte, v interface{}) error
	MakeRpcRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, inParam []byte) IRpcRequestData
	MakeRpcResponse(seq uint64, err RpcError, reply []byte) IRpcResponseData

	ReleaseRpcRequest(rpcRequestData IRpcRequestData)
	ReleaseRpcResponse(rpcRequestData IRpcResponseData)
	IsParse(param interface{}) bool //是否可解析
	GetProcessorType() RpcProcessorType
}

func GetProcessor 

func GetProcessor(processorType uint8) IRpcProcessor

type IRpcRequestData 

type IRpcRequestData interface {
	GetSeq() uint64
	GetServiceMethod() string
	GetInParam() []byte
	IsNoReply() bool
	GetRpcMethodId() uint32
}

type IRpcResponseData 

type IRpcResponseData interface {
	GetSeq() uint64
	GetErr() *RpcError
	GetReply() []byte
}

type IncreaseRankData 

type IncreaseRankData struct {
	RankId                  uint64                  `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`
	Key                     uint64                  `protobuf:"varint,2,opt,name=Key,proto3" json:"Key,omitempty"`
	Extend                  []*ExtendIncData        `protobuf:"bytes,3,rep,name=Extend,proto3" json:"Extend,omitempty"`
	IncreaseSortData        []int64                 `protobuf:"varint,4,rep,packed,name=IncreaseSortData,proto3" json:"IncreaseSortData,omitempty"`
	SetSortAndExtendData    []*SetSortAndExtendData `protobuf:"bytes,5,rep,name=SetSortAndExtendData,proto3" json:"SetSortAndExtendData,omitempty"`
	ReturnRankData          bool                    `protobuf:"varint,6,opt,name=ReturnRankData,proto3" json:"ReturnRankData,omitempty"`
	InsertDataOnNonExistent bool                    `protobuf:"varint,7,opt,name=InsertDataOnNonExistent,proto3" json:"InsertDataOnNonExistent,omitempty"`
	InitData                []byte                  `protobuf:"bytes,8,opt,name=InitData,proto3" json:"InitData,omitempty"`
	InitSortData            []int64                 `protobuf:"varint,9,rep,packed,name=InitSortData,proto3" json:"InitSortData,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}                `json:"-"`
	XXX_unrecognized        []byte                  `json:"-"`
	XXX_sizecache           int32                   `json:"-"`
}

自增值

func (*IncreaseRankData) Descriptor 

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

func (*IncreaseRankData) GetExtend 

func (m *IncreaseRankData) GetExtend() []*ExtendIncData

func (*IncreaseRankData) GetIncreaseSortData 

func (m *IncreaseRankData) GetIncreaseSortData() []int64

func (*IncreaseRankData) GetInitData 

func (m *IncreaseRankData) GetInitData() []byte

func (*IncreaseRankData) GetInitSortData 

func (m *IncreaseRankData) GetInitSortData() []int64

func (*IncreaseRankData) GetInsertDataOnNonExistent 

func (m *IncreaseRankData) GetInsertDataOnNonExistent() bool

func (*IncreaseRankData) GetKey 

func (m *IncreaseRankData) GetKey() uint64

func (*IncreaseRankData) GetRankId 

func (m *IncreaseRankData) GetRankId() uint64

func (*IncreaseRankData) GetReturnRankData 

func (m *IncreaseRankData) GetReturnRankData() bool

func (*IncreaseRankData) GetSetSortAndExtendData 

func (m *IncreaseRankData) GetSetSortAndExtendData() []*SetSortAndExtendData

func (*IncreaseRankData) Marshal 

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

func (*IncreaseRankData) MarshalTo 

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

func (*IncreaseRankData) MarshalToSizedBuffer 

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

func (*IncreaseRankData) ProtoMessage 

func (*IncreaseRankData) ProtoMessage()

func (*IncreaseRankData) Reset 

func (m *IncreaseRankData) Reset()

func (*IncreaseRankData) Size 

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

func (*IncreaseRankData) String 

func (m *IncreaseRankData) String() string

func (*IncreaseRankData) Unmarshal 

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

func (*IncreaseRankData) XXX_DiscardUnknown 

func (m *IncreaseRankData) XXX_DiscardUnknown()

func (*IncreaseRankData) XXX_Marshal 

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

func (*IncreaseRankData) XXX_Merge 

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

func (*IncreaseRankData) XXX_Size 

func (m *IncreaseRankData) XXX_Size() int

func (*IncreaseRankData) XXX_Unmarshal 

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

type IncreaseRankDataRet 

type IncreaseRankDataRet struct {
	PosData              *RankPosData `protobuf:"bytes,1,opt,name=PosData,proto3" json:"PosData,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*IncreaseRankDataRet) Descriptor 

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

func (*IncreaseRankDataRet) GetPosData 

func (m *IncreaseRankDataRet) GetPosData() *RankPosData

func (*IncreaseRankDataRet) Marshal 

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

func (*IncreaseRankDataRet) MarshalTo 

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

func (*IncreaseRankDataRet) MarshalToSizedBuffer 

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

func (*IncreaseRankDataRet) ProtoMessage 

func (*IncreaseRankDataRet) ProtoMessage()

func (*IncreaseRankDataRet) Reset 

func (m *IncreaseRankDataRet) Reset()

func (*IncreaseRankDataRet) Size 

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

func (*IncreaseRankDataRet) String 

func (m *IncreaseRankDataRet) String() string

func (*IncreaseRankDataRet) Unmarshal 

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

func (*IncreaseRankDataRet) XXX_DiscardUnknown 

func (m *IncreaseRankDataRet) XXX_DiscardUnknown()

func (*IncreaseRankDataRet) XXX_Marshal 

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

func (*IncreaseRankDataRet) XXX_Merge 

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

func (*IncreaseRankDataRet) XXX_Size 

func (m *IncreaseRankDataRet) XXX_Size() int

func (*IncreaseRankDataRet) XXX_Unmarshal 

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

type JsonProcessor 

type JsonProcessor struct {
}

func (*JsonProcessor) Clone 

func (jsonProcessor *JsonProcessor) Clone(src interface{}) (interface{}, error)

func (*JsonProcessor) GetProcessorType 

func (jsonProcessor *JsonProcessor) GetProcessorType() RpcProcessorType

func (*JsonProcessor) IsParse 

func (jsonProcessor *JsonProcessor) IsParse(param interface{}) bool

func (*JsonProcessor) MakeRpcRequest 

func (jsonProcessor *JsonProcessor) MakeRpcRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, inParam []byte) IRpcRequestData

func (*JsonProcessor) MakeRpcResponse 

func (jsonProcessor *JsonProcessor) MakeRpcResponse(seq uint64, err RpcError, reply []byte) IRpcResponseData

func (*JsonProcessor) Marshal 

func (jsonProcessor *JsonProcessor) Marshal(v interface{}) ([]byte, error)

func (*JsonProcessor) ReleaseRpcRequest 

func (jsonProcessor *JsonProcessor) ReleaseRpcRequest(rpcRequestData IRpcRequestData)

func (*JsonProcessor) ReleaseRpcResponse 

func (jsonProcessor *JsonProcessor) ReleaseRpcResponse(rpcResponseData IRpcResponseData)

func (*JsonProcessor) Unmarshal 

func (jsonProcessor *JsonProcessor) Unmarshal(data []byte, v interface{}) error

type JsonRpcRequestData 

type JsonRpcRequestData struct {
	//packhead
	Seq uint64 // sequence number chosen by client

	ServiceMethod string // format: "Service.Method"
	NoReply       bool   //是否需要返回
	//packbody
	InParam []byte
	// contains filtered or unexported fields
}

func (*JsonRpcRequestData) GetInParam 

func (jsonRpcRequestData *JsonRpcRequestData) GetInParam() []byte

func (*JsonRpcRequestData) GetRpcMethodId 

func (jsonRpcRequestData *JsonRpcRequestData) GetRpcMethodId() uint32

func (*JsonRpcRequestData) GetSeq 

func (jsonRpcRequestData *JsonRpcRequestData) GetSeq() uint64

func (*JsonRpcRequestData) GetServiceMethod 

func (jsonRpcRequestData *JsonRpcRequestData) GetServiceMethod() string

func (*JsonRpcRequestData) IsNoReply 

func (jsonRpcRequestData *JsonRpcRequestData) IsNoReply() bool

type JsonRpcResponseData 

type JsonRpcResponseData struct {
	//head
	Seq uint64 // sequence number chosen by client
	Err string

	//returns
	Reply []byte
}

func (*JsonRpcResponseData) GetErr 

func (jsonRpcResponseData *JsonRpcResponseData) GetErr() *RpcError

func (*JsonRpcResponseData) GetReply 

func (jsonRpcResponseData *JsonRpcResponseData) GetReply() []byte

func (*JsonRpcResponseData) GetSeq 

func (jsonRpcResponseData *JsonRpcResponseData) GetSeq() uint64

type LClient 

type LClient struct {
	// contains filtered or unexported fields
}

本结点的Client

func (*LClient) AsyncCall 

func (lc *LClient) AsyncCall(rpcHandler IRpcHandler, serviceMethod string, callback reflect.Value, args interface{}, reply interface{}) error

func (*LClient) Close 

func (lc *LClient) Close(waitDone bool)

func (*LClient) Go 

func (lc *LClient) Go(rpcHandler IRpcHandler, noReply bool, serviceMethod string, args interface{}, reply interface{}) *Call

func (*LClient) IsConnected 

func (lc *LClient) IsConnected() bool

func (*LClient) Lock 

func (rc *LClient) Lock()

func (*LClient) OnClose 

func (lc *LClient) OnClose()

func (*LClient) RawGo 

func (rc *LClient) RawGo(rpcHandler IRpcHandler, processor IRpcProcessor, noReply bool, rpcMethodId uint32, serviceName string, rawArgs []byte, reply interface{}) *Call

func (*LClient) Run 

func (lc *LClient) Run()

func (*LClient) SetConn 

func (lc *LClient) SetConn(conn *network.TCPConn)

func (*LClient) Unlock 

func (rc *LClient) Unlock()

type NodeInfo 

type NodeInfo struct {
	NodeId               int32    `protobuf:"varint,1,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	NodeName             string   `protobuf:"bytes,2,opt,name=NodeName,proto3" json:"NodeName,omitempty"`
	ListenAddr           string   `protobuf:"bytes,3,opt,name=ListenAddr,proto3" json:"ListenAddr,omitempty"`
	MaxRpcParamLen       uint32   `protobuf:"varint,4,opt,name=MaxRpcParamLen,proto3" json:"MaxRpcParamLen,omitempty"`
	Private              bool     `protobuf:"varint,5,opt,name=Private,proto3" json:"Private,omitempty"`
	PublicServiceList    []string `protobuf:"bytes,6,rep,name=PublicServiceList,proto3" json:"PublicServiceList,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetListenAddr 

func (m *NodeInfo) GetListenAddr() string

func (*NodeInfo) GetMaxRpcParamLen 

func (m *NodeInfo) GetMaxRpcParamLen() uint32

func (*NodeInfo) GetNodeId 

func (m *NodeInfo) GetNodeId() int32

func (*NodeInfo) GetNodeName 

func (m *NodeInfo) GetNodeName() string

func (*NodeInfo) GetPrivate 

func (m *NodeInfo) GetPrivate() bool

func (*NodeInfo) GetPublicServiceList 

func (m *NodeInfo) GetPublicServiceList() []string

func (*NodeInfo) Marshal 

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

func (*NodeInfo) MarshalTo 

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

func (*NodeInfo) MarshalToSizedBuffer 

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

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size 

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

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal 

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

func (*NodeInfo) XXX_DiscardUnknown 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal 

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

func (*NodeInfo) XXX_Merge 

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

func (*NodeInfo) XXX_Size 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal 

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

type RClient 

type RClient struct {
	network.TCPClient

	TriggerRpcConnEvent
	// contains filtered or unexported fields
}

跨结点连接的Client

func (*RClient) AsyncCall 

func (rc *RClient) AsyncCall(rpcHandler IRpcHandler, serviceMethod string, callback reflect.Value, args interface{}, replyParam interface{}) error

func (*RClient) Close 

func (rc *RClient) Close(waitDone bool)

func (*RClient) GetConn 

func (rc *RClient) GetConn() *network.TCPConn

func (*RClient) Go 

func (rc *RClient) Go(rpcHandler IRpcHandler, noReply bool, serviceMethod string, args interface{}, reply interface{}) *Call

func (*RClient) IsConnected 

func (rc *RClient) IsConnected() bool

func (*RClient) OnClose 

func (rc *RClient) OnClose()

func (*RClient) RawGo 

func (rc *RClient) RawGo(rpcHandler IRpcHandler, processor IRpcProcessor, noReply bool, rpcMethodId uint32, serviceMethod string, rawArgs []byte, reply interface{}) *Call

func (*RClient) Run 

func (rc *RClient) Run()

func (*RClient) SetConn 

func (rc *RClient) SetConn(conn *network.TCPConn)

type RankData 

type RankData struct {
	Key                  uint64           `protobuf:"varint,1,opt,name=Key,proto3" json:"Key,omitempty"`
	SortData             []int64          `protobuf:"varint,2,rep,packed,name=SortData,proto3" json:"SortData,omitempty"`
	Data                 []byte           `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	ExData               []*ExtendIncData `protobuf:"bytes,4,rep,name=ExData,proto3" json:"ExData,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

RankData 排行数据

func (*RankData) Descriptor 

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

func (*RankData) GetData 

func (m *RankData) GetData() []byte

func (*RankData) GetExData 

func (m *RankData) GetExData() []*ExtendIncData

func (*RankData) GetKey 

func (m *RankData) GetKey() uint64

func (*RankData) GetSortData 

func (m *RankData) GetSortData() []int64

func (*RankData) Marshal 

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

func (*RankData) MarshalTo 

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

func (*RankData) MarshalToSizedBuffer 

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

func (*RankData) ProtoMessage 

func (*RankData) ProtoMessage()

func (*RankData) Reset 

func (m *RankData) Reset()

func (*RankData) Size 

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

func (*RankData) String 

func (m *RankData) String() string

func (*RankData) Unmarshal 

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

func (*RankData) XXX_DiscardUnknown 

func (m *RankData) XXX_DiscardUnknown()

func (*RankData) XXX_Marshal 

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

func (*RankData) XXX_Merge 

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

func (*RankData) XXX_Size 

func (m *RankData) XXX_Size() int

func (*RankData) XXX_Unmarshal 

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

type RankDataList 

type RankDataList struct {
	RankDataCount        uint64         `protobuf:"varint,1,opt,name=RankDataCount,proto3" json:"RankDataCount,omitempty"`
	RankPosDataList      []*RankPosData `protobuf:"bytes,2,rep,name=RankPosDataList,proto3" json:"RankPosDataList,omitempty"`
	KeyRank              *RankPosData   `protobuf:"bytes,3,opt,name=KeyRank,proto3" json:"KeyRank,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

RankDataList

func (*RankDataList) Descriptor 

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

func (*RankDataList) GetKeyRank 

func (m *RankDataList) GetKeyRank() *RankPosData

func (*RankDataList) GetRankDataCount 

func (m *RankDataList) GetRankDataCount() uint64

func (*RankDataList) GetRankPosDataList 

func (m *RankDataList) GetRankPosDataList() []*RankPosData

func (*RankDataList) Marshal 

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

func (*RankDataList) MarshalTo 

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

func (*RankDataList) MarshalToSizedBuffer 

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

func (*RankDataList) ProtoMessage 

func (*RankDataList) ProtoMessage()

func (*RankDataList) Reset 

func (m *RankDataList) Reset()

func (*RankDataList) Size 

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

func (*RankDataList) String 

func (m *RankDataList) String() string

func (*RankDataList) Unmarshal 

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

func (*RankDataList) XXX_DiscardUnknown 

func (m *RankDataList) XXX_DiscardUnknown()

func (*RankDataList) XXX_Marshal 

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

func (*RankDataList) XXX_Merge 

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

func (*RankDataList) XXX_Size 

func (m *RankDataList) XXX_Size() int

func (*RankDataList) XXX_Unmarshal 

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

type RankInfo 

type RankInfo struct {
	Key                  uint64   `protobuf:"varint,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Rank                 uint64   `protobuf:"varint,2,opt,name=Rank,proto3" json:"Rank,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RankInfo) Descriptor 

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

func (*RankInfo) GetKey 

func (m *RankInfo) GetKey() uint64

func (*RankInfo) GetRank 

func (m *RankInfo) GetRank() uint64

func (*RankInfo) Marshal 

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

func (*RankInfo) MarshalTo 

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

func (*RankInfo) MarshalToSizedBuffer 

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

func (*RankInfo) ProtoMessage 

func (*RankInfo) ProtoMessage()

func (*RankInfo) Reset 

func (m *RankInfo) Reset()

func (*RankInfo) Size 

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

func (*RankInfo) String 

func (m *RankInfo) String() string

func (*RankInfo) Unmarshal 

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

func (*RankInfo) XXX_DiscardUnknown 

func (m *RankInfo) XXX_DiscardUnknown()

func (*RankInfo) XXX_Marshal 

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

func (*RankInfo) XXX_Merge 

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

func (*RankInfo) XXX_Size 

func (m *RankInfo) XXX_Size() int

func (*RankInfo) XXX_Unmarshal 

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

type RankList 

type RankList struct {
	RankId               uint64   `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`
	RankName             string   `protobuf:"bytes,2,opt,name=RankName,proto3" json:"RankName,omitempty"`
	SkipListLevel        int32    `protobuf:"varint,3,opt,name=SkipListLevel,proto3" json:"SkipListLevel,omitempty"`
	IsDec                bool     `protobuf:"varint,4,opt,name=IsDec,proto3" json:"IsDec,omitempty"`
	MaxRank              uint64   `protobuf:"varint,5,opt,name=MaxRank,proto3" json:"MaxRank,omitempty"`
	ExpireMs             int64    `protobuf:"varint,6,opt,name=ExpireMs,proto3" json:"ExpireMs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RankList 排行榜数据

func (*RankList) Descriptor 

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

func (*RankList) GetExpireMs 

func (m *RankList) GetExpireMs() int64

func (*RankList) GetIsDec 

func (m *RankList) GetIsDec() bool

func (*RankList) GetMaxRank 

func (m *RankList) GetMaxRank() uint64

func (*RankList) GetRankId 

func (m *RankList) GetRankId() uint64

func (*RankList) GetRankName 

func (m *RankList) GetRankName() string

func (*RankList) GetSkipListLevel 

func (m *RankList) GetSkipListLevel() int32

func (*RankList) Marshal 

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

func (*RankList) MarshalTo 

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

func (*RankList) MarshalToSizedBuffer 

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

func (*RankList) ProtoMessage 

func (*RankList) ProtoMessage()

func (*RankList) Reset 

func (m *RankList) Reset()

func (*RankList) Size 

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

func (*RankList) String 

func (m *RankList) String() string

func (*RankList) Unmarshal 

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

func (*RankList) XXX_DiscardUnknown 

func (m *RankList) XXX_DiscardUnknown()

func (*RankList) XXX_Marshal 

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

func (*RankList) XXX_Merge 

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

func (*RankList) XXX_Size 

func (m *RankList) XXX_Size() int

func (*RankList) XXX_Unmarshal 

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

type RankPosData 

type RankPosData struct {
	Key                  uint64   `protobuf:"varint,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Rank                 uint64   `protobuf:"varint,2,opt,name=Rank,proto3" json:"Rank,omitempty"`
	SortData             []int64  `protobuf:"varint,3,rep,packed,name=SortData,proto3" json:"SortData,omitempty"`
	Data                 []byte   `protobuf:"bytes,4,opt,name=Data,proto3" json:"Data,omitempty"`
	ExtendData           []int64  `protobuf:"varint,5,rep,packed,name=ExtendData,proto3" json:"ExtendData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RankPosData 排行数据——查询返回

func (*RankPosData) Descriptor 

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

func (*RankPosData) GetData 

func (m *RankPosData) GetData() []byte

func (*RankPosData) GetExtendData 

func (m *RankPosData) GetExtendData() []int64

func (*RankPosData) GetKey 

func (m *RankPosData) GetKey() uint64

func (*RankPosData) GetRank 

func (m *RankPosData) GetRank() uint64

func (*RankPosData) GetSortData 

func (m *RankPosData) GetSortData() []int64

func (*RankPosData) Marshal 

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

func (*RankPosData) MarshalTo 

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

func (*RankPosData) MarshalToSizedBuffer 

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

func (*RankPosData) ProtoMessage 

func (*RankPosData) ProtoMessage()

func (*RankPosData) Reset 

func (m *RankPosData) Reset()

func (*RankPosData) Size 

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

func (*RankPosData) String 

func (m *RankPosData) String() string

func (*RankPosData) Unmarshal 

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

func (*RankPosData) XXX_DiscardUnknown 

func (m *RankPosData) XXX_DiscardUnknown()

func (*RankPosData) XXX_Marshal 

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

func (*RankPosData) XXX_Merge 

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

func (*RankPosData) XXX_Size 

func (m *RankPosData) XXX_Size() int

func (*RankPosData) XXX_Unmarshal 

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

type RankResult 

type RankResult struct {
	AddCount             int32       `protobuf:"varint,1,opt,name=AddCount,proto3" json:"AddCount,omitempty"`
	ModifyCount          int32       `protobuf:"varint,2,opt,name=ModifyCount,proto3" json:"ModifyCount,omitempty"`
	RemoveCount          int32       `protobuf:"varint,3,opt,name=RemoveCount,proto3" json:"RemoveCount,omitempty"`
	NewRank              []*RankInfo `protobuf:"bytes,4,rep,name=NewRank,proto3" json:"NewRank,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

RankResult

func (*RankResult) Descriptor 

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

func (*RankResult) GetAddCount 

func (m *RankResult) GetAddCount() int32

func (*RankResult) GetModifyCount 

func (m *RankResult) GetModifyCount() int32

func (*RankResult) GetNewRank 

func (m *RankResult) GetNewRank() []*RankInfo

func (*RankResult) GetRemoveCount 

func (m *RankResult) GetRemoveCount() int32

func (*RankResult) Marshal 

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

func (*RankResult) MarshalTo 

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

func (*RankResult) MarshalToSizedBuffer 

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

func (*RankResult) ProtoMessage 

func (*RankResult) ProtoMessage()

func (*RankResult) Reset 

func (m *RankResult) Reset()

func (*RankResult) Size 

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

func (*RankResult) String 

func (m *RankResult) String() string

func (*RankResult) Unmarshal 

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

func (*RankResult) XXX_DiscardUnknown 

func (m *RankResult) XXX_DiscardUnknown()

func (*RankResult) XXX_Marshal 

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

func (*RankResult) XXX_Merge 

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

func (*RankResult) XXX_Size 

func (m *RankResult) XXX_Size() int

func (*RankResult) XXX_Unmarshal 

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

type RawRpcCallBack 

type RawRpcCallBack func(rawData []byte)

type RequestHandler 

type RequestHandler func(Returns interface{}, Err RpcError)

type Responder 

type Responder = RequestHandler

func (*Responder) IsInvalid 

func (r *Responder) IsInvalid() bool

type RpcAgent 

type RpcAgent struct {
	// contains filtered or unexported fields
}

func (*RpcAgent) Close 

func (agent *RpcAgent) Close()

func (*RpcAgent) Destroy 

func (agent *RpcAgent) Destroy()

func (*RpcAgent) LocalAddr 

func (agent *RpcAgent) LocalAddr() net.Addr

func (*RpcAgent) OnClose 

func (agent *RpcAgent) OnClose()

func (*RpcAgent) OnDestroy 

func (agent *RpcAgent) OnDestroy()

func (*RpcAgent) RemoteAddr 

func (agent *RpcAgent) RemoteAddr() net.Addr

func (*RpcAgent) Run 

func (agent *RpcAgent) Run()

func (*RpcAgent) WriteMsg 

func (agent *RpcAgent) WriteMsg(msg interface{})

func (*RpcAgent) WriteResponse 

func (agent *RpcAgent) WriteResponse(processor IRpcProcessor, serviceMethod string, seq uint64, reply interface{}, rpcError RpcError)

type RpcError 

type RpcError string
var NilError RpcError

func ConvertError 

func ConvertError(e error) RpcError

func (RpcError) Error 

func (e RpcError) Error() string

type RpcHandleFinder 

type RpcHandleFinder interface {
	FindRpcHandler(serviceMethod string) IRpcHandler
}

type RpcHandler 

type RpcHandler struct {
	IRpcHandlerChannel
	// contains filtered or unexported fields
}

func (*RpcHandler) AsyncCall 

func (handler *RpcHandler) AsyncCall(serviceMethod string, args interface{}, callback interface{}) error

func (*RpcHandler) AsyncCallNode 

func (handler *RpcHandler) AsyncCallNode(nodeId int, serviceMethod string, args interface{}, callback interface{}) error

func (*RpcHandler) Call 

func (handler *RpcHandler) Call(serviceMethod string, args interface{}, reply interface{}) error

func (*RpcHandler) CallMethod 

func (handler *RpcHandler) CallMethod(client *Client, ServiceMethod string, param interface{}, callBack reflect.Value, reply interface{}) error

func (*RpcHandler) CallNode 

func (handler *RpcHandler) CallNode(nodeId int, serviceMethod string, args interface{}, reply interface{}) error

func (*RpcHandler) CastGo 

func (handler *RpcHandler) CastGo(serviceMethod string, args interface{}) error

func (*RpcHandler) GetName 

func (handler *RpcHandler) GetName() string

func (*RpcHandler) GetRpcHandler 

func (handler *RpcHandler) GetRpcHandler() IRpcHandler

func (*RpcHandler) GetRpcServer 

func (handler *RpcHandler) GetRpcServer() FuncRpcServer

func (*RpcHandler) Go 

func (handler *RpcHandler) Go(serviceMethod string, args interface{}) error

func (*RpcHandler) GoNode 

func (handler *RpcHandler) GoNode(nodeId int, serviceMethod string, args interface{}) error

func (*RpcHandler) HandlerRpcRequest 

func (handler *RpcHandler) HandlerRpcRequest(request *RpcRequest)

func (*RpcHandler) HandlerRpcResponseCB 

func (handler *RpcHandler) HandlerRpcResponseCB(call *Call)

func (*RpcHandler) InitRpcHandler 

func (handler *RpcHandler) InitRpcHandler(rpcHandler IRpcHandler, getClientFun FuncRpcClient, getServerFun FuncRpcServer, rpcHandlerChannel IRpcHandlerChannel)

func (*RpcHandler) IsSingleCoroutine 

func (handler *RpcHandler) IsSingleCoroutine() bool

func (*RpcHandler) RawGoNode 

func (handler *RpcHandler) RawGoNode(rpcProcessorType RpcProcessorType, nodeId int, rpcMethodId uint32, serviceName string, rawArgs []byte) error

func (*RpcHandler) RegRawRpc 

func (handler *RpcHandler) RegRawRpc(rpcMethodId uint32, rawRpcCB RawRpcCallBack)

func (*RpcHandler) RegisterRpc 

func (handler *RpcHandler) RegisterRpc(rpcHandler IRpcHandler) error

func (*RpcHandler) UnmarshalInParam 

func (handler *RpcHandler) UnmarshalInParam(rpcProcessor IRpcProcessor, serviceMethod string, rawRpcMethodId uint32, inParam []byte) (interface{}, error)

type RpcMethodInfo 

type RpcMethodInfo struct {
	// contains filtered or unexported fields
}

type RpcProcessorType 

type RpcProcessorType uint8
const (
	RpcProcessorJson   RpcProcessorType = 0
	RpcProcessorGoGoPB RpcProcessorType = 1
)

type RpcRequest 

type RpcRequest struct {
	RpcRequestData IRpcRequestData
	// contains filtered or unexported fields
}

func MakeRpcRequest 

func MakeRpcRequest(rpcProcessor IRpcProcessor, seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, inParam []byte) *RpcRequest

func (*RpcRequest) Clear 

func (slf *RpcRequest) Clear() *RpcRequest

func (*RpcRequest) IsRef 

func (slf *RpcRequest) IsRef() bool

func (*RpcRequest) Ref 

func (slf *RpcRequest) Ref()

func (*RpcRequest) Reset 

func (slf *RpcRequest) Reset()

func (*RpcRequest) UnRef 

func (slf *RpcRequest) UnRef()

type RpcResponse 

type RpcResponse struct {
	RpcResponseData IRpcResponseData
}

func (*RpcResponse) Clear 

func (rpcResponse *RpcResponse) Clear() *RpcResponse

type Server 

type Server struct {
	// contains filtered or unexported fields
}

func (*Server) Init 

func (server *Server) Init(rpcHandleFinder RpcHandleFinder)

func (*Server) NewAgent 

func (server *Server) NewAgent(c *network.TCPConn) network.Agent

func (*Server) Start 

func (server *Server) Start(listenAddr string, maxRpcParamLen uint32)

type ServiceDiscoverReq 

type ServiceDiscoverReq struct {
	NodeInfo             *NodeInfo `protobuf:"bytes,1,opt,name=nodeInfo,proto3" json:"nodeInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Client->Master

func (*ServiceDiscoverReq) Descriptor 

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

func (*ServiceDiscoverReq) GetNodeInfo 

func (m *ServiceDiscoverReq) GetNodeInfo() *NodeInfo

func (*ServiceDiscoverReq) Marshal 

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

func (*ServiceDiscoverReq) MarshalTo 

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

func (*ServiceDiscoverReq) MarshalToSizedBuffer 

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

func (*ServiceDiscoverReq) ProtoMessage 

func (*ServiceDiscoverReq) ProtoMessage()

func (*ServiceDiscoverReq) Reset 

func (m *ServiceDiscoverReq) Reset()

func (*ServiceDiscoverReq) Size 

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

func (*ServiceDiscoverReq) String 

func (m *ServiceDiscoverReq) String() string

func (*ServiceDiscoverReq) Unmarshal 

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

func (*ServiceDiscoverReq) XXX_DiscardUnknown 

func (m *ServiceDiscoverReq) XXX_DiscardUnknown()

func (*ServiceDiscoverReq) XXX_Marshal 

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

func (*ServiceDiscoverReq) XXX_Merge 

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

func (*ServiceDiscoverReq) XXX_Size 

func (m *ServiceDiscoverReq) XXX_Size() int

func (*ServiceDiscoverReq) XXX_Unmarshal 

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

type SetSortAndExtendData 

type SetSortAndExtendData struct {
	IsSortData           bool     `protobuf:"varint,1,opt,name=IsSortData,proto3" json:"IsSortData,omitempty"`
	Pos                  int32    `protobuf:"varint,2,opt,name=Pos,proto3" json:"Pos,omitempty"`
	Data                 int64    `protobuf:"varint,3,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetSortAndExtendData) Descriptor 

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

func (*SetSortAndExtendData) GetData 

func (m *SetSortAndExtendData) GetData() int64

func (*SetSortAndExtendData) GetIsSortData 

func (m *SetSortAndExtendData) GetIsSortData() bool

func (*SetSortAndExtendData) GetPos 

func (m *SetSortAndExtendData) GetPos() int32

func (*SetSortAndExtendData) Marshal 

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

func (*SetSortAndExtendData) MarshalTo 

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

func (*SetSortAndExtendData) MarshalToSizedBuffer 

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

func (*SetSortAndExtendData) ProtoMessage 

func (*SetSortAndExtendData) ProtoMessage()

func (*SetSortAndExtendData) Reset 

func (m *SetSortAndExtendData) Reset()

func (*SetSortAndExtendData) Size 

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

func (*SetSortAndExtendData) String 

func (m *SetSortAndExtendData) String() string

func (*SetSortAndExtendData) Unmarshal 

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

func (*SetSortAndExtendData) XXX_DiscardUnknown 

func (m *SetSortAndExtendData) XXX_DiscardUnknown()

func (*SetSortAndExtendData) XXX_Marshal 

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

func (*SetSortAndExtendData) XXX_Merge 

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

func (*SetSortAndExtendData) XXX_Size 

func (m *SetSortAndExtendData) XXX_Size() int

func (*SetSortAndExtendData) XXX_Unmarshal 

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

type SubscribeDiscoverNotify 

type SubscribeDiscoverNotify struct {
	MasterNodeId         int32       `protobuf:"varint,1,opt,name=MasterNodeId,proto3" json:"MasterNodeId,omitempty"`
	IsFull               bool        `protobuf:"varint,2,opt,name=IsFull,proto3" json:"IsFull,omitempty"`
	DelNodeId            int32       `protobuf:"varint,3,opt,name=DelNodeId,proto3" json:"DelNodeId,omitempty"`
	NodeInfo             []*NodeInfo `protobuf:"bytes,4,rep,name=nodeInfo,proto3" json:"nodeInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Master->Client

func (*SubscribeDiscoverNotify) Descriptor 

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

func (*SubscribeDiscoverNotify) GetDelNodeId 

func (m *SubscribeDiscoverNotify) GetDelNodeId() int32

func (*SubscribeDiscoverNotify) GetIsFull 

func (m *SubscribeDiscoverNotify) GetIsFull() bool

func (*SubscribeDiscoverNotify) GetMasterNodeId 

func (m *SubscribeDiscoverNotify) GetMasterNodeId() int32

func (*SubscribeDiscoverNotify) GetNodeInfo 

func (m *SubscribeDiscoverNotify) GetNodeInfo() []*NodeInfo

func (*SubscribeDiscoverNotify) Marshal 

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

func (*SubscribeDiscoverNotify) MarshalTo 

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

func (*SubscribeDiscoverNotify) MarshalToSizedBuffer 

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

func (*SubscribeDiscoverNotify) ProtoMessage 

func (*SubscribeDiscoverNotify) ProtoMessage()

func (*SubscribeDiscoverNotify) Reset 

func (m *SubscribeDiscoverNotify) Reset()

func (*SubscribeDiscoverNotify) Size 

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

func (*SubscribeDiscoverNotify) String 

func (m *SubscribeDiscoverNotify) String() string

func (*SubscribeDiscoverNotify) Unmarshal 

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

func (*SubscribeDiscoverNotify) XXX_DiscardUnknown 

func (m *SubscribeDiscoverNotify) XXX_DiscardUnknown()

func (*SubscribeDiscoverNotify) XXX_Marshal 

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

func (*SubscribeDiscoverNotify) XXX_Merge 

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

func (*SubscribeDiscoverNotify) XXX_Size 

func (m *SubscribeDiscoverNotify) XXX_Size() int

func (*SubscribeDiscoverNotify) XXX_Unmarshal 

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

type SubscribeMethod 

type SubscribeMethod int32
const (
	SubscribeMethod_Method_Custom SubscribeMethod = 0
	SubscribeMethod_Method_Last   SubscribeMethod = 1
)

func (SubscribeMethod) EnumDescriptor 

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

func (SubscribeMethod) String 

func (x SubscribeMethod) String() string

type SubscribeType 

type SubscribeType int32
const (
	SubscribeType_Subscribe   SubscribeType = 0
	SubscribeType_Unsubscribe SubscribeType = 1
)

func (SubscribeType) EnumDescriptor 

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

func (SubscribeType) String 

func (x SubscribeType) String() string

type TriggerRpcConnEvent 

type TriggerRpcConnEvent func(bConnect bool, clientSeq uint32, nodeId int)

type UpdateRankData 

type UpdateRankData struct {
	RankId               uint64   `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`
	Key                  uint64   `protobuf:"varint,2,opt,name=Key,proto3" json:"Key,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

用于单独刷新排行榜数据

func (*UpdateRankData) Descriptor 

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

func (*UpdateRankData) GetData 

func (m *UpdateRankData) GetData() []byte

func (*UpdateRankData) GetKey 

func (m *UpdateRankData) GetKey() uint64

func (*UpdateRankData) GetRankId 

func (m *UpdateRankData) GetRankId() uint64

func (*UpdateRankData) Marshal 

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

func (*UpdateRankData) MarshalTo 

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

func (*UpdateRankData) MarshalToSizedBuffer 

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

func (*UpdateRankData) ProtoMessage 

func (*UpdateRankData) ProtoMessage()

func (*UpdateRankData) Reset 

func (m *UpdateRankData) Reset()

func (*UpdateRankData) Size 

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

func (*UpdateRankData) String 

func (m *UpdateRankData) String() string

func (*UpdateRankData) Unmarshal 

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

func (*UpdateRankData) XXX_DiscardUnknown 

func (m *UpdateRankData) XXX_DiscardUnknown()

func (*UpdateRankData) XXX_Marshal 

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

func (*UpdateRankData) XXX_Merge 

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

func (*UpdateRankData) XXX_Size 

func (m *UpdateRankData) XXX_Size() int

func (*UpdateRankData) XXX_Unmarshal 

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

type UpdateRankDataRet 

type UpdateRankDataRet struct {
	Ret                  bool     `protobuf:"varint,1,opt,name=Ret,proto3" json:"Ret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateRankDataRet) Descriptor 

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

func (*UpdateRankDataRet) GetRet 

func (m *UpdateRankDataRet) GetRet() bool

func (*UpdateRankDataRet) Marshal 

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

func (*UpdateRankDataRet) MarshalTo 

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

func (*UpdateRankDataRet) MarshalToSizedBuffer 

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

func (*UpdateRankDataRet) ProtoMessage 

func (*UpdateRankDataRet) ProtoMessage()

func (*UpdateRankDataRet) Reset 

func (m *UpdateRankDataRet) Reset()

func (*UpdateRankDataRet) Size 

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

func (*UpdateRankDataRet) String 

func (m *UpdateRankDataRet) String() string

func (*UpdateRankDataRet) Unmarshal 

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

func (*UpdateRankDataRet) XXX_DiscardUnknown 

func (m *UpdateRankDataRet) XXX_DiscardUnknown()

func (*UpdateRankDataRet) XXX_Marshal 

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

func (*UpdateRankDataRet) XXX_Merge 

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

func (*UpdateRankDataRet) XXX_Size 

func (m *UpdateRankDataRet) XXX_Size() int

func (*UpdateRankDataRet) XXX_Unmarshal 

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

type UpsetRankData 

type UpsetRankData struct {
	RankId               uint64      `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`
	RankDataList         []*RankData `protobuf:"bytes,2,rep,name=RankDataList,proto3" json:"RankDataList,omitempty"`
	FindNewRank          bool        `protobuf:"varint,3,opt,name=FindNewRank,proto3" json:"FindNewRank,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

UpsetRankData 更新排行榜数据

func (*UpsetRankData) Descriptor 

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

func (*UpsetRankData) GetFindNewRank 

func (m *UpsetRankData) GetFindNewRank() bool

func (*UpsetRankData) GetRankDataList 

func (m *UpsetRankData) GetRankDataList() []*RankData

func (*UpsetRankData) GetRankId 

func (m *UpsetRankData) GetRankId() uint64

func (*UpsetRankData) Marshal 

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

func (*UpsetRankData) MarshalTo 

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

func (*UpsetRankData) MarshalToSizedBuffer 

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

func (*UpsetRankData) ProtoMessage 

func (*UpsetRankData) ProtoMessage()

func (*UpsetRankData) Reset 

func (m *UpsetRankData) Reset()

func (*UpsetRankData) Size 

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

func (*UpsetRankData) String 

func (m *UpsetRankData) String() string

func (*UpsetRankData) Unmarshal 

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

func (*UpsetRankData) XXX_DiscardUnknown 

func (m *UpsetRankData) XXX_DiscardUnknown()

func (*UpsetRankData) XXX_Marshal 

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

func (*UpsetRankData) XXX_Merge 

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

func (*UpsetRankData) XXX_Size 

func (m *UpsetRankData) XXX_Size() int

func (*UpsetRankData) XXX_Unmarshal 

func (m *UpsetRankData) 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.