Versions in this module Expand all Collapse all v1 v1.0.1 Aug 3, 2023 v1.0.0 Aug 3, 2023 Changes in this version + const DefaultCheckRpcCallTimeoutInterval + const DefaultConnectInterval + const DefaultMaxCheckCallRpcCount + const DefaultMaxPendingWriteNum + const DefaultRpcConnNum + const DefaultRpcLenMsgLen + const DefaultRpcMinMsgLen + const DefaultRpcTimeout + const Default_ReadWriteDeadline + var ErrIntOverflowDynamicdiscover = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowGogorpc = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowMessagequeue = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowRank = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthDynamicdiscover = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthGogorpc = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthMessagequeue = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthRank = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupDynamicdiscover = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupGogorpc = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupMessagequeue = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupRank = fmt.Errorf("proto: unexpected end of group") + var LittleEndian bool + var SubscribeMethod_name = map[int32]string + var SubscribeMethod_value = map[string]int32 + var SubscribeType_name = map[int32]string + var SubscribeType_value = map[string]int32 + func AppendProcessor(rpcProcessor IRpcProcessor) + func GetProcessorType(param interface{}) (RpcProcessorType, IRpcProcessor) + func ReleaseCall(call *Call) + func ReleaseRpcRequest(rpcRequest *RpcRequest) + func SetCompressor(cp ICompressor) + type AddRankList struct + AddList []*RankList + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AddRankList) Descriptor() ([]byte, []int) + func (*AddRankList) ProtoMessage() + func (m *AddRankList) GetAddList() []*RankList + func (m *AddRankList) Marshal() (dAtA []byte, err error) + func (m *AddRankList) MarshalTo(dAtA []byte) (int, error) + func (m *AddRankList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AddRankList) Reset() + func (m *AddRankList) Size() (n int) + func (m *AddRankList) String() string + func (m *AddRankList) Unmarshal(dAtA []byte) error + func (m *AddRankList) XXX_DiscardUnknown() + func (m *AddRankList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AddRankList) XXX_Merge(src proto.Message) + func (m *AddRankList) XXX_Size() int + func (m *AddRankList) XXX_Unmarshal(b []byte) error + type Call struct + Err error + Reply interface{} + Response *RpcResponse + Seq uint64 + ServiceMethod string + TimeOut time.Duration + func MakeCall() *Call + func (call *Call) Clear() *Call + func (call *Call) DoError(err error) + func (call *Call) DoOK() + func (call *Call) Done() *Call + func (call *Call) IsRef() bool + func (call *Call) Ref() + func (call *Call) Reset() + func (call *Call) UnRef() + type CallTimer struct + FireTime int64 + SeqId uint64 + type CallTimerHeap struct + func (h *CallTimerHeap) AddTimer(seqId uint64, d time.Duration) + func (h *CallTimerHeap) Cancel(seq uint64) bool + func (h *CallTimerHeap) Init() + func (h *CallTimerHeap) Len() int + func (h *CallTimerHeap) Less(i, j int) bool + func (h *CallTimerHeap) Pop() any + func (h *CallTimerHeap) PopFirst() uint64 + func (h *CallTimerHeap) PopTimeout() uint64 + func (h *CallTimerHeap) Push(t any) + func (h *CallTimerHeap) Swap(i, j int) + type CancelRpc func() + type Client struct + func NewLClient(nodeId int) *Client + func NewRClient(nodeId int, addr string, maxRpcParamLen uint32, compressBytesLen int, ...) *Client + func (bc *Client) AddPending(call *Call) + func (bc *Client) FindPending(seq uint64) (pCall *Call) + func (bc *Client) RemovePending(seq uint64) *Call + func (client *Client) GetClientId() uint32 + func (client *Client) GetNodeId() int + func (client *Client) InitPending() + func (client *Client) NewClientAgent(conn *network.TCPConn) network.Agent + type DBQueuePopReq struct + CustomerId string + PopNum int32 + PopStartPos int32 + PushData []byte + QueueName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DBQueuePopReq) Descriptor() ([]byte, []int) + func (*DBQueuePopReq) ProtoMessage() + func (m *DBQueuePopReq) GetCustomerId() string + func (m *DBQueuePopReq) GetPopNum() int32 + func (m *DBQueuePopReq) GetPopStartPos() int32 + func (m *DBQueuePopReq) GetPushData() []byte + func (m *DBQueuePopReq) GetQueueName() string + func (m *DBQueuePopReq) Marshal() (dAtA []byte, err error) + func (m *DBQueuePopReq) MarshalTo(dAtA []byte) (int, error) + func (m *DBQueuePopReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DBQueuePopReq) Reset() + func (m *DBQueuePopReq) Size() (n int) + func (m *DBQueuePopReq) String() string + func (m *DBQueuePopReq) Unmarshal(dAtA []byte) error + func (m *DBQueuePopReq) XXX_DiscardUnknown() + func (m *DBQueuePopReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DBQueuePopReq) XXX_Merge(src proto.Message) + func (m *DBQueuePopReq) XXX_Size() int + func (m *DBQueuePopReq) XXX_Unmarshal(b []byte) error + type DBQueuePopRes struct + PushData [][]byte + QueueName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DBQueuePopRes) Descriptor() ([]byte, []int) + func (*DBQueuePopRes) ProtoMessage() + func (m *DBQueuePopRes) GetPushData() [][]byte + func (m *DBQueuePopRes) GetQueueName() string + func (m *DBQueuePopRes) Marshal() (dAtA []byte, err error) + func (m *DBQueuePopRes) MarshalTo(dAtA []byte) (int, error) + func (m *DBQueuePopRes) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DBQueuePopRes) Reset() + func (m *DBQueuePopRes) Size() (n int) + func (m *DBQueuePopRes) String() string + func (m *DBQueuePopRes) Unmarshal(dAtA []byte) error + func (m *DBQueuePopRes) XXX_DiscardUnknown() + func (m *DBQueuePopRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DBQueuePopRes) XXX_Merge(src proto.Message) + func (m *DBQueuePopRes) XXX_Size() int + func (m *DBQueuePopRes) XXX_Unmarshal(b []byte) error + type DBQueuePublishReq struct + PushData [][]byte + TopicName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DBQueuePublishReq) Descriptor() ([]byte, []int) + func (*DBQueuePublishReq) ProtoMessage() + func (m *DBQueuePublishReq) GetPushData() [][]byte + func (m *DBQueuePublishReq) GetTopicName() string + func (m *DBQueuePublishReq) Marshal() (dAtA []byte, err error) + func (m *DBQueuePublishReq) MarshalTo(dAtA []byte) (int, error) + func (m *DBQueuePublishReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DBQueuePublishReq) Reset() + func (m *DBQueuePublishReq) Size() (n int) + func (m *DBQueuePublishReq) String() string + func (m *DBQueuePublishReq) Unmarshal(dAtA []byte) error + func (m *DBQueuePublishReq) XXX_DiscardUnknown() + func (m *DBQueuePublishReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DBQueuePublishReq) XXX_Merge(src proto.Message) + func (m *DBQueuePublishReq) XXX_Size() int + func (m *DBQueuePublishReq) XXX_Unmarshal(b []byte) error + type DBQueuePublishRes struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DBQueuePublishRes) Descriptor() ([]byte, []int) + func (*DBQueuePublishRes) ProtoMessage() + func (m *DBQueuePublishRes) Marshal() (dAtA []byte, err error) + func (m *DBQueuePublishRes) MarshalTo(dAtA []byte) (int, error) + func (m *DBQueuePublishRes) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DBQueuePublishRes) Reset() + func (m *DBQueuePublishRes) Size() (n int) + func (m *DBQueuePublishRes) String() string + func (m *DBQueuePublishRes) Unmarshal(dAtA []byte) error + func (m *DBQueuePublishRes) XXX_DiscardUnknown() + func (m *DBQueuePublishRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DBQueuePublishRes) XXX_Merge(src proto.Message) + func (m *DBQueuePublishRes) XXX_Size() int + func (m *DBQueuePublishRes) XXX_Unmarshal(b []byte) error + type DBQueueSubscribeReq struct + CustomerId string + FromNodeId int32 + Method SubscribeMethod + OneBatchQuantity int32 + RpcMethod string + StartIndex uint64 + SubType SubscribeType + TopicName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DBQueueSubscribeReq) Descriptor() ([]byte, []int) + func (*DBQueueSubscribeReq) ProtoMessage() + func (m *DBQueueSubscribeReq) GetCustomerId() string + func (m *DBQueueSubscribeReq) GetFromNodeId() int32 + func (m *DBQueueSubscribeReq) GetMethod() SubscribeMethod + func (m *DBQueueSubscribeReq) GetOneBatchQuantity() int32 + func (m *DBQueueSubscribeReq) GetRpcMethod() string + func (m *DBQueueSubscribeReq) GetStartIndex() uint64 + func (m *DBQueueSubscribeReq) GetSubType() SubscribeType + func (m *DBQueueSubscribeReq) GetTopicName() string + func (m *DBQueueSubscribeReq) Marshal() (dAtA []byte, err error) + func (m *DBQueueSubscribeReq) MarshalTo(dAtA []byte) (int, error) + func (m *DBQueueSubscribeReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DBQueueSubscribeReq) Reset() + func (m *DBQueueSubscribeReq) Size() (n int) + func (m *DBQueueSubscribeReq) String() string + func (m *DBQueueSubscribeReq) Unmarshal(dAtA []byte) error + func (m *DBQueueSubscribeReq) XXX_DiscardUnknown() + func (m *DBQueueSubscribeReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DBQueueSubscribeReq) XXX_Merge(src proto.Message) + func (m *DBQueueSubscribeReq) XXX_Size() int + func (m *DBQueueSubscribeReq) XXX_Unmarshal(b []byte) error + type DBQueueSubscribeRes struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DBQueueSubscribeRes) Descriptor() ([]byte, []int) + func (*DBQueueSubscribeRes) ProtoMessage() + func (m *DBQueueSubscribeRes) Marshal() (dAtA []byte, err error) + func (m *DBQueueSubscribeRes) MarshalTo(dAtA []byte) (int, error) + func (m *DBQueueSubscribeRes) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DBQueueSubscribeRes) Reset() + func (m *DBQueueSubscribeRes) Size() (n int) + func (m *DBQueueSubscribeRes) String() string + func (m *DBQueueSubscribeRes) Unmarshal(dAtA []byte) error + func (m *DBQueueSubscribeRes) XXX_DiscardUnknown() + func (m *DBQueueSubscribeRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DBQueueSubscribeRes) XXX_Merge(src proto.Message) + func (m *DBQueueSubscribeRes) XXX_Size() int + func (m *DBQueueSubscribeRes) XXX_Unmarshal(b []byte) error + type DeleteByKey struct + KeyList []uint64 + RankId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteByKey) Descriptor() ([]byte, []int) + func (*DeleteByKey) ProtoMessage() + func (m *DeleteByKey) GetKeyList() []uint64 + func (m *DeleteByKey) GetRankId() uint64 + func (m *DeleteByKey) Marshal() (dAtA []byte, err error) + func (m *DeleteByKey) MarshalTo(dAtA []byte) (int, error) + func (m *DeleteByKey) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DeleteByKey) Reset() + func (m *DeleteByKey) Size() (n int) + func (m *DeleteByKey) String() string + func (m *DeleteByKey) Unmarshal(dAtA []byte) error + func (m *DeleteByKey) XXX_DiscardUnknown() + func (m *DeleteByKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteByKey) XXX_Merge(src proto.Message) + func (m *DeleteByKey) XXX_Size() int + func (m *DeleteByKey) XXX_Unmarshal(b []byte) error + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Marshal() (dAtA []byte, err error) + func (m *Empty) MarshalTo(dAtA []byte) (int, error) + func (m *Empty) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Empty) Reset() + func (m *Empty) Size() (n int) + func (m *Empty) String() string + func (m *Empty) Unmarshal(dAtA []byte) error + func (m *Empty) XXX_DiscardUnknown() + func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Empty) XXX_Merge(src proto.Message) + func (m *Empty) XXX_Size() int + func (m *Empty) XXX_Unmarshal(b []byte) error + type ExtendIncData struct + IncreaseValue int64 + InitValue int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExtendIncData) Descriptor() ([]byte, []int) + func (*ExtendIncData) ProtoMessage() + func (m *ExtendIncData) GetIncreaseValue() int64 + func (m *ExtendIncData) GetInitValue() int64 + func (m *ExtendIncData) Marshal() (dAtA []byte, err error) + func (m *ExtendIncData) MarshalTo(dAtA []byte) (int, error) + func (m *ExtendIncData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExtendIncData) Reset() + func (m *ExtendIncData) Size() (n int) + func (m *ExtendIncData) String() string + func (m *ExtendIncData) Unmarshal(dAtA []byte) error + func (m *ExtendIncData) XXX_DiscardUnknown() + func (m *ExtendIncData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExtendIncData) XXX_Merge(src proto.Message) + func (m *ExtendIncData) XXX_Size() int + func (m *ExtendIncData) XXX_Unmarshal(b []byte) error + type FindRankDataByKey struct + Key uint64 + RankId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FindRankDataByKey) Descriptor() ([]byte, []int) + func (*FindRankDataByKey) ProtoMessage() + func (m *FindRankDataByKey) GetKey() uint64 + func (m *FindRankDataByKey) GetRankId() uint64 + func (m *FindRankDataByKey) Marshal() (dAtA []byte, err error) + func (m *FindRankDataByKey) MarshalTo(dAtA []byte) (int, error) + func (m *FindRankDataByKey) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FindRankDataByKey) Reset() + func (m *FindRankDataByKey) Size() (n int) + func (m *FindRankDataByKey) String() string + func (m *FindRankDataByKey) Unmarshal(dAtA []byte) error + func (m *FindRankDataByKey) XXX_DiscardUnknown() + func (m *FindRankDataByKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FindRankDataByKey) XXX_Merge(src proto.Message) + func (m *FindRankDataByKey) XXX_Size() int + func (m *FindRankDataByKey) XXX_Unmarshal(b []byte) error + type FindRankDataByRank struct + Rank uint64 + RankId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FindRankDataByRank) Descriptor() ([]byte, []int) + func (*FindRankDataByRank) ProtoMessage() + func (m *FindRankDataByRank) GetRank() uint64 + func (m *FindRankDataByRank) GetRankId() uint64 + func (m *FindRankDataByRank) Marshal() (dAtA []byte, err error) + func (m *FindRankDataByRank) MarshalTo(dAtA []byte) (int, error) + func (m *FindRankDataByRank) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FindRankDataByRank) Reset() + func (m *FindRankDataByRank) Size() (n int) + func (m *FindRankDataByRank) String() string + func (m *FindRankDataByRank) Unmarshal(dAtA []byte) error + func (m *FindRankDataByRank) XXX_DiscardUnknown() + func (m *FindRankDataByRank) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FindRankDataByRank) XXX_Merge(src proto.Message) + func (m *FindRankDataByRank) XXX_Size() int + func (m *FindRankDataByRank) XXX_Unmarshal(b []byte) error + type FindRankDataList struct + Count uint64 + Key uint64 + RankId uint64 + StartRank uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FindRankDataList) Descriptor() ([]byte, []int) + func (*FindRankDataList) ProtoMessage() + func (m *FindRankDataList) GetCount() uint64 + func (m *FindRankDataList) GetKey() uint64 + func (m *FindRankDataList) GetRankId() uint64 + func (m *FindRankDataList) GetStartRank() uint64 + func (m *FindRankDataList) Marshal() (dAtA []byte, err error) + func (m *FindRankDataList) MarshalTo(dAtA []byte) (int, error) + func (m *FindRankDataList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FindRankDataList) Reset() + func (m *FindRankDataList) Size() (n int) + func (m *FindRankDataList) String() string + func (m *FindRankDataList) Unmarshal(dAtA []byte) error + func (m *FindRankDataList) XXX_DiscardUnknown() + func (m *FindRankDataList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FindRankDataList) XXX_Merge(src proto.Message) + func (m *FindRankDataList) XXX_Size() int + func (m *FindRankDataList) XXX_Unmarshal(b []byte) error + type FuncRpcClient func(nodeId int, serviceMethod string, client []*Client) (error, int) + type FuncRpcServer func() *Server + type GoGoPBProcessor struct + func (slf *GoGoPBProcessor) Clone(src interface{}) (interface{}, error) + func (slf *GoGoPBProcessor) GetProcessorType() RpcProcessorType + func (slf *GoGoPBProcessor) IsParse(param interface{}) bool + func (slf *GoGoPBProcessor) MakeRpcRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, ...) IRpcRequestData + func (slf *GoGoPBProcessor) MakeRpcResponse(seq uint64, err RpcError, reply []byte) IRpcResponseData + func (slf *GoGoPBProcessor) Marshal(v interface{}) ([]byte, error) + func (slf *GoGoPBProcessor) ReleaseRpcRequest(rpcRequestData IRpcRequestData) + func (slf *GoGoPBProcessor) ReleaseRpcResponse(rpcResponseData IRpcResponseData) + func (slf *GoGoPBProcessor) Unmarshal(data []byte, msg interface{}) error + type GoGoPBRpcRequestData struct + InParam []byte + NoReply bool + RpcMethodId uint32 + Seq uint64 + ServiceMethod string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GoGoPBRpcRequestData) Descriptor() ([]byte, []int) + func (*GoGoPBRpcRequestData) ProtoMessage() + func (m *GoGoPBRpcRequestData) GetInParam() []byte + func (m *GoGoPBRpcRequestData) GetNoReply() bool + func (m *GoGoPBRpcRequestData) GetRpcMethodId() uint32 + func (m *GoGoPBRpcRequestData) GetSeq() uint64 + func (m *GoGoPBRpcRequestData) GetServiceMethod() string + func (m *GoGoPBRpcRequestData) Marshal() (dAtA []byte, err error) + func (m *GoGoPBRpcRequestData) MarshalTo(dAtA []byte) (int, error) + func (m *GoGoPBRpcRequestData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GoGoPBRpcRequestData) Reset() + func (m *GoGoPBRpcRequestData) Size() (n int) + func (m *GoGoPBRpcRequestData) String() string + func (m *GoGoPBRpcRequestData) Unmarshal(dAtA []byte) error + func (m *GoGoPBRpcRequestData) XXX_DiscardUnknown() + func (m *GoGoPBRpcRequestData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GoGoPBRpcRequestData) XXX_Merge(src proto.Message) + func (m *GoGoPBRpcRequestData) XXX_Size() int + func (m *GoGoPBRpcRequestData) XXX_Unmarshal(b []byte) error + func (slf *GoGoPBRpcRequestData) IsNoReply() bool + func (slf *GoGoPBRpcRequestData) MakeRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, ...) *GoGoPBRpcRequestData + type GoGoPBRpcResponseData struct + Error string + Reply []byte + Seq uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GoGoPBRpcResponseData) Descriptor() ([]byte, []int) + func (*GoGoPBRpcResponseData) ProtoMessage() + func (m *GoGoPBRpcResponseData) GetError() string + func (m *GoGoPBRpcResponseData) GetReply() []byte + func (m *GoGoPBRpcResponseData) GetSeq() uint64 + func (m *GoGoPBRpcResponseData) Marshal() (dAtA []byte, err error) + func (m *GoGoPBRpcResponseData) MarshalTo(dAtA []byte) (int, error) + func (m *GoGoPBRpcResponseData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GoGoPBRpcResponseData) Reset() + func (m *GoGoPBRpcResponseData) Size() (n int) + func (m *GoGoPBRpcResponseData) String() string + func (m *GoGoPBRpcResponseData) Unmarshal(dAtA []byte) error + func (m *GoGoPBRpcResponseData) XXX_DiscardUnknown() + func (m *GoGoPBRpcResponseData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GoGoPBRpcResponseData) XXX_Merge(src proto.Message) + func (m *GoGoPBRpcResponseData) XXX_Size() int + func (m *GoGoPBRpcResponseData) XXX_Unmarshal(b []byte) error + func (slf *GoGoPBRpcResponseData) GetErr() *RpcError + func (slf *GoGoPBRpcResponseData) MakeRespone(seq uint64, err RpcError, reply []byte) *GoGoPBRpcResponseData + type ICompressor interface + CompressBlock func(src []byte) ([]byte, error) + CompressBufferCollection func(buffer []byte) + UnCompressBufferCollection func(buffer []byte) + UncompressBlock func(src []byte) ([]byte, error) + type IDiscoveryServiceListener interface + OnDiscoveryService func(nodeId int, serviceName []string) + OnUnDiscoveryService func(nodeId int, serviceName []string) + type INodeListener interface + OnNodeConnected func(nodeId int) + OnNodeDisconnect func(nodeId int) + type IRealClient interface + AsyncCall func(timeout time.Duration, rpcHandler IRpcHandler, serviceMethod string, ...) (CancelRpc, error) + Close func(waitDone bool) + Go func(timeout time.Duration, rpcHandler IRpcHandler, noReply bool, ...) *Call + IsConnected func() bool + OnClose func() + RawGo func(timeout time.Duration, rpcHandler IRpcHandler, processor IRpcProcessor, ...) *Call + Run func() + SetConn func(conn *network.TCPConn) + type IRpcHandler interface + AsyncCall func(serviceMethod string, args interface{}, callback interface{}) error + AsyncCallNode func(nodeId int, serviceMethod string, args interface{}, callback interface{}) error + AsyncCallNodeWithTimeout func(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, ...) (CancelRpc, error) + AsyncCallWithTimeout func(timeout time.Duration, serviceMethod string, args interface{}, ...) (CancelRpc, error) + Call func(serviceMethod string, args interface{}, reply interface{}) error + CallMethod func(client *Client, ServiceMethod string, param interface{}, ...) error + CallNode func(nodeId int, serviceMethod string, args interface{}, reply interface{}) error + CallNodeWithTimeout func(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, ...) error + CallWithTimeout func(timeout time.Duration, serviceMethod string, args interface{}, ...) error + CastGo func(serviceMethod string, args interface{}) error + GetName func() string + GetRpcHandler func() IRpcHandler + GetRpcServer func() FuncRpcServer + Go func(serviceMethod string, args interface{}) error + GoNode func(nodeId int, serviceMethod string, args interface{}) error + HandlerRpcRequest func(request *RpcRequest) + HandlerRpcResponseCB func(call *Call) + InitRpcHandler func(rpcHandler IRpcHandler, getClientFun FuncRpcClient, getServerFun FuncRpcServer, ...) + IsSingleCoroutine func() bool + RawGoNode func(rpcProcessorType RpcProcessorType, nodeId int, rpcMethodId uint32, ...) error + UnmarshalInParam func(rpcProcessor IRpcProcessor, serviceMethod string, rawRpcMethodId uint32, ...) (interface{}, error) + type IRpcHandlerChannel interface + PushRpcRequest func(rpcRequest *RpcRequest) error + PushRpcResponse func(call *Call) error + type IRpcProcessor interface + Clone func(src interface{}) (interface{}, error) + GetProcessorType func() RpcProcessorType + IsParse func(param interface{}) bool + MakeRpcRequest func(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, ...) IRpcRequestData + MakeRpcResponse func(seq uint64, err RpcError, reply []byte) IRpcResponseData + Marshal func(v interface{}) ([]byte, error) + ReleaseRpcRequest func(rpcRequestData IRpcRequestData) + ReleaseRpcResponse func(rpcRequestData IRpcResponseData) + Unmarshal func(data []byte, v interface{}) error + func GetProcessor(processorType uint8) IRpcProcessor + type IRpcRequestData interface + GetInParam func() []byte + GetRpcMethodId func() uint32 + GetSeq func() uint64 + GetServiceMethod func() string + IsNoReply func() bool + type IRpcResponseData interface + GetErr func() *RpcError + GetReply func() []byte + GetSeq func() uint64 + type IncreaseRankData struct + Extend []*ExtendIncData + IncreaseSortData []int64 + InitData []byte + InitSortData []int64 + InsertDataOnNonExistent bool + Key uint64 + RankId uint64 + ReturnRankData bool + SetSortAndExtendData []*SetSortAndExtendData + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IncreaseRankData) Descriptor() ([]byte, []int) + func (*IncreaseRankData) ProtoMessage() + func (m *IncreaseRankData) GetExtend() []*ExtendIncData + func (m *IncreaseRankData) GetIncreaseSortData() []int64 + func (m *IncreaseRankData) GetInitData() []byte + func (m *IncreaseRankData) GetInitSortData() []int64 + func (m *IncreaseRankData) GetInsertDataOnNonExistent() bool + func (m *IncreaseRankData) GetKey() uint64 + func (m *IncreaseRankData) GetRankId() uint64 + func (m *IncreaseRankData) GetReturnRankData() bool + func (m *IncreaseRankData) GetSetSortAndExtendData() []*SetSortAndExtendData + func (m *IncreaseRankData) Marshal() (dAtA []byte, err error) + func (m *IncreaseRankData) MarshalTo(dAtA []byte) (int, error) + func (m *IncreaseRankData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IncreaseRankData) Reset() + func (m *IncreaseRankData) Size() (n int) + func (m *IncreaseRankData) String() string + func (m *IncreaseRankData) Unmarshal(dAtA []byte) error + func (m *IncreaseRankData) XXX_DiscardUnknown() + func (m *IncreaseRankData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IncreaseRankData) XXX_Merge(src proto.Message) + func (m *IncreaseRankData) XXX_Size() int + func (m *IncreaseRankData) XXX_Unmarshal(b []byte) error + type IncreaseRankDataRet struct + PosData *RankPosData + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IncreaseRankDataRet) Descriptor() ([]byte, []int) + func (*IncreaseRankDataRet) ProtoMessage() + func (m *IncreaseRankDataRet) GetPosData() *RankPosData + func (m *IncreaseRankDataRet) Marshal() (dAtA []byte, err error) + func (m *IncreaseRankDataRet) MarshalTo(dAtA []byte) (int, error) + func (m *IncreaseRankDataRet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IncreaseRankDataRet) Reset() + func (m *IncreaseRankDataRet) Size() (n int) + func (m *IncreaseRankDataRet) String() string + func (m *IncreaseRankDataRet) Unmarshal(dAtA []byte) error + func (m *IncreaseRankDataRet) XXX_DiscardUnknown() + func (m *IncreaseRankDataRet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IncreaseRankDataRet) XXX_Merge(src proto.Message) + func (m *IncreaseRankDataRet) XXX_Size() int + func (m *IncreaseRankDataRet) XXX_Unmarshal(b []byte) error + type JsonProcessor struct + func (jsonProcessor *JsonProcessor) Clone(src interface{}) (interface{}, error) + func (jsonProcessor *JsonProcessor) GetProcessorType() RpcProcessorType + func (jsonProcessor *JsonProcessor) IsParse(param interface{}) bool + func (jsonProcessor *JsonProcessor) MakeRpcRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, ...) IRpcRequestData + func (jsonProcessor *JsonProcessor) MakeRpcResponse(seq uint64, err RpcError, reply []byte) IRpcResponseData + func (jsonProcessor *JsonProcessor) Marshal(v interface{}) ([]byte, error) + func (jsonProcessor *JsonProcessor) ReleaseRpcRequest(rpcRequestData IRpcRequestData) + func (jsonProcessor *JsonProcessor) ReleaseRpcResponse(rpcResponseData IRpcResponseData) + func (jsonProcessor *JsonProcessor) Unmarshal(data []byte, v interface{}) error + type JsonRpcRequestData struct + InParam []byte + NoReply bool + Seq uint64 + ServiceMethod string + func (jsonRpcRequestData *JsonRpcRequestData) GetInParam() []byte + func (jsonRpcRequestData *JsonRpcRequestData) GetRpcMethodId() uint32 + func (jsonRpcRequestData *JsonRpcRequestData) GetSeq() uint64 + func (jsonRpcRequestData *JsonRpcRequestData) GetServiceMethod() string + func (jsonRpcRequestData *JsonRpcRequestData) IsNoReply() bool + type JsonRpcResponseData struct + Err string + Reply []byte + Seq uint64 + func (jsonRpcResponseData *JsonRpcResponseData) GetErr() *RpcError + func (jsonRpcResponseData *JsonRpcResponseData) GetReply() []byte + func (jsonRpcResponseData *JsonRpcResponseData) GetSeq() uint64 + type LClient struct + func (lc *LClient) AsyncCall(timeout time.Duration, rpcHandler IRpcHandler, serviceMethod string, ...) (CancelRpc, error) + func (lc *LClient) Close(waitDone bool) + func (lc *LClient) Go(timeout time.Duration, rpcHandler IRpcHandler, noReply bool, ...) *Call + func (lc *LClient) IsConnected() bool + func (lc *LClient) OnClose() + func (lc *LClient) Run() + func (lc *LClient) SetConn(conn *network.TCPConn) + func (rc *LClient) Lock() + func (rc *LClient) RawGo(timeout time.Duration, rpcHandler IRpcHandler, processor IRpcProcessor, ...) *Call + func (rc *LClient) Unlock() + type Lz4Compressor struct + func (lc *Lz4Compressor) CompressBlock(src []byte) (dest []byte, err error) + func (lc *Lz4Compressor) CompressBufferCollection(buffer []byte) + func (lc *Lz4Compressor) UnCompressBufferCollection(buffer []byte) + func (lc *Lz4Compressor) UncompressBlock(src []byte) (dest []byte, err error) + type NodeInfo struct + ListenAddr string + MaxRpcParamLen uint32 + NodeId int32 + NodeName string + Private bool + PublicServiceList []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeInfo) Descriptor() ([]byte, []int) + func (*NodeInfo) ProtoMessage() + func (m *NodeInfo) GetListenAddr() string + func (m *NodeInfo) GetMaxRpcParamLen() uint32 + func (m *NodeInfo) GetNodeId() int32 + func (m *NodeInfo) GetNodeName() string + func (m *NodeInfo) GetPrivate() bool + func (m *NodeInfo) GetPublicServiceList() []string + func (m *NodeInfo) Marshal() (dAtA []byte, err error) + func (m *NodeInfo) MarshalTo(dAtA []byte) (int, error) + func (m *NodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NodeInfo) Reset() + func (m *NodeInfo) Size() (n int) + func (m *NodeInfo) String() string + func (m *NodeInfo) Unmarshal(dAtA []byte) error + func (m *NodeInfo) XXX_DiscardUnknown() + func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeInfo) XXX_Merge(src proto.Message) + func (m *NodeInfo) XXX_Size() int + func (m *NodeInfo) XXX_Unmarshal(b []byte) error + type RClient struct + func (rc *RClient) AsyncCall(timeout time.Duration, rpcHandler IRpcHandler, serviceMethod string, ...) (CancelRpc, error) + func (rc *RClient) Close(waitDone bool) + func (rc *RClient) GetConn() *network.TCPConn + func (rc *RClient) Go(timeout time.Duration, rpcHandler IRpcHandler, noReply bool, ...) *Call + func (rc *RClient) IsConnected() bool + func (rc *RClient) OnClose() + func (rc *RClient) RawGo(timeout time.Duration, rpcHandler IRpcHandler, processor IRpcProcessor, ...) *Call + func (rc *RClient) Run() + func (rc *RClient) SetConn(conn *network.TCPConn) + type RankData struct + Data []byte + ExData []*ExtendIncData + Key uint64 + SortData []int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RankData) Descriptor() ([]byte, []int) + func (*RankData) ProtoMessage() + func (m *RankData) GetData() []byte + func (m *RankData) GetExData() []*ExtendIncData + func (m *RankData) GetKey() uint64 + func (m *RankData) GetSortData() []int64 + func (m *RankData) Marshal() (dAtA []byte, err error) + func (m *RankData) MarshalTo(dAtA []byte) (int, error) + func (m *RankData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RankData) Reset() + func (m *RankData) Size() (n int) + func (m *RankData) String() string + func (m *RankData) Unmarshal(dAtA []byte) error + func (m *RankData) XXX_DiscardUnknown() + func (m *RankData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RankData) XXX_Merge(src proto.Message) + func (m *RankData) XXX_Size() int + func (m *RankData) XXX_Unmarshal(b []byte) error + type RankDataList struct + KeyRank *RankPosData + RankDataCount uint64 + RankPosDataList []*RankPosData + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RankDataList) Descriptor() ([]byte, []int) + func (*RankDataList) ProtoMessage() + func (m *RankDataList) GetKeyRank() *RankPosData + func (m *RankDataList) GetRankDataCount() uint64 + func (m *RankDataList) GetRankPosDataList() []*RankPosData + func (m *RankDataList) Marshal() (dAtA []byte, err error) + func (m *RankDataList) MarshalTo(dAtA []byte) (int, error) + func (m *RankDataList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RankDataList) Reset() + func (m *RankDataList) Size() (n int) + func (m *RankDataList) String() string + func (m *RankDataList) Unmarshal(dAtA []byte) error + func (m *RankDataList) XXX_DiscardUnknown() + func (m *RankDataList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RankDataList) XXX_Merge(src proto.Message) + func (m *RankDataList) XXX_Size() int + func (m *RankDataList) XXX_Unmarshal(b []byte) error + type RankInfo struct + Key uint64 + Rank uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RankInfo) Descriptor() ([]byte, []int) + func (*RankInfo) ProtoMessage() + func (m *RankInfo) GetKey() uint64 + func (m *RankInfo) GetRank() uint64 + func (m *RankInfo) Marshal() (dAtA []byte, err error) + func (m *RankInfo) MarshalTo(dAtA []byte) (int, error) + func (m *RankInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RankInfo) Reset() + func (m *RankInfo) Size() (n int) + func (m *RankInfo) String() string + func (m *RankInfo) Unmarshal(dAtA []byte) error + func (m *RankInfo) XXX_DiscardUnknown() + func (m *RankInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RankInfo) XXX_Merge(src proto.Message) + func (m *RankInfo) XXX_Size() int + func (m *RankInfo) XXX_Unmarshal(b []byte) error + type RankList struct + ExpireMs int64 + IsDec bool + MaxRank uint64 + RankId uint64 + RankName string + SkipListLevel int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RankList) Descriptor() ([]byte, []int) + func (*RankList) ProtoMessage() + func (m *RankList) GetExpireMs() int64 + func (m *RankList) GetIsDec() bool + func (m *RankList) GetMaxRank() uint64 + func (m *RankList) GetRankId() uint64 + func (m *RankList) GetRankName() string + func (m *RankList) GetSkipListLevel() int32 + func (m *RankList) Marshal() (dAtA []byte, err error) + func (m *RankList) MarshalTo(dAtA []byte) (int, error) + func (m *RankList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RankList) Reset() + func (m *RankList) Size() (n int) + func (m *RankList) String() string + func (m *RankList) Unmarshal(dAtA []byte) error + func (m *RankList) XXX_DiscardUnknown() + func (m *RankList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RankList) XXX_Merge(src proto.Message) + func (m *RankList) XXX_Size() int + func (m *RankList) XXX_Unmarshal(b []byte) error + type RankPosData struct + Data []byte + ExtendData []int64 + Key uint64 + Rank uint64 + SortData []int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RankPosData) Descriptor() ([]byte, []int) + func (*RankPosData) ProtoMessage() + func (m *RankPosData) GetData() []byte + func (m *RankPosData) GetExtendData() []int64 + func (m *RankPosData) GetKey() uint64 + func (m *RankPosData) GetRank() uint64 + func (m *RankPosData) GetSortData() []int64 + func (m *RankPosData) Marshal() (dAtA []byte, err error) + func (m *RankPosData) MarshalTo(dAtA []byte) (int, error) + func (m *RankPosData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RankPosData) Reset() + func (m *RankPosData) Size() (n int) + func (m *RankPosData) String() string + func (m *RankPosData) Unmarshal(dAtA []byte) error + func (m *RankPosData) XXX_DiscardUnknown() + func (m *RankPosData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RankPosData) XXX_Merge(src proto.Message) + func (m *RankPosData) XXX_Size() int + func (m *RankPosData) XXX_Unmarshal(b []byte) error + type RankResult struct + AddCount int32 + ModifyCount int32 + NewRank []*RankInfo + RemoveCount int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RankResult) Descriptor() ([]byte, []int) + func (*RankResult) ProtoMessage() + func (m *RankResult) GetAddCount() int32 + func (m *RankResult) GetModifyCount() int32 + func (m *RankResult) GetNewRank() []*RankInfo + func (m *RankResult) GetRemoveCount() int32 + func (m *RankResult) Marshal() (dAtA []byte, err error) + func (m *RankResult) MarshalTo(dAtA []byte) (int, error) + func (m *RankResult) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RankResult) Reset() + func (m *RankResult) Size() (n int) + func (m *RankResult) String() string + func (m *RankResult) Unmarshal(dAtA []byte) error + func (m *RankResult) XXX_DiscardUnknown() + func (m *RankResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RankResult) XXX_Merge(src proto.Message) + func (m *RankResult) XXX_Size() int + func (m *RankResult) XXX_Unmarshal(b []byte) error + type RawRpcCallBack func(rawData []byte) + type RequestHandler func(Returns interface{}, Err RpcError) + type Responder = RequestHandler + func (r *Responder) IsInvalid() bool + type RpcAgent struct + func (agent *RpcAgent) Close() + func (agent *RpcAgent) Destroy() + func (agent *RpcAgent) LocalAddr() net.Addr + func (agent *RpcAgent) OnClose() + func (agent *RpcAgent) OnDestroy() + func (agent *RpcAgent) RemoteAddr() net.Addr + func (agent *RpcAgent) Run() + func (agent *RpcAgent) WriteMsg(msg interface{}) + func (agent *RpcAgent) WriteResponse(processor IRpcProcessor, serviceMethod string, seq uint64, reply interface{}, ...) + type RpcCancel struct + CallSeq uint64 + Cli *Client + func (rc *RpcCancel) CancelRpc() + type RpcError string + var NilError RpcError + func ConvertError(e error) RpcError + func (e RpcError) Error() string + type RpcHandleFinder interface + FindRpcHandler func(serviceMethod string) IRpcHandler + type RpcHandler struct + func (handler *RpcHandler) AsyncCall(serviceMethod string, args interface{}, callback interface{}) error + func (handler *RpcHandler) AsyncCallNode(nodeId int, serviceMethod string, args interface{}, callback interface{}) error + func (handler *RpcHandler) AsyncCallNodeWithTimeout(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, ...) (CancelRpc, error) + func (handler *RpcHandler) AsyncCallWithTimeout(timeout time.Duration, serviceMethod string, args interface{}, ...) (CancelRpc, error) + func (handler *RpcHandler) Call(serviceMethod string, args interface{}, reply interface{}) error + func (handler *RpcHandler) CallMethod(client *Client, ServiceMethod string, param interface{}, ...) error + func (handler *RpcHandler) CallNode(nodeId int, serviceMethod string, args interface{}, reply interface{}) error + func (handler *RpcHandler) CallNodeWithTimeout(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, ...) error + func (handler *RpcHandler) CallWithTimeout(timeout time.Duration, serviceMethod string, args interface{}, ...) error + func (handler *RpcHandler) CastGo(serviceMethod string, args interface{}) error + func (handler *RpcHandler) GetName() string + func (handler *RpcHandler) GetRpcHandler() IRpcHandler + func (handler *RpcHandler) GetRpcServer() FuncRpcServer + func (handler *RpcHandler) Go(serviceMethod string, args interface{}) error + func (handler *RpcHandler) GoNode(nodeId int, serviceMethod string, args interface{}) error + func (handler *RpcHandler) HandlerRpcRequest(request *RpcRequest) + func (handler *RpcHandler) HandlerRpcResponseCB(call *Call) + func (handler *RpcHandler) InitRpcHandler(rpcHandler IRpcHandler, getClientFun FuncRpcClient, getServerFun FuncRpcServer, ...) + func (handler *RpcHandler) IsSingleCoroutine() bool + func (handler *RpcHandler) RawGoNode(rpcProcessorType RpcProcessorType, nodeId int, rpcMethodId uint32, ...) error + func (handler *RpcHandler) RegRawRpc(rpcMethodId uint32, rawRpcCB RawRpcCallBack) + func (handler *RpcHandler) RegisterRpc(rpcHandler IRpcHandler) error + func (handler *RpcHandler) UnmarshalInParam(rpcProcessor IRpcProcessor, serviceMethod string, rawRpcMethodId uint32, ...) (interface{}, error) + type RpcMethodInfo struct + type RpcProcessorType uint8 + const RpcProcessorGoGoPB + const RpcProcessorJson + type RpcRequest struct + RpcRequestData IRpcRequestData + func MakeRpcRequest(rpcProcessor IRpcProcessor, seq uint64, rpcMethodId uint32, ...) *RpcRequest + func (slf *RpcRequest) Clear() *RpcRequest + func (slf *RpcRequest) IsRef() bool + func (slf *RpcRequest) Ref() + func (slf *RpcRequest) Reset() + func (slf *RpcRequest) UnRef() + type RpcResponse struct + RpcResponseData IRpcResponseData + func (rpcResponse *RpcResponse) Clear() *RpcResponse + type Server struct + func (server *Server) Init(rpcHandleFinder RpcHandleFinder) + func (server *Server) NewAgent(c *network.TCPConn) network.Agent + func (server *Server) Start(listenAddr string, maxRpcParamLen uint32, compressBytesLen int) + type ServiceDiscoverReq struct + NodeInfo *NodeInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServiceDiscoverReq) Descriptor() ([]byte, []int) + func (*ServiceDiscoverReq) ProtoMessage() + func (m *ServiceDiscoverReq) GetNodeInfo() *NodeInfo + func (m *ServiceDiscoverReq) Marshal() (dAtA []byte, err error) + func (m *ServiceDiscoverReq) MarshalTo(dAtA []byte) (int, error) + func (m *ServiceDiscoverReq) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ServiceDiscoverReq) Reset() + func (m *ServiceDiscoverReq) Size() (n int) + func (m *ServiceDiscoverReq) String() string + func (m *ServiceDiscoverReq) Unmarshal(dAtA []byte) error + func (m *ServiceDiscoverReq) XXX_DiscardUnknown() + func (m *ServiceDiscoverReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServiceDiscoverReq) XXX_Merge(src proto.Message) + func (m *ServiceDiscoverReq) XXX_Size() int + func (m *ServiceDiscoverReq) XXX_Unmarshal(b []byte) error + type SetSortAndExtendData struct + Data int64 + IsSortData bool + Pos int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetSortAndExtendData) Descriptor() ([]byte, []int) + func (*SetSortAndExtendData) ProtoMessage() + func (m *SetSortAndExtendData) GetData() int64 + func (m *SetSortAndExtendData) GetIsSortData() bool + func (m *SetSortAndExtendData) GetPos() int32 + func (m *SetSortAndExtendData) Marshal() (dAtA []byte, err error) + func (m *SetSortAndExtendData) MarshalTo(dAtA []byte) (int, error) + func (m *SetSortAndExtendData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SetSortAndExtendData) Reset() + func (m *SetSortAndExtendData) Size() (n int) + func (m *SetSortAndExtendData) String() string + func (m *SetSortAndExtendData) Unmarshal(dAtA []byte) error + func (m *SetSortAndExtendData) XXX_DiscardUnknown() + func (m *SetSortAndExtendData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetSortAndExtendData) XXX_Merge(src proto.Message) + func (m *SetSortAndExtendData) XXX_Size() int + func (m *SetSortAndExtendData) XXX_Unmarshal(b []byte) error + type SubscribeDiscoverNotify struct + DelNodeId int32 + IsFull bool + MasterNodeId int32 + NodeInfo []*NodeInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscribeDiscoverNotify) Descriptor() ([]byte, []int) + func (*SubscribeDiscoverNotify) ProtoMessage() + func (m *SubscribeDiscoverNotify) GetDelNodeId() int32 + func (m *SubscribeDiscoverNotify) GetIsFull() bool + func (m *SubscribeDiscoverNotify) GetMasterNodeId() int32 + func (m *SubscribeDiscoverNotify) GetNodeInfo() []*NodeInfo + func (m *SubscribeDiscoverNotify) Marshal() (dAtA []byte, err error) + func (m *SubscribeDiscoverNotify) MarshalTo(dAtA []byte) (int, error) + func (m *SubscribeDiscoverNotify) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SubscribeDiscoverNotify) Reset() + func (m *SubscribeDiscoverNotify) Size() (n int) + func (m *SubscribeDiscoverNotify) String() string + func (m *SubscribeDiscoverNotify) Unmarshal(dAtA []byte) error + func (m *SubscribeDiscoverNotify) XXX_DiscardUnknown() + func (m *SubscribeDiscoverNotify) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscribeDiscoverNotify) XXX_Merge(src proto.Message) + func (m *SubscribeDiscoverNotify) XXX_Size() int + func (m *SubscribeDiscoverNotify) XXX_Unmarshal(b []byte) error + type SubscribeMethod int32 + const SubscribeMethod_Method_Custom + const SubscribeMethod_Method_Last + func (SubscribeMethod) EnumDescriptor() ([]byte, []int) + func (x SubscribeMethod) String() string + type SubscribeType int32 + const SubscribeType_Subscribe + const SubscribeType_Unsubscribe + func (SubscribeType) EnumDescriptor() ([]byte, []int) + func (x SubscribeType) String() string + type TriggerRpcConnEvent func(bConnect bool, clientSeq uint32, nodeId int) + type UpdateRankData struct + Data []byte + Key uint64 + RankId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateRankData) Descriptor() ([]byte, []int) + func (*UpdateRankData) ProtoMessage() + func (m *UpdateRankData) GetData() []byte + func (m *UpdateRankData) GetKey() uint64 + func (m *UpdateRankData) GetRankId() uint64 + func (m *UpdateRankData) Marshal() (dAtA []byte, err error) + func (m *UpdateRankData) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateRankData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateRankData) Reset() + func (m *UpdateRankData) Size() (n int) + func (m *UpdateRankData) String() string + func (m *UpdateRankData) Unmarshal(dAtA []byte) error + func (m *UpdateRankData) XXX_DiscardUnknown() + func (m *UpdateRankData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateRankData) XXX_Merge(src proto.Message) + func (m *UpdateRankData) XXX_Size() int + func (m *UpdateRankData) XXX_Unmarshal(b []byte) error + type UpdateRankDataRet struct + Ret bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateRankDataRet) Descriptor() ([]byte, []int) + func (*UpdateRankDataRet) ProtoMessage() + func (m *UpdateRankDataRet) GetRet() bool + func (m *UpdateRankDataRet) Marshal() (dAtA []byte, err error) + func (m *UpdateRankDataRet) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateRankDataRet) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateRankDataRet) Reset() + func (m *UpdateRankDataRet) Size() (n int) + func (m *UpdateRankDataRet) String() string + func (m *UpdateRankDataRet) Unmarshal(dAtA []byte) error + func (m *UpdateRankDataRet) XXX_DiscardUnknown() + func (m *UpdateRankDataRet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateRankDataRet) XXX_Merge(src proto.Message) + func (m *UpdateRankDataRet) XXX_Size() int + func (m *UpdateRankDataRet) XXX_Unmarshal(b []byte) error + type UpsetRankData struct + FindNewRank bool + RankDataList []*RankData + RankId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpsetRankData) Descriptor() ([]byte, []int) + func (*UpsetRankData) ProtoMessage() + func (m *UpsetRankData) GetFindNewRank() bool + func (m *UpsetRankData) GetRankDataList() []*RankData + func (m *UpsetRankData) GetRankId() uint64 + func (m *UpsetRankData) Marshal() (dAtA []byte, err error) + func (m *UpsetRankData) MarshalTo(dAtA []byte) (int, error) + func (m *UpsetRankData) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpsetRankData) Reset() + func (m *UpsetRankData) Size() (n int) + func (m *UpsetRankData) String() string + func (m *UpsetRankData) Unmarshal(dAtA []byte) error + func (m *UpsetRankData) XXX_DiscardUnknown() + func (m *UpsetRankData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpsetRankData) XXX_Merge(src proto.Message) + func (m *UpsetRankData) XXX_Size() int + func (m *UpsetRankData) XXX_Unmarshal(b []byte) error
Go to main page