rpc

Oct 9, 2023

Changes in this version

+ var File_proto_rpcproto_dynamicdiscover_proto protoreflect.FileDescriptor

type NodeInfo

+ Retire bool

+ func (x *NodeInfo) GetRetire() bool

+ type NodeRetireReq struct

+ NodeInfo *NodeInfo

+ func (*NodeRetireReq) Descriptor() ([]byte, []int)

+ func (*NodeRetireReq) ProtoMessage()

+ func (x *NodeRetireReq) GetNodeInfo() *NodeInfo

+ func (x *NodeRetireReq) ProtoReflect() protoreflect.Message

+ func (x *NodeRetireReq) Reset()

+ func (x *NodeRetireReq) String() string

type RpcProcessorType

+ const RpcProcessorPB

Aug 29, 2023

Changes in this version

+ var File_test_rpc_dynamicdiscover_proto protoreflect.FileDescriptor

+ var File_test_rpc_messagequeue_proto protoreflect.FileDescriptor

+ var File_test_rpc_protorpc_proto protoreflect.FileDescriptor

+ var File_test_rpc_rank_proto protoreflect.FileDescriptor

type AddRankList

+ func (x *AddRankList) ProtoReflect() protoreflect.Message

type DBQueuePopReq

+ func (x *DBQueuePopReq) ProtoReflect() protoreflect.Message

type DBQueuePopRes

+ func (x *DBQueuePopRes) ProtoReflect() protoreflect.Message

type DBQueuePublishReq

+ func (x *DBQueuePublishReq) ProtoReflect() protoreflect.Message

type DBQueuePublishRes

+ func (x *DBQueuePublishRes) ProtoReflect() protoreflect.Message

type DBQueueSubscribeReq

+ func (x *DBQueueSubscribeReq) ProtoReflect() protoreflect.Message

type DBQueueSubscribeRes

+ func (x *DBQueueSubscribeRes) ProtoReflect() protoreflect.Message

type DeleteByKey

+ func (x *DeleteByKey) ProtoReflect() protoreflect.Message

type Empty

+ func (x *Empty) ProtoReflect() protoreflect.Message

type ExtendIncData

+ func (x *ExtendIncData) ProtoReflect() protoreflect.Message

type FindRankDataByKey

+ func (x *FindRankDataByKey) ProtoReflect() protoreflect.Message

type FindRankDataByRank

+ func (x *FindRankDataByRank) ProtoReflect() protoreflect.Message

type FindRankDataList

+ func (x *FindRankDataList) ProtoReflect() protoreflect.Message

type IncreaseRankData

+ func (x *IncreaseRankData) ProtoReflect() protoreflect.Message

type IncreaseRankDataRet

+ func (x *IncreaseRankDataRet) ProtoReflect() protoreflect.Message

type NodeInfo

+ func (x *NodeInfo) ProtoReflect() protoreflect.Message

+ type PBProcessor struct

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

+ func (slf *PBProcessor) GetProcessorType() RpcProcessorType

+ func (slf *PBProcessor) IsParse(param interface{}) bool

+ func (slf *PBProcessor) MakeRpcRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, ...) IRpcRequestData

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

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

+ func (slf *PBProcessor) ReleaseRpcRequest(rpcRequestData IRpcRequestData)

+ func (slf *PBProcessor) ReleaseRpcResponse(rpcResponseData IRpcResponseData)

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

+ type PBRpcRequestData struct

+ InParam []byte

+ NoReply bool

+ RpcMethodId uint32

+ Seq uint64

+ ServiceMethod string

+ func (*PBRpcRequestData) Descriptor() ([]byte, []int)

+ func (*PBRpcRequestData) ProtoMessage()

+ func (slf *PBRpcRequestData) IsNoReply() bool

+ func (slf *PBRpcRequestData) MakeRequest(seq uint64, rpcMethodId uint32, serviceMethod string, noReply bool, ...) *PBRpcRequestData

+ func (x *PBRpcRequestData) GetInParam() []byte

+ func (x *PBRpcRequestData) GetNoReply() bool

+ func (x *PBRpcRequestData) GetRpcMethodId() uint32

+ func (x *PBRpcRequestData) GetSeq() uint64

+ func (x *PBRpcRequestData) GetServiceMethod() string

+ func (x *PBRpcRequestData) ProtoReflect() protoreflect.Message

+ func (x *PBRpcRequestData) Reset()

+ func (x *PBRpcRequestData) String() string

+ type PBRpcResponseData struct

+ Error string

+ Reply []byte

+ Seq uint64

+ func (*PBRpcResponseData) Descriptor() ([]byte, []int)

+ func (*PBRpcResponseData) ProtoMessage()

+ func (slf *PBRpcResponseData) GetErr() *RpcError

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

+ func (x *PBRpcResponseData) GetError() string

+ func (x *PBRpcResponseData) GetReply() []byte

+ func (x *PBRpcResponseData) GetSeq() uint64

+ func (x *PBRpcResponseData) ProtoReflect() protoreflect.Message

+ func (x *PBRpcResponseData) Reset()

+ func (x *PBRpcResponseData) String() string

type RankData

+ func (x *RankData) ProtoReflect() protoreflect.Message

type RankDataList

+ func (x *RankDataList) ProtoReflect() protoreflect.Message

type RankInfo

+ func (x *RankInfo) ProtoReflect() protoreflect.Message

type RankList

+ func (x *RankList) ProtoReflect() protoreflect.Message

type RankPosData

+ func (x *RankPosData) ProtoReflect() protoreflect.Message

type RankResult

+ func (x *RankResult) ProtoReflect() protoreflect.Message

type ServiceDiscoverReq

+ func (x *ServiceDiscoverReq) ProtoReflect() protoreflect.Message

type SetSortAndExtendData

+ func (x *SetSortAndExtendData) ProtoReflect() protoreflect.Message

type SubscribeDiscoverNotify

+ func (x *SubscribeDiscoverNotify) ProtoReflect() protoreflect.Message

type SubscribeMethod

+ func (SubscribeMethod) Descriptor() protoreflect.EnumDescriptor

+ func (SubscribeMethod) Type() protoreflect.EnumType

+ func (x SubscribeMethod) Enum() *SubscribeMethod

+ func (x SubscribeMethod) Number() protoreflect.EnumNumber

type SubscribeType

+ func (SubscribeType) Descriptor() protoreflect.EnumDescriptor

+ func (SubscribeType) Type() protoreflect.EnumType

+ func (x SubscribeType) Enum() *SubscribeType

+ func (x SubscribeType) Number() protoreflect.EnumNumber

type UpdateRankData

+ func (x *UpdateRankData) ProtoReflect() protoreflect.Message

type UpdateRankDataRet

+ func (x *UpdateRankDataRet) ProtoReflect() protoreflect.Message

type UpsetRankData

+ func (x *UpsetRankData) ProtoReflect() protoreflect.Message

Jul 28, 2023

Changes in this version

+ func SetCompressor(cp ICompressor)

type Call

+ TimeOut time.Duration

+ 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 ICompressor interface

+ CompressBlock func(src []byte) ([]byte, error)

+ CompressBufferCollection func(buffer []byte)

+ UnCompressBufferCollection func(buffer []byte)

+ UncompressBlock func(src []byte) ([]byte, error)

type IRpcHandler

+ AsyncCallNodeWithTimeout func(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, ...) (CancelRpc, error)

+ AsyncCallWithTimeout func(timeout time.Duration, serviceMethod string, args interface{}, ...) (CancelRpc, error)

+ CallNodeWithTimeout func(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, ...) error

+ CallWithTimeout func(timeout time.Duration, serviceMethod string, args interface{}, ...) error

+ 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 RpcCancel struct

+ CallSeq uint64

+ Cli *Client

+ func (rc *RpcCancel) CancelRpc()

type RpcHandler

+ 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) CallNodeWithTimeout(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, ...) error

+ func (handler *RpcHandler) CallWithTimeout(timeout time.Duration, serviceMethod string, args interface{}, ...) error

May 9, 2023

Changes in this version

type Call

+ func (call *Call) DoError(err error)

+ func (call *Call) DoOK()

Apr 4, 2023

Changes in this version

+ const DefaultCheckRpcCallTimeoutInterval

+ const DefaultConnectInterval

+ const DefaultMaxCheckCallRpcCount

+ const DefaultMaxPendingWriteNum

+ const DefaultRpcConnNum

+ const DefaultRpcLenMsgLen

+ const DefaultRpcMinMsgLen

Feb 22, 2023

Changes in this version

+ const CheckRpcCallTimeoutInterval

+ const DefaultRpcTimeout

+ const RpcConnNum

+ const RpcLenMsgLen

+ const RpcMinMsgLen

type Client

+ func NewLClient(nodeId int) *Client

+ func NewRClient(nodeId int, addr string, maxRpcParamLen uint32, ...) *Client

+ func (client *Client) GetClientId() uint32

+ func (client *Client) GetNodeId() int

+ func (client *Client) InitPending()

+ 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 GoGoPBProcessor

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

+ type IRealClient interface

+ AsyncCall func(rpcHandler IRpcHandler, serviceMethod string, callback reflect.Value, ...) error

+ Close func(waitDone bool)

+ Go func(rpcHandler IRpcHandler, noReply bool, serviceMethod string, args interface{}, ...) *Call

+ IsConnected func() bool

+ OnClose func()

+ RawGo func(rpcHandler IRpcHandler, processor IRpcProcessor, noReply bool, ...) *Call

+ Run func()

+ SetConn func(conn *network.TCPConn)

type IRpcHandler

+ GetRpcServer func() FuncRpcServer

type IRpcProcessor

+ Clone func(src interface{}) (interface{}, error)

+ 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

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

+ type LClient struct

+ func (lc *LClient) AsyncCall(rpcHandler IRpcHandler, serviceMethod string, callback reflect.Value, ...) error

+ func (lc *LClient) Close(waitDone bool)

+ func (lc *LClient) Go(rpcHandler IRpcHandler, noReply bool, serviceMethod string, args interface{}, ...) *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(rpcHandler IRpcHandler, processor IRpcProcessor, noReply bool, ...) *Call

+ func (rc *LClient) Unlock()

+ type RClient struct

+ func (rc *RClient) AsyncCall(rpcHandler IRpcHandler, serviceMethod string, callback reflect.Value, ...) error

+ func (rc *RClient) Close(waitDone bool)

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

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

+ func (rc *RClient) IsConnected() bool

+ func (rc *RClient) OnClose()

+ func (rc *RClient) RawGo(rpcHandler IRpcHandler, processor IRpcProcessor, noReply bool, ...) *Call

+ func (rc *RClient) Run()

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

type RankData

+ ExData []*ExtendIncData

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

+ 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 RankPosData

+ ExtendData []int64

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

type RankResult

+ NewRank []*RankInfo

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

type RpcHandler

+ func (handler *RpcHandler) GetRpcServer() FuncRpcServer

+ 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 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

+ FindNewRank bool

+ func (m *UpsetRankData) GetFindNewRank() bool

Nov 23, 2022

Changes in this version

+ const ConnectInterval

+ const Default_ReadWriteDeadline

+ const MaxCheckCallRpcCount

+ const MaxPendingWriteNum

+ var ErrIntOverflowMessagequeue = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowRank = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthMessagequeue = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthRank = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupMessagequeue = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupRank = fmt.Errorf("proto: unexpected end of group")

+ var SubscribeMethod_name = map[int32]string

+ var SubscribeMethod_value = map[string]int32

+ var SubscribeType_name = map[int32]string

+ var SubscribeType_value = map[string]int32

+ 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 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 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 RankData struct

+ Data []byte

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

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

+ 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) 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 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 UpsetRankData struct

+ RankDataList []*RankData

+ RankId uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpsetRankData) ProtoMessage()

+ 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

Jul 11, 2022

Changes in this version

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

Mar 10, 2022

Changes in this version

+ var ErrIntOverflowDynamicdiscover = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowGogorpc = 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 ErrUnexpectedEndOfGroupDynamicdiscover = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupGogorpc = fmt.Errorf("proto: unexpected end of group")

+ var LittleEndian bool

+ func AppendProcessor(rpcProcessor IRpcProcessor)

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

+ func ReleaseCall(call *Call)

+ func ReleaseRpcRequest(rpcRequest *RpcRequest)

+ type Call struct

+ Err error

+ Reply interface{}

+ Response *RpcResponse

+ Seq uint64

+ ServiceMethod string

+ func MakeCall() *Call

+ func (call *Call) Clear() *Call

+ func (call *Call) Done() *Call

+ func (call *Call) IsRef() bool

+ func (call *Call) Ref()

+ func (call *Call) Reset()

+ func (call *Call) UnRef()

+ type Client struct

+ func (client *Client) AddPending(call *Call)

+ func (client *Client) AsyncCall(rpcHandler IRpcHandler, serviceMethod string, callback reflect.Value, ...) error

+ func (client *Client) Close(waitDone bool)

+ func (client *Client) Connect(id int, addr string, maxRpcParamLen uint32) error

+ func (client *Client) FindPending(seq uint64) *Call

+ func (client *Client) GetClientSeq() uint32

+ func (client *Client) GetId() int

+ func (client *Client) Go(noReply bool, serviceMethod string, args interface{}, reply interface{}) *Call

+ func (client *Client) IsConnected() bool

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

+ func (client *Client) OnClose()

+ func (client *Client) RawGo(processor IRpcProcessor, noReply bool, rpcMethodId uint32, ...) *Call

+ func (client *Client) RemovePending(seq uint64) *Call

+ func (client *Client) ResetPending()

+ func (client *Client) Run()

+ 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 FuncRpcClient func(nodeId int, serviceMethod string, client []*Client) (error, int)

+ type FuncRpcServer func() *Server

+ type GoGoPBProcessor struct

+ 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 IRawInputArgs interface

+ DoEscape func()

+ DoFree func()

+ GetRawData func() []byte

+ type IRpcHandler interface

+ AsyncCall func(serviceMethod string, args interface{}, callback interface{}) error

+ AsyncCallNode func(nodeId int, serviceMethod string, args interface{}, callback interface{}) error

+ Call func(serviceMethod string, args interface{}, reply interface{}) error

+ CallMethod func(ServiceMethod string, param interface{}, reply interface{}) error

+ CallNode func(nodeId int, serviceMethod string, args interface{}, reply interface{}) error

+ CastGo func(serviceMethod string, args interface{}) error

+ GetName func() string

+ GetRpcHandler func() IRpcHandler

+ 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 IRpcListener interface

+ OnNodeConnected func(nodeId int)

+ OnNodeDisconnect func(nodeId int)

+ type IRpcProcessor interface

+ 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 JsonProcessor struct

+ 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 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 RawRpcCallBack interface

+ CB func(data interface{})

+ Unmarshal func(data []byte) (interface{}, error)

+ 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 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) Call(serviceMethod string, args interface{}, reply interface{}) error

+ func (handler *RpcHandler) CallMethod(ServiceMethod string, param interface{}, reply interface{}) error

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

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

+ func (handler *RpcHandler) GetName() string

+ func (handler *RpcHandler) GetRpcHandler() IRpcHandler

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

+ 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 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 TriggerRpcEvent func(bConnect bool, clientSeq uint32, nodeId int)