rpc

package
v1.19.6 Latest Latest
Warning

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

 Go to latest Published: May 9, 2023 License: Apache-2.0 Imports: 21 Imported by: 6

Documentation

Index

Constants

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

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

Variables

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

Functions

func AppendProcessor 

func AppendProcessor(rpcProcessor IRpcProcessor)

func GetProcessorType 

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

func ReleaseCall 

func ReleaseCall(call *Call)

func ReleaseRpcRequest 

func ReleaseRpcRequest(rpcRequest *RpcRequest)

Types

type AddRankList added in v1.19.0 

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

AddRankList 新增排行榜

func (*AddRankList) Descriptor added in v1.19.0 

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

func (*AddRankList) GetAddList added in v1.19.0 

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

func (*AddRankList) Marshal added in v1.19.0 

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

func (*AddRankList) MarshalTo added in v1.19.0 

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

func (*AddRankList) MarshalToSizedBuffer added in v1.19.0 

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

func (*AddRankList) ProtoMessage added in v1.19.0 

func (*AddRankList) ProtoMessage()

func (*AddRankList) Reset added in v1.19.0 

func (m *AddRankList) Reset()

func (*AddRankList) Size added in v1.19.0 

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

func (*AddRankList) String added in v1.19.0 

func (m *AddRankList) String() string

func (*AddRankList) Unmarshal added in v1.19.0 

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

func (*AddRankList) XXX_DiscardUnknown added in v1.19.0 

func (m *AddRankList) XXX_DiscardUnknown()

func (*AddRankList) XXX_Marshal added in v1.19.0 

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

func (*AddRankList) XXX_Merge added in v1.19.0 

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

func (*AddRankList) XXX_Size added in v1.19.0 

func (m *AddRankList) XXX_Size() int

func (*AddRankList) XXX_Unmarshal added in v1.19.0 

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

type Call 

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

func MakeCall 

func MakeCall() *Call

func (*Call) Clear 

func (call *Call) Clear() *Call

func (*Call) DoError added in v1.19.6 

func (call *Call) DoError(err error)

func (*Call) DoOK added in v1.19.6 

func (call *Call) DoOK()

func (*Call) Done 

func (call *Call) Done() *Call

func (*Call) IsRef 

func (call *Call) IsRef() bool

func (*Call) Ref 

func (call *Call) Ref()

func (*Call) Reset 

func (call *Call) Reset()

func (*Call) UnRef 

func (call *Call) UnRef()

type Client 

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

func NewLClient added in v1.19.3 

func NewLClient(nodeId int) *Client

func NewRClient added in v1.19.3 

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

func (*Client) AddPending 

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

func (*Client) FindPending 

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

func (*Client) GetClientId added in v1.19.3 

func (client *Client) GetClientId() uint32

func (*Client) GetNodeId added in v1.19.3 

func (client *Client) GetNodeId() int

func (*Client) InitPending added in v1.19.3 

func (client *Client) InitPending()

func (*Client) NewClientAgent 

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

func (*Client) RemovePending 

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

type DBQueuePopReq added in v1.19.0 

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

func (*DBQueuePopReq) Descriptor added in v1.19.0 

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

func (*DBQueuePopReq) GetCustomerId added in v1.19.0 

func (m *DBQueuePopReq) GetCustomerId() string

func (*DBQueuePopReq) GetPopNum added in v1.19.0 

func (m *DBQueuePopReq) GetPopNum() int32

func (*DBQueuePopReq) GetPopStartPos added in v1.19.0 

func (m *DBQueuePopReq) GetPopStartPos() int32

func (*DBQueuePopReq) GetPushData added in v1.19.0 

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

func (*DBQueuePopReq) GetQueueName added in v1.19.0 

func (m *DBQueuePopReq) GetQueueName() string

func (*DBQueuePopReq) Marshal added in v1.19.0 

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

func (*DBQueuePopReq) MarshalTo added in v1.19.0 

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

func (*DBQueuePopReq) MarshalToSizedBuffer added in v1.19.0 

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

func (*DBQueuePopReq) ProtoMessage added in v1.19.0 

func (*DBQueuePopReq) ProtoMessage()

func (*DBQueuePopReq) Reset added in v1.19.0 

func (m *DBQueuePopReq) Reset()

func (*DBQueuePopReq) Size added in v1.19.0 

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

func (*DBQueuePopReq) String added in v1.19.0 

func (m *DBQueuePopReq) String() string

func (*DBQueuePopReq) Unmarshal added in v1.19.0 

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

func (*DBQueuePopReq) XXX_DiscardUnknown added in v1.19.0 

func (m *DBQueuePopReq) XXX_DiscardUnknown()

func (*DBQueuePopReq) XXX_Marshal added in v1.19.0 

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

func (*DBQueuePopReq) XXX_Merge added in v1.19.0 

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

func (*DBQueuePopReq) XXX_Size added in v1.19.0 

func (m *DBQueuePopReq) XXX_Size() int

func (*DBQueuePopReq) XXX_Unmarshal added in v1.19.0 

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

type DBQueuePopRes added in v1.19.0 

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

func (*DBQueuePopRes) Descriptor added in v1.19.0 

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

func (*DBQueuePopRes) GetPushData added in v1.19.0 

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

func (*DBQueuePopRes) GetQueueName added in v1.19.0 

func (m *DBQueuePopRes) GetQueueName() string

func (*DBQueuePopRes) Marshal added in v1.19.0 

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

func (*DBQueuePopRes) MarshalTo added in v1.19.0 

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

func (*DBQueuePopRes) MarshalToSizedBuffer added in v1.19.0 

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

func (*DBQueuePopRes) ProtoMessage added in v1.19.0 

func (*DBQueuePopRes) ProtoMessage()

func (*DBQueuePopRes) Reset added in v1.19.0 

func (m *DBQueuePopRes) Reset()

func (*DBQueuePopRes) Size added in v1.19.0 

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

func (*DBQueuePopRes) String added in v1.19.0 

func (m *DBQueuePopRes) String() string

func (*DBQueuePopRes) Unmarshal added in v1.19.0 

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

func (*DBQueuePopRes) XXX_DiscardUnknown added in v1.19.0 

func (m *DBQueuePopRes) XXX_DiscardUnknown()

func (*DBQueuePopRes) XXX_Marshal added in v1.19.0 

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

func (*DBQueuePopRes) XXX_Merge added in v1.19.0 

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

func (*DBQueuePopRes) XXX_Size added in v1.19.0 

func (m *DBQueuePopRes) XXX_Size() int

func (*DBQueuePopRes) XXX_Unmarshal added in v1.19.0 

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

type DBQueuePublishReq added in v1.19.0 

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

func (*DBQueuePublishReq) Descriptor added in v1.19.0 

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

func (*DBQueuePublishReq) GetPushData added in v1.19.0 

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

func (*DBQueuePublishReq) GetTopicName added in v1.19.0 

func (m *DBQueuePublishReq) GetTopicName() string

func (*DBQueuePublishReq) Marshal added in v1.19.0 

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

func (*DBQueuePublishReq) MarshalTo added in v1.19.0 

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

func (*DBQueuePublishReq) MarshalToSizedBuffer added in v1.19.0 

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

func (*DBQueuePublishReq) ProtoMessage added in v1.19.0 

func (*DBQueuePublishReq) ProtoMessage()

func (*DBQueuePublishReq) Reset added in v1.19.0 

func (m *DBQueuePublishReq) Reset()

func (*DBQueuePublishReq) Size added in v1.19.0 

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

func (*DBQueuePublishReq) String added in v1.19.0 

func (m *DBQueuePublishReq) String() string

func (*DBQueuePublishReq) Unmarshal added in v1.19.0 

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

func (*DBQueuePublishReq) XXX_DiscardUnknown added in v1.19.0 

func (m *DBQueuePublishReq) XXX_DiscardUnknown()

func (*DBQueuePublishReq) XXX_Marshal added in v1.19.0 

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

func (*DBQueuePublishReq) XXX_Merge added in v1.19.0 

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

func (*DBQueuePublishReq) XXX_Size added in v1.19.0 

func (m *DBQueuePublishReq) XXX_Size() int

func (*DBQueuePublishReq) XXX_Unmarshal added in v1.19.0 

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

type DBQueuePublishRes added in v1.19.0 

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

func (*DBQueuePublishRes) Descriptor added in v1.19.0 

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

func (*DBQueuePublishRes) Marshal added in v1.19.0 

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

func (*DBQueuePublishRes) MarshalTo added in v1.19.0 

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

func (*DBQueuePublishRes) MarshalToSizedBuffer added in v1.19.0 

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

func (*DBQueuePublishRes) ProtoMessage added in v1.19.0 

func (*DBQueuePublishRes) ProtoMessage()

func (*DBQueuePublishRes) Reset added in v1.19.0 

func (m *DBQueuePublishRes) Reset()

func (*DBQueuePublishRes) Size added in v1.19.0 

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

func (*DBQueuePublishRes) String added in v1.19.0 

func (m *DBQueuePublishRes) String() string

func (*DBQueuePublishRes) Unmarshal added in v1.19.0 

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

func (*DBQueuePublishRes) XXX_DiscardUnknown added in v1.19.0 

func (m *DBQueuePublishRes) XXX_DiscardUnknown()

func (*DBQueuePublishRes) XXX_Marshal added in v1.19.0 

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

func (*DBQueuePublishRes) XXX_Merge added in v1.19.0 

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

func (*DBQueuePublishRes) XXX_Size added in v1.19.0 

func (m *DBQueuePublishRes) XXX_Size() int

func (*DBQueuePublishRes) XXX_Unmarshal added in v1.19.0 

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

type DBQueueSubscribeReq added in v1.19.0 

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

订阅

func (*DBQueueSubscribeReq) Descriptor added in v1.19.0 

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

func (*DBQueueSubscribeReq) GetCustomerId added in v1.19.0 

func (m *DBQueueSubscribeReq) GetCustomerId() string

func (*DBQueueSubscribeReq) GetFromNodeId added in v1.19.0 

func (m *DBQueueSubscribeReq) GetFromNodeId() int32

func (*DBQueueSubscribeReq) GetMethod added in v1.19.0 

func (m *DBQueueSubscribeReq) GetMethod() SubscribeMethod

func (*DBQueueSubscribeReq) GetOneBatchQuantity added in v1.19.0 

func (m *DBQueueSubscribeReq) GetOneBatchQuantity() int32

func (*DBQueueSubscribeReq) GetRpcMethod added in v1.19.0 

func (m *DBQueueSubscribeReq) GetRpcMethod() string

func (*DBQueueSubscribeReq) GetStartIndex added in v1.19.0 

func (m *DBQueueSubscribeReq) GetStartIndex() uint64

func (*DBQueueSubscribeReq) GetSubType added in v1.19.0 

func (m *DBQueueSubscribeReq) GetSubType() SubscribeType

func (*DBQueueSubscribeReq) GetTopicName added in v1.19.0 

func (m *DBQueueSubscribeReq) GetTopicName() string

func (*DBQueueSubscribeReq) Marshal added in v1.19.0 

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

func (*DBQueueSubscribeReq) MarshalTo added in v1.19.0 

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

func (*DBQueueSubscribeReq) MarshalToSizedBuffer added in v1.19.0 

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

func (*DBQueueSubscribeReq) ProtoMessage added in v1.19.0 

func (*DBQueueSubscribeReq) ProtoMessage()

func (*DBQueueSubscribeReq) Reset added in v1.19.0 

func (m *DBQueueSubscribeReq) Reset()

func (*DBQueueSubscribeReq) Size added in v1.19.0 

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

func (*DBQueueSubscribeReq) String added in v1.19.0 

func (m *DBQueueSubscribeReq) String() string

func (*DBQueueSubscribeReq) Unmarshal added in v1.19.0 

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

func (*DBQueueSubscribeReq) XXX_DiscardUnknown added in v1.19.0 

func (m *DBQueueSubscribeReq) XXX_DiscardUnknown()

func (*DBQueueSubscribeReq) XXX_Marshal added in v1.19.0 

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

func (*DBQueueSubscribeReq) XXX_Merge added in v1.19.0 

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

func (*DBQueueSubscribeReq) XXX_Size added in v1.19.0 

func (m *DBQueueSubscribeReq) XXX_Size() int

func (*DBQueueSubscribeReq) XXX_Unmarshal added in v1.19.0 

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

type DBQueueSubscribeRes added in v1.19.0 

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

func (*DBQueueSubscribeRes) Descriptor added in v1.19.0 

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

func (*DBQueueSubscribeRes) Marshal added in v1.19.0 

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

func (*DBQueueSubscribeRes) MarshalTo added in v1.19.0 

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

func (*DBQueueSubscribeRes) MarshalToSizedBuffer added in v1.19.0 

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

func (*DBQueueSubscribeRes) ProtoMessage added in v1.19.0 

func (*DBQueueSubscribeRes) ProtoMessage()

func (*DBQueueSubscribeRes) Reset added in v1.19.0 

func (m *DBQueueSubscribeRes) Reset()

func (*DBQueueSubscribeRes) Size added in v1.19.0 

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

func (*DBQueueSubscribeRes) String added in v1.19.0 

func (m *DBQueueSubscribeRes) String() string

func (*DBQueueSubscribeRes) Unmarshal added in v1.19.0 

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

func (*DBQueueSubscribeRes) XXX_DiscardUnknown added in v1.19.0 

func (m *DBQueueSubscribeRes) XXX_DiscardUnknown()

func (*DBQueueSubscribeRes) XXX_Marshal added in v1.19.0 

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

func (*DBQueueSubscribeRes) XXX_Merge added in v1.19.0 

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

func (*DBQueueSubscribeRes) XXX_Size added in v1.19.0 

func (m *DBQueueSubscribeRes) XXX_Size() int

func (*DBQueueSubscribeRes) XXX_Unmarshal added in v1.19.0 

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

type DeleteByKey added in v1.19.0 

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

DeleteByKey 删除排行榜数据

func (*DeleteByKey) Descriptor added in v1.19.0 

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

func (*DeleteByKey) GetKeyList added in v1.19.0 

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

func (*DeleteByKey) GetRankId added in v1.19.0 

func (m *DeleteByKey) GetRankId() uint64

func (*DeleteByKey) Marshal added in v1.19.0 

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

func (*DeleteByKey) MarshalTo added in v1.19.0 

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

func (*DeleteByKey) MarshalToSizedBuffer added in v1.19.0 

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

func (*DeleteByKey) ProtoMessage added in v1.19.0 

func (*DeleteByKey) ProtoMessage()

func (*DeleteByKey) Reset added in v1.19.0 

func (m *DeleteByKey) Reset()

func (*DeleteByKey) Size added in v1.19.0 

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

func (*DeleteByKey) String added in v1.19.0 

func (m *DeleteByKey) String() string

func (*DeleteByKey) Unmarshal added in v1.19.0 

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

func (*DeleteByKey) XXX_DiscardUnknown added in v1.19.0 

func (m *DeleteByKey) XXX_DiscardUnknown()

func (*DeleteByKey) XXX_Marshal added in v1.19.0 

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

func (*DeleteByKey) XXX_Merge added in v1.19.0 

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

func (*DeleteByKey) XXX_Size added in v1.19.0 

func (m *DeleteByKey) XXX_Size() int

func (*DeleteByKey) XXX_Unmarshal added in v1.19.0 

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

type Empty 

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

Master->Client

func (*Empty) Descriptor 

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

func (*Empty) Marshal 

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

func (*Empty) MarshalTo 

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

func (*Empty) MarshalToSizedBuffer 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

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

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) Unmarshal 

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

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type ExtendIncData added in v1.19.3 

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

func (*ExtendIncData) Descriptor added in v1.19.3 

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

func (*ExtendIncData) GetIncreaseValue added in v1.19.3 

func (m *ExtendIncData) GetIncreaseValue() int64

func (*ExtendIncData) GetInitValue added in v1.19.3 

func (m *ExtendIncData) GetInitValue() int64

func (*ExtendIncData) Marshal added in v1.19.3 

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

func (*ExtendIncData) MarshalTo added in v1.19.3 

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

func (*ExtendIncData) MarshalToSizedBuffer added in v1.19.3 

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

func (*ExtendIncData) ProtoMessage added in v1.19.3 

func (*ExtendIncData) ProtoMessage()

func (*ExtendIncData) Reset added in v1.19.3 

func (m *ExtendIncData) Reset()

func (*ExtendIncData) Size added in v1.19.3 

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

func (*ExtendIncData) String added in v1.19.3 

func (m *ExtendIncData) String() string

func (*ExtendIncData) Unmarshal added in v1.19.3 

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

func (*ExtendIncData) XXX_DiscardUnknown added in v1.19.3 

func (m *ExtendIncData) XXX_DiscardUnknown()

func (*ExtendIncData) XXX_Marshal added in v1.19.3 

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

func (*ExtendIncData) XXX_Merge added in v1.19.3 

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

func (*ExtendIncData) XXX_Size added in v1.19.3 

func (m *ExtendIncData) XXX_Size() int

func (*ExtendIncData) XXX_Unmarshal added in v1.19.3 

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

type FindRankDataByKey added in v1.19.0 

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

FindRankDataByKey 查找排行信息

func (*FindRankDataByKey) Descriptor added in v1.19.0 

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

func (*FindRankDataByKey) GetKey added in v1.19.0 

func (m *FindRankDataByKey) GetKey() uint64

func (*FindRankDataByKey) GetRankId added in v1.19.0 

func (m *FindRankDataByKey) GetRankId() uint64

func (*FindRankDataByKey) Marshal added in v1.19.0 

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

func (*FindRankDataByKey) MarshalTo added in v1.19.0 

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

func (*FindRankDataByKey) MarshalToSizedBuffer added in v1.19.0 

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

func (*FindRankDataByKey) ProtoMessage added in v1.19.0 

func (*FindRankDataByKey) ProtoMessage()

func (*FindRankDataByKey) Reset added in v1.19.0 

func (m *FindRankDataByKey) Reset()

func (*FindRankDataByKey) Size added in v1.19.0 

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

func (*FindRankDataByKey) String added in v1.19.0 

func (m *FindRankDataByKey) String() string

func (*FindRankDataByKey) Unmarshal added in v1.19.0 

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

func (*FindRankDataByKey) XXX_DiscardUnknown added in v1.19.0 

func (m *FindRankDataByKey) XXX_DiscardUnknown()

func (*FindRankDataByKey) XXX_Marshal added in v1.19.0 

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

func (*FindRankDataByKey) XXX_Merge added in v1.19.0 

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

func (*FindRankDataByKey) XXX_Size added in v1.19.0 

func (m *FindRankDataByKey) XXX_Size() int

func (*FindRankDataByKey) XXX_Unmarshal added in v1.19.0 

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

type FindRankDataByRank added in v1.19.0 

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

FindRankDataByRank 查找排行信息

func (*FindRankDataByRank) Descriptor added in v1.19.0 

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

func (*FindRankDataByRank) GetRank added in v1.19.0 

func (m *FindRankDataByRank) GetRank() uint64

func (*FindRankDataByRank) GetRankId added in v1.19.0 

func (m *FindRankDataByRank) GetRankId() uint64

func (*FindRankDataByRank) Marshal added in v1.19.0 

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

func (*FindRankDataByRank) MarshalTo added in v1.19.0 

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

func (*FindRankDataByRank) MarshalToSizedBuffer added in v1.19.0 

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

func (*FindRankDataByRank) ProtoMessage added in v1.19.0 

func (*FindRankDataByRank) ProtoMessage()

func (*FindRankDataByRank) Reset added in v1.19.0 

func (m *FindRankDataByRank) Reset()

func (*FindRankDataByRank) Size added in v1.19.0 

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

func (*FindRankDataByRank) String added in v1.19.0 

func (m *FindRankDataByRank) String() string

func (*FindRankDataByRank) Unmarshal added in v1.19.0 

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

func (*FindRankDataByRank) XXX_DiscardUnknown added in v1.19.0 

func (m *FindRankDataByRank) XXX_DiscardUnknown()

func (*FindRankDataByRank) XXX_Marshal added in v1.19.0 

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

func (*FindRankDataByRank) XXX_Merge added in v1.19.0 

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

func (*FindRankDataByRank) XXX_Size added in v1.19.0 

func (m *FindRankDataByRank) XXX_Size() int

func (*FindRankDataByRank) XXX_Unmarshal added in v1.19.0 

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

type FindRankDataList added in v1.19.0 

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

FindRankDataList 查找排行信息

func (*FindRankDataList) Descriptor added in v1.19.0 

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

func (*FindRankDataList) GetCount added in v1.19.0 

func (m *FindRankDataList) GetCount() uint64

func (*FindRankDataList) GetKey added in v1.19.0 

func (m *FindRankDataList) GetKey() uint64

func (*FindRankDataList) GetRankId added in v1.19.0 

func (m *FindRankDataList) GetRankId() uint64

func (*FindRankDataList) GetStartRank added in v1.19.0 

func (m *FindRankDataList) GetStartRank() uint64

func (*FindRankDataList) Marshal added in v1.19.0 

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

func (*FindRankDataList) MarshalTo added in v1.19.0 

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

func (*FindRankDataList) MarshalToSizedBuffer added in v1.19.0 

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

func (*FindRankDataList) ProtoMessage added in v1.19.0 

func (*FindRankDataList) ProtoMessage()

func (*FindRankDataList) Reset added in v1.19.0 

func (m *FindRankDataList) Reset()

func (*FindRankDataList) Size added in v1.19.0 

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

func (*FindRankDataList) String added in v1.19.0 

func (m *FindRankDataList) String() string

func (*FindRankDataList) Unmarshal added in v1.19.0 

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

func (*FindRankDataList) XXX_DiscardUnknown added in v1.19.0 

func (m *FindRankDataList) XXX_DiscardUnknown()

func (*FindRankDataList) XXX_Marshal added in v1.19.0 

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

func (*FindRankDataList) XXX_Merge added in v1.19.0 

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

func (*FindRankDataList) XXX_Size added in v1.19.0 

func (m *FindRankDataList) XXX_Size() int

func (*FindRankDataList) XXX_Unmarshal added in v1.19.0 

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

type FuncRpcClient 

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

type FuncRpcServer 

type FuncRpcServer func() *Server

type GoGoPBProcessor 

type GoGoPBProcessor struct {
}

func (*GoGoPBProcessor) Clone added in v1.19.3 

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

func (*GoGoPBProcessor) GetProcessorType 

func (slf *GoGoPBProcessor) GetProcessorType() RpcProcessorType

func (*GoGoPBProcessor) IsParse 

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

func (*GoGoPBProcessor) MakeRpcRequest 

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

func (*GoGoPBProcessor) MakeRpcResponse 

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

func (*GoGoPBProcessor) Marshal 

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

func (*GoGoPBProcessor) ReleaseRpcRequest 

func (slf *GoGoPBProcessor) ReleaseRpcRequest(rpcRequestData IRpcRequestData)

func (*GoGoPBProcessor) ReleaseRpcResponse 

func (slf *GoGoPBProcessor) ReleaseRpcResponse(rpcResponseData IRpcResponseData)

func (*GoGoPBProcessor) Unmarshal 

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

type GoGoPBRpcRequestData 

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

func (*GoGoPBRpcRequestData) Descriptor 

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

func (*GoGoPBRpcRequestData) GetInParam 

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

func (*GoGoPBRpcRequestData) GetNoReply 

func (m *GoGoPBRpcRequestData) GetNoReply() bool

func (*GoGoPBRpcRequestData) GetRpcMethodId 

func (m *GoGoPBRpcRequestData) GetRpcMethodId() uint32

func (*GoGoPBRpcRequestData) GetSeq 

func (m *GoGoPBRpcRequestData) GetSeq() uint64

func (*GoGoPBRpcRequestData) GetServiceMethod 

func (m *GoGoPBRpcRequestData) GetServiceMethod() string

func (*GoGoPBRpcRequestData) IsNoReply 

func (slf *GoGoPBRpcRequestData) IsNoReply() bool

func (*GoGoPBRpcRequestData) MakeRequest 

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

func (*GoGoPBRpcRequestData) Marshal 

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

func (*GoGoPBRpcRequestData) MarshalTo 

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

func (*GoGoPBRpcRequestData) MarshalToSizedBuffer 

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

func (*GoGoPBRpcRequestData) ProtoMessage 

func (*GoGoPBRpcRequestData) ProtoMessage()

func (*GoGoPBRpcRequestData) Reset 

func (m *GoGoPBRpcRequestData) Reset()

func (*GoGoPBRpcRequestData) Size 

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

func (*GoGoPBRpcRequestData) String 

func (m *GoGoPBRpcRequestData) String() string

func (*GoGoPBRpcRequestData) Unmarshal 

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

func (*GoGoPBRpcRequestData) XXX_DiscardUnknown 

func (m *GoGoPBRpcRequestData) XXX_DiscardUnknown()

func (*GoGoPBRpcRequestData) XXX_Marshal 

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

func (*GoGoPBRpcRequestData) XXX_Merge 

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

func (*GoGoPBRpcRequestData) XXX_Size 

func (m *GoGoPBRpcRequestData) XXX_Size() int

func (*GoGoPBRpcRequestData) XXX_Unmarshal 

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

type GoGoPBRpcResponseData 

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

func (*GoGoPBRpcResponseData) Descriptor 

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

func (*GoGoPBRpcResponseData) GetErr 

func (slf *GoGoPBRpcResponseData) GetErr() *RpcError

func (*GoGoPBRpcResponseData) GetError 

func (m *GoGoPBRpcResponseData) GetError() string

func (*GoGoPBRpcResponseData) GetReply 

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

func (*GoGoPBRpcResponseData) GetSeq 

func (m *GoGoPBRpcResponseData) GetSeq() uint64

func (*GoGoPBRpcResponseData) MakeRespone 

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

func (*GoGoPBRpcResponseData) Marshal 

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

func (*GoGoPBRpcResponseData) MarshalTo 

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

func (*GoGoPBRpcResponseData) MarshalToSizedBuffer 

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

func (*GoGoPBRpcResponseData) ProtoMessage 

func (*GoGoPBRpcResponseData) ProtoMessage()

func (*GoGoPBRpcResponseData) Reset 

func (m *GoGoPBRpcResponseData) Reset()

func (*GoGoPBRpcResponseData) Size 

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

func (*GoGoPBRpcResponseData) String 

func (m *GoGoPBRpcResponseData) String() string

func (*GoGoPBRpcResponseData) Unmarshal 

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

func (*GoGoPBRpcResponseData) XXX_DiscardUnknown 

func (m *GoGoPBRpcResponseData) XXX_DiscardUnknown()

func (*GoGoPBRpcResponseData) XXX_Marshal 

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

func (*GoGoPBRpcResponseData) XXX_Merge 

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

func (*GoGoPBRpcResponseData) XXX_Size 

func (m *GoGoPBRpcResponseData) XXX_Size() int

func (*GoGoPBRpcResponseData) XXX_Unmarshal 

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

type IDiscoveryServiceListener added in v1.18.3 

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

type INodeListener added in v1.18.3 

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

type IRealClient added in v1.19.3 

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

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

	Run()
	OnClose()
}

type IRpcHandler 

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

type IRpcHandlerChannel 

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

type IRpcProcessor 

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

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

func GetProcessor 

func GetProcessor(processorType uint8) IRpcProcessor

type IRpcRequestData 

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

type IRpcResponseData 

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

type IncreaseRankData added in v1.19.3 

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

自增值

func (*IncreaseRankData) Descriptor added in v1.19.3 

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

func (*IncreaseRankData) GetExtend added in v1.19.3 

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

func (*IncreaseRankData) GetIncreaseSortData added in v1.19.3 

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

func (*IncreaseRankData) GetInitData added in v1.19.3 

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

func (*IncreaseRankData) GetInitSortData added in v1.19.3 

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

func (*IncreaseRankData) GetInsertDataOnNonExistent added in v1.19.3 

func (m *IncreaseRankData) GetInsertDataOnNonExistent() bool

func (*IncreaseRankData) GetKey added in v1.19.3 

func (m *IncreaseRankData) GetKey() uint64

func (*IncreaseRankData) GetRankId added in v1.19.3 

func (m *IncreaseRankData) GetRankId() uint64

func (*IncreaseRankData) GetReturnRankData added in v1.19.3 

func (m *IncreaseRankData) GetReturnRankData() bool

func (*IncreaseRankData) GetSetSortAndExtendData added in v1.19.3 

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

func (*IncreaseRankData) Marshal added in v1.19.3 

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

func (*IncreaseRankData) MarshalTo added in v1.19.3 

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

func (*IncreaseRankData) MarshalToSizedBuffer added in v1.19.3 

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

func (*IncreaseRankData) ProtoMessage added in v1.19.3 

func (*IncreaseRankData) ProtoMessage()

func (*IncreaseRankData) Reset added in v1.19.3 

func (m *IncreaseRankData) Reset()

func (*IncreaseRankData) Size added in v1.19.3 

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

func (*IncreaseRankData) String added in v1.19.3 

func (m *IncreaseRankData) String() string

func (*IncreaseRankData) Unmarshal added in v1.19.3 

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

func (*IncreaseRankData) XXX_DiscardUnknown added in v1.19.3 

func (m *IncreaseRankData) XXX_DiscardUnknown()

func (*IncreaseRankData) XXX_Marshal added in v1.19.3 

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

func (*IncreaseRankData) XXX_Merge added in v1.19.3 

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

func (*IncreaseRankData) XXX_Size added in v1.19.3 

func (m *IncreaseRankData) XXX_Size() int

func (*IncreaseRankData) XXX_Unmarshal added in v1.19.3 

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

type IncreaseRankDataRet added in v1.19.3 

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

func (*IncreaseRankDataRet) Descriptor added in v1.19.3 

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

func (*IncreaseRankDataRet) GetPosData added in v1.19.3 

func (m *IncreaseRankDataRet) GetPosData() *RankPosData

func (*IncreaseRankDataRet) Marshal added in v1.19.3 

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

func (*IncreaseRankDataRet) MarshalTo added in v1.19.3 

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

func (*IncreaseRankDataRet) MarshalToSizedBuffer added in v1.19.3 

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

func (*IncreaseRankDataRet) ProtoMessage added in v1.19.3 

func (*IncreaseRankDataRet) ProtoMessage()

func (*IncreaseRankDataRet) Reset added in v1.19.3 

func (m *IncreaseRankDataRet) Reset()

func (*IncreaseRankDataRet) Size added in v1.19.3 

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

func (*IncreaseRankDataRet) String added in v1.19.3 

func (m *IncreaseRankDataRet) String() string

func (*IncreaseRankDataRet) Unmarshal added in v1.19.3 

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

func (*IncreaseRankDataRet) XXX_DiscardUnknown added in v1.19.3 

func (m *IncreaseRankDataRet) XXX_DiscardUnknown()

func (*IncreaseRankDataRet) XXX_Marshal added in v1.19.3 

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

func (*IncreaseRankDataRet) XXX_Merge added in v1.19.3 

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

func (*IncreaseRankDataRet) XXX_Size added in v1.19.3 

func (m *IncreaseRankDataRet) XXX_Size() int

func (*IncreaseRankDataRet) XXX_Unmarshal added in v1.19.3 

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

type JsonProcessor 

type JsonProcessor struct {
}

func (*JsonProcessor) Clone added in v1.19.3 

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

func (*JsonProcessor) GetProcessorType 

func (jsonProcessor *JsonProcessor) GetProcessorType() RpcProcessorType

func (*JsonProcessor) IsParse 

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

func (*JsonProcessor) MakeRpcRequest 

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

func (*JsonProcessor) MakeRpcResponse 

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

func (*JsonProcessor) Marshal 

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

func (*JsonProcessor) ReleaseRpcRequest 

func (jsonProcessor *JsonProcessor) ReleaseRpcRequest(rpcRequestData IRpcRequestData)

func (*JsonProcessor) ReleaseRpcResponse 

func (jsonProcessor *JsonProcessor) ReleaseRpcResponse(rpcResponseData IRpcResponseData)

func (*JsonProcessor) Unmarshal 

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

type JsonRpcRequestData 

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

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

func (*JsonRpcRequestData) GetInParam 

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

func (*JsonRpcRequestData) GetRpcMethodId 

func (jsonRpcRequestData *JsonRpcRequestData) GetRpcMethodId() uint32

func (*JsonRpcRequestData) GetSeq 

func (jsonRpcRequestData *JsonRpcRequestData) GetSeq() uint64

func (*JsonRpcRequestData) GetServiceMethod 

func (jsonRpcRequestData *JsonRpcRequestData) GetServiceMethod() string

func (*JsonRpcRequestData) IsNoReply 

func (jsonRpcRequestData *JsonRpcRequestData) IsNoReply() bool

type JsonRpcResponseData 

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

	//returns
	Reply []byte
}

func (*JsonRpcResponseData) GetErr 

func (jsonRpcResponseData *JsonRpcResponseData) GetErr() *RpcError

func (*JsonRpcResponseData) GetReply 

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

func (*JsonRpcResponseData) GetSeq 

func (jsonRpcResponseData *JsonRpcResponseData) GetSeq() uint64

type LClient added in v1.19.3 

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

本结点的Client

func (*LClient) AsyncCall added in v1.19.3 

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

func (*LClient) Close added in v1.19.3 

func (lc *LClient) Close(waitDone bool)

func (*LClient) Go added in v1.19.3 

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

func (*LClient) IsConnected added in v1.19.3 

func (lc *LClient) IsConnected() bool

func (*LClient) Lock added in v1.19.3 

func (rc *LClient) Lock()

func (*LClient) OnClose added in v1.19.3 

func (lc *LClient) OnClose()

func (*LClient) RawGo added in v1.19.3 

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

func (*LClient) Run added in v1.19.3 

func (lc *LClient) Run()

func (*LClient) SetConn added in v1.19.3 

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

func (*LClient) Unlock added in v1.19.3 

func (rc *LClient) Unlock()

type NodeInfo 

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

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetListenAddr 

func (m *NodeInfo) GetListenAddr() string

func (*NodeInfo) GetMaxRpcParamLen 

func (m *NodeInfo) GetMaxRpcParamLen() uint32

func (*NodeInfo) GetNodeId 

func (m *NodeInfo) GetNodeId() int32

func (*NodeInfo) GetNodeName 

func (m *NodeInfo) GetNodeName() string

func (*NodeInfo) GetPrivate 

func (m *NodeInfo) GetPrivate() bool

func (*NodeInfo) GetPublicServiceList 

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

func (*NodeInfo) Marshal 

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

func (*NodeInfo) MarshalTo 

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

func (*NodeInfo) MarshalToSizedBuffer 

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

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size 

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

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal 

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

func (*NodeInfo) XXX_DiscardUnknown 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal 

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

func (*NodeInfo) XXX_Merge 

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

func (*NodeInfo) XXX_Size 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal 

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

type RClient added in v1.19.3 

type RClient struct {
	network.TCPClient

	TriggerRpcConnEvent
	// contains filtered or unexported fields
}

跨结点连接的Client

func (*RClient) AsyncCall added in v1.19.3 

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

func (*RClient) Close added in v1.19.3 

func (rc *RClient) Close(waitDone bool)

func (*RClient) GetConn added in v1.19.3 

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

func (*RClient) Go added in v1.19.3 

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

func (*RClient) IsConnected added in v1.19.3 

func (rc *RClient) IsConnected() bool

func (*RClient) OnClose added in v1.19.3 

func (rc *RClient) OnClose()

func (*RClient) RawGo added in v1.19.3 

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

func (*RClient) Run added in v1.19.3 

func (rc *RClient) Run()

func (*RClient) SetConn added in v1.19.3 

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

type RankData added in v1.19.0 

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

RankData 排行数据

func (*RankData) Descriptor added in v1.19.0 

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

func (*RankData) GetData added in v1.19.0 

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

func (*RankData) GetExData added in v1.19.3 

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

func (*RankData) GetKey added in v1.19.0 

func (m *RankData) GetKey() uint64

func (*RankData) GetSortData added in v1.19.0 

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

func (*RankData) Marshal added in v1.19.0 

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

func (*RankData) MarshalTo added in v1.19.0 

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

func (*RankData) MarshalToSizedBuffer added in v1.19.0 

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

func (*RankData) ProtoMessage added in v1.19.0 

func (*RankData) ProtoMessage()

func (*RankData) Reset added in v1.19.0 

func (m *RankData) Reset()

func (*RankData) Size added in v1.19.0 

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

func (*RankData) String added in v1.19.0 

func (m *RankData) String() string

func (*RankData) Unmarshal added in v1.19.0 

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

func (*RankData) XXX_DiscardUnknown added in v1.19.0 

func (m *RankData) XXX_DiscardUnknown()

func (*RankData) XXX_Marshal added in v1.19.0 

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

func (*RankData) XXX_Merge added in v1.19.0 

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

func (*RankData) XXX_Size added in v1.19.0 

func (m *RankData) XXX_Size() int

func (*RankData) XXX_Unmarshal added in v1.19.0 

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

type RankDataList added in v1.19.0 

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

RankDataList

func (*RankDataList) Descriptor added in v1.19.0 

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

func (*RankDataList) GetKeyRank added in v1.19.0 

func (m *RankDataList) GetKeyRank() *RankPosData

func (*RankDataList) GetRankDataCount added in v1.19.0 

func (m *RankDataList) GetRankDataCount() uint64

func (*RankDataList) GetRankPosDataList added in v1.19.0 

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

func (*RankDataList) Marshal added in v1.19.0 

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

func (*RankDataList) MarshalTo added in v1.19.0 

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

func (*RankDataList) MarshalToSizedBuffer added in v1.19.0 

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

func (*RankDataList) ProtoMessage added in v1.19.0 

func (*RankDataList) ProtoMessage()

func (*RankDataList) Reset added in v1.19.0 

func (m *RankDataList) Reset()

func (*RankDataList) Size added in v1.19.0 

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

func (*RankDataList) String added in v1.19.0 

func (m *RankDataList) String() string

func (*RankDataList) Unmarshal added in v1.19.0 

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

func (*RankDataList) XXX_DiscardUnknown added in v1.19.0 

func (m *RankDataList) XXX_DiscardUnknown()

func (*RankDataList) XXX_Marshal added in v1.19.0 

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

func (*RankDataList) XXX_Merge added in v1.19.0 

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

func (*RankDataList) XXX_Size added in v1.19.0 

func (m *RankDataList) XXX_Size() int

func (*RankDataList) XXX_Unmarshal added in v1.19.0 

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

type RankInfo added in v1.19.3 

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

func (*RankInfo) Descriptor added in v1.19.3 

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

func (*RankInfo) GetKey added in v1.19.3 

func (m *RankInfo) GetKey() uint64

func (*RankInfo) GetRank added in v1.19.3 

func (m *RankInfo) GetRank() uint64

func (*RankInfo) Marshal added in v1.19.3 

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

func (*RankInfo) MarshalTo added in v1.19.3 

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

func (*RankInfo) MarshalToSizedBuffer added in v1.19.3 

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

func (*RankInfo) ProtoMessage added in v1.19.3 

func (*RankInfo) ProtoMessage()

func (*RankInfo) Reset added in v1.19.3 

func (m *RankInfo) Reset()

func (*RankInfo) Size added in v1.19.3 

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

func (*RankInfo) String added in v1.19.3 

func (m *RankInfo) String() string

func (*RankInfo) Unmarshal added in v1.19.3 

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

func (*RankInfo) XXX_DiscardUnknown added in v1.19.3 

func (m *RankInfo) XXX_DiscardUnknown()

func (*RankInfo) XXX_Marshal added in v1.19.3 

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

func (*RankInfo) XXX_Merge added in v1.19.3 

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

func (*RankInfo) XXX_Size added in v1.19.3 

func (m *RankInfo) XXX_Size() int

func (*RankInfo) XXX_Unmarshal added in v1.19.3 

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

type RankList added in v1.19.0 

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

RankList 排行榜数据

func (*RankList) Descriptor added in v1.19.0 

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

func (*RankList) GetExpireMs added in v1.19.0 

func (m *RankList) GetExpireMs() int64

func (*RankList) GetIsDec added in v1.19.0 

func (m *RankList) GetIsDec() bool

func (*RankList) GetMaxRank added in v1.19.0 

func (m *RankList) GetMaxRank() uint64

func (*RankList) GetRankId added in v1.19.0 

func (m *RankList) GetRankId() uint64

func (*RankList) GetRankName added in v1.19.0 

func (m *RankList) GetRankName() string

func (*RankList) GetSkipListLevel added in v1.19.0 

func (m *RankList) GetSkipListLevel() int32

func (*RankList) Marshal added in v1.19.0 

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

func (*RankList) MarshalTo added in v1.19.0 

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

func (*RankList) MarshalToSizedBuffer added in v1.19.0 

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

func (*RankList) ProtoMessage added in v1.19.0 

func (*RankList) ProtoMessage()

func (*RankList) Reset added in v1.19.0 

func (m *RankList) Reset()

func (*RankList) Size added in v1.19.0 

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

func (*RankList) String added in v1.19.0 

func (m *RankList) String() string

func (*RankList) Unmarshal added in v1.19.0 

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

func (*RankList) XXX_DiscardUnknown added in v1.19.0 

func (m *RankList) XXX_DiscardUnknown()

func (*RankList) XXX_Marshal added in v1.19.0 

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

func (*RankList) XXX_Merge added in v1.19.0 

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

func (*RankList) XXX_Size added in v1.19.0 

func (m *RankList) XXX_Size() int

func (*RankList) XXX_Unmarshal added in v1.19.0 

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

type RankPosData added in v1.19.0 

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

RankPosData 排行数据——查询返回

func (*RankPosData) Descriptor added in v1.19.0 

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

func (*RankPosData) GetData added in v1.19.0 

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

func (*RankPosData) GetExtendData added in v1.19.3 

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

func (*RankPosData) GetKey added in v1.19.0 

func (m *RankPosData) GetKey() uint64

func (*RankPosData) GetRank added in v1.19.0 

func (m *RankPosData) GetRank() uint64

func (*RankPosData) GetSortData added in v1.19.0 

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

func (*RankPosData) Marshal added in v1.19.0 

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

func (*RankPosData) MarshalTo added in v1.19.0 

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

func (*RankPosData) MarshalToSizedBuffer added in v1.19.0 

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

func (*RankPosData) ProtoMessage added in v1.19.0 

func (*RankPosData) ProtoMessage()

func (*RankPosData) Reset added in v1.19.0 

func (m *RankPosData) Reset()

func (*RankPosData) Size added in v1.19.0 

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

func (*RankPosData) String added in v1.19.0 

func (m *RankPosData) String() string

func (*RankPosData) Unmarshal added in v1.19.0 

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

func (*RankPosData) XXX_DiscardUnknown added in v1.19.0 

func (m *RankPosData) XXX_DiscardUnknown()

func (*RankPosData) XXX_Marshal added in v1.19.0 

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

func (*RankPosData) XXX_Merge added in v1.19.0 

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

func (*RankPosData) XXX_Size added in v1.19.0 

func (m *RankPosData) XXX_Size() int

func (*RankPosData) XXX_Unmarshal added in v1.19.0 

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

type RankResult added in v1.19.0 

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

RankResult

func (*RankResult) Descriptor added in v1.19.0 

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

func (*RankResult) GetAddCount added in v1.19.0 

func (m *RankResult) GetAddCount() int32

func (*RankResult) GetModifyCount added in v1.19.0 

func (m *RankResult) GetModifyCount() int32

func (*RankResult) GetNewRank added in v1.19.3 

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

func (*RankResult) GetRemoveCount added in v1.19.0 

func (m *RankResult) GetRemoveCount() int32

func (*RankResult) Marshal added in v1.19.0 

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

func (*RankResult) MarshalTo added in v1.19.0 

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

func (*RankResult) MarshalToSizedBuffer added in v1.19.0 

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

func (*RankResult) ProtoMessage added in v1.19.0 

func (*RankResult) ProtoMessage()

func (*RankResult) Reset added in v1.19.0 

func (m *RankResult) Reset()

func (*RankResult) Size added in v1.19.0 

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

func (*RankResult) String added in v1.19.0 

func (m *RankResult) String() string

func (*RankResult) Unmarshal added in v1.19.0 

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

func (*RankResult) XXX_DiscardUnknown added in v1.19.0 

func (m *RankResult) XXX_DiscardUnknown()

func (*RankResult) XXX_Marshal added in v1.19.0 

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

func (*RankResult) XXX_Merge added in v1.19.0 

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

func (*RankResult) XXX_Size added in v1.19.0 

func (m *RankResult) XXX_Size() int

func (*RankResult) XXX_Unmarshal added in v1.19.0 

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

type RawRpcCallBack 

type RawRpcCallBack func(rawData []byte)

type RequestHandler 

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

type Responder 

type Responder = RequestHandler

func (*Responder) IsInvalid 

func (r *Responder) IsInvalid() bool

type RpcAgent 

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

func (*RpcAgent) Close 

func (agent *RpcAgent) Close()

func (*RpcAgent) Destroy 

func (agent *RpcAgent) Destroy()

func (*RpcAgent) LocalAddr 

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

func (*RpcAgent) OnClose 

func (agent *RpcAgent) OnClose()

func (*RpcAgent) OnDestroy 

func (agent *RpcAgent) OnDestroy()

func (*RpcAgent) RemoteAddr 

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

func (*RpcAgent) Run 

func (agent *RpcAgent) Run()

func (*RpcAgent) WriteMsg 

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

func (*RpcAgent) WriteResponse 

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

type RpcError 

type RpcError string
var NilError RpcError

func ConvertError 

func ConvertError(e error) RpcError

func (RpcError) Error 

func (e RpcError) Error() string

type RpcHandleFinder 

type RpcHandleFinder interface {
	FindRpcHandler(serviceMethod string) IRpcHandler
}

type RpcHandler 

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

func (*RpcHandler) AsyncCall 

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

func (*RpcHandler) AsyncCallNode 

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

func (*RpcHandler) Call 

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

func (*RpcHandler) CallMethod 

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

func (*RpcHandler) CallNode 

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

func (*RpcHandler) CastGo 

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

func (*RpcHandler) GetName 

func (handler *RpcHandler) GetName() string

func (*RpcHandler) GetRpcHandler 

func (handler *RpcHandler) GetRpcHandler() IRpcHandler

func (*RpcHandler) GetRpcServer added in v1.19.3 

func (handler *RpcHandler) GetRpcServer() FuncRpcServer

func (*RpcHandler) Go 

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

func (*RpcHandler) GoNode 

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

func (*RpcHandler) HandlerRpcRequest 

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

func (*RpcHandler) HandlerRpcResponseCB 

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

func (*RpcHandler) InitRpcHandler 

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

func (*RpcHandler) IsSingleCoroutine 

func (handler *RpcHandler) IsSingleCoroutine() bool

func (*RpcHandler) RawGoNode 

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

func (*RpcHandler) RegRawRpc 

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

func (*RpcHandler) RegisterRpc 

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

func (*RpcHandler) UnmarshalInParam 

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

type RpcMethodInfo 

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

type RpcProcessorType 

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

type RpcRequest 

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

func MakeRpcRequest 

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

func (*RpcRequest) Clear 

func (slf *RpcRequest) Clear() *RpcRequest

func (*RpcRequest) IsRef 

func (slf *RpcRequest) IsRef() bool

func (*RpcRequest) Ref 

func (slf *RpcRequest) Ref()

func (*RpcRequest) Reset 

func (slf *RpcRequest) Reset()

func (*RpcRequest) UnRef 

func (slf *RpcRequest) UnRef()

type RpcResponse 

type RpcResponse struct {
	RpcResponseData IRpcResponseData
}

func (*RpcResponse) Clear 

func (rpcResponse *RpcResponse) Clear() *RpcResponse

type Server 

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

func (*Server) Init 

func (server *Server) Init(rpcHandleFinder RpcHandleFinder)

func (*Server) NewAgent 

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

func (*Server) Start 

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

type ServiceDiscoverReq 

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

Client->Master

func (*ServiceDiscoverReq) Descriptor 

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

func (*ServiceDiscoverReq) GetNodeInfo 

func (m *ServiceDiscoverReq) GetNodeInfo() *NodeInfo

func (*ServiceDiscoverReq) Marshal 

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

func (*ServiceDiscoverReq) MarshalTo 

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

func (*ServiceDiscoverReq) MarshalToSizedBuffer 

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

func (*ServiceDiscoverReq) ProtoMessage 

func (*ServiceDiscoverReq) ProtoMessage()

func (*ServiceDiscoverReq) Reset 

func (m *ServiceDiscoverReq) Reset()

func (*ServiceDiscoverReq) Size 

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

func (*ServiceDiscoverReq) String 

func (m *ServiceDiscoverReq) String() string

func (*ServiceDiscoverReq) Unmarshal 

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

func (*ServiceDiscoverReq) XXX_DiscardUnknown 

func (m *ServiceDiscoverReq) XXX_DiscardUnknown()

func (*ServiceDiscoverReq) XXX_Marshal 

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

func (*ServiceDiscoverReq) XXX_Merge 

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

func (*ServiceDiscoverReq) XXX_Size 

func (m *ServiceDiscoverReq) XXX_Size() int

func (*ServiceDiscoverReq) XXX_Unmarshal 

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

type SetSortAndExtendData added in v1.19.3 

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

func (*SetSortAndExtendData) Descriptor added in v1.19.3 

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

func (*SetSortAndExtendData) GetData added in v1.19.3 

func (m *SetSortAndExtendData) GetData() int64

func (*SetSortAndExtendData) GetIsSortData added in v1.19.3 

func (m *SetSortAndExtendData) GetIsSortData() bool

func (*SetSortAndExtendData) GetPos added in v1.19.3 

func (m *SetSortAndExtendData) GetPos() int32

func (*SetSortAndExtendData) Marshal added in v1.19.3 

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

func (*SetSortAndExtendData) MarshalTo added in v1.19.3 

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

func (*SetSortAndExtendData) MarshalToSizedBuffer added in v1.19.3 

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

func (*SetSortAndExtendData) ProtoMessage added in v1.19.3 

func (*SetSortAndExtendData) ProtoMessage()

func (*SetSortAndExtendData) Reset added in v1.19.3 

func (m *SetSortAndExtendData) Reset()

func (*SetSortAndExtendData) Size added in v1.19.3 

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

func (*SetSortAndExtendData) String added in v1.19.3 

func (m *SetSortAndExtendData) String() string

func (*SetSortAndExtendData) Unmarshal added in v1.19.3 

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

func (*SetSortAndExtendData) XXX_DiscardUnknown added in v1.19.3 

func (m *SetSortAndExtendData) XXX_DiscardUnknown()

func (*SetSortAndExtendData) XXX_Marshal added in v1.19.3 

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

func (*SetSortAndExtendData) XXX_Merge added in v1.19.3 

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

func (*SetSortAndExtendData) XXX_Size added in v1.19.3 

func (m *SetSortAndExtendData) XXX_Size() int

func (*SetSortAndExtendData) XXX_Unmarshal added in v1.19.3 

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

type SubscribeDiscoverNotify 

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

Master->Client

func (*SubscribeDiscoverNotify) Descriptor 

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

func (*SubscribeDiscoverNotify) GetDelNodeId 

func (m *SubscribeDiscoverNotify) GetDelNodeId() int32

func (*SubscribeDiscoverNotify) GetIsFull 

func (m *SubscribeDiscoverNotify) GetIsFull() bool

func (*SubscribeDiscoverNotify) GetMasterNodeId 

func (m *SubscribeDiscoverNotify) GetMasterNodeId() int32

func (*SubscribeDiscoverNotify) GetNodeInfo 

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

func (*SubscribeDiscoverNotify) Marshal 

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

func (*SubscribeDiscoverNotify) MarshalTo 

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

func (*SubscribeDiscoverNotify) MarshalToSizedBuffer 

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

func (*SubscribeDiscoverNotify) ProtoMessage 

func (*SubscribeDiscoverNotify) ProtoMessage()

func (*SubscribeDiscoverNotify) Reset 

func (m *SubscribeDiscoverNotify) Reset()

func (*SubscribeDiscoverNotify) Size 

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

func (*SubscribeDiscoverNotify) String 

func (m *SubscribeDiscoverNotify) String() string

func (*SubscribeDiscoverNotify) Unmarshal 

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

func (*SubscribeDiscoverNotify) XXX_DiscardUnknown 

func (m *SubscribeDiscoverNotify) XXX_DiscardUnknown()

func (*SubscribeDiscoverNotify) XXX_Marshal 

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

func (*SubscribeDiscoverNotify) XXX_Merge 

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

func (*SubscribeDiscoverNotify) XXX_Size 

func (m *SubscribeDiscoverNotify) XXX_Size() int

func (*SubscribeDiscoverNotify) XXX_Unmarshal 

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

type SubscribeMethod added in v1.19.0 

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

func (SubscribeMethod) EnumDescriptor added in v1.19.0 

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

func (SubscribeMethod) String added in v1.19.0 

func (x SubscribeMethod) String() string

type SubscribeType added in v1.19.0 

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

func (SubscribeType) EnumDescriptor added in v1.19.0 

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

func (SubscribeType) String added in v1.19.0 

func (x SubscribeType) String() string

type TriggerRpcConnEvent added in v1.19.3 

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

type UpdateRankData added in v1.19.3 

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

用于单独刷新排行榜数据

func (*UpdateRankData) Descriptor added in v1.19.3 

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

func (*UpdateRankData) GetData added in v1.19.3 

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

func (*UpdateRankData) GetKey added in v1.19.3 

func (m *UpdateRankData) GetKey() uint64

func (*UpdateRankData) GetRankId added in v1.19.3 

func (m *UpdateRankData) GetRankId() uint64

func (*UpdateRankData) Marshal added in v1.19.3 

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

func (*UpdateRankData) MarshalTo added in v1.19.3 

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

func (*UpdateRankData) MarshalToSizedBuffer added in v1.19.3 

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

func (*UpdateRankData) ProtoMessage added in v1.19.3 

func (*UpdateRankData) ProtoMessage()

func (*UpdateRankData) Reset added in v1.19.3 

func (m *UpdateRankData) Reset()

func (*UpdateRankData) Size added in v1.19.3 

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

func (*UpdateRankData) String added in v1.19.3 

func (m *UpdateRankData) String() string

func (*UpdateRankData) Unmarshal added in v1.19.3 

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

func (*UpdateRankData) XXX_DiscardUnknown added in v1.19.3 

func (m *UpdateRankData) XXX_DiscardUnknown()

func (*UpdateRankData) XXX_Marshal added in v1.19.3 

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

func (*UpdateRankData) XXX_Merge added in v1.19.3 

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

func (*UpdateRankData) XXX_Size added in v1.19.3 

func (m *UpdateRankData) XXX_Size() int

func (*UpdateRankData) XXX_Unmarshal added in v1.19.3 

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

type UpdateRankDataRet added in v1.19.3 

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

func (*UpdateRankDataRet) Descriptor added in v1.19.3 

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

func (*UpdateRankDataRet) GetRet added in v1.19.3 

func (m *UpdateRankDataRet) GetRet() bool

func (*UpdateRankDataRet) Marshal added in v1.19.3 

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

func (*UpdateRankDataRet) MarshalTo added in v1.19.3 

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

func (*UpdateRankDataRet) MarshalToSizedBuffer added in v1.19.3 

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

func (*UpdateRankDataRet) ProtoMessage added in v1.19.3 

func (*UpdateRankDataRet) ProtoMessage()

func (*UpdateRankDataRet) Reset added in v1.19.3 

func (m *UpdateRankDataRet) Reset()

func (*UpdateRankDataRet) Size added in v1.19.3 

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

func (*UpdateRankDataRet) String added in v1.19.3 

func (m *UpdateRankDataRet) String() string

func (*UpdateRankDataRet) Unmarshal added in v1.19.3 

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

func (*UpdateRankDataRet) XXX_DiscardUnknown added in v1.19.3 

func (m *UpdateRankDataRet) XXX_DiscardUnknown()

func (*UpdateRankDataRet) XXX_Marshal added in v1.19.3 

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

func (*UpdateRankDataRet) XXX_Merge added in v1.19.3 

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

func (*UpdateRankDataRet) XXX_Size added in v1.19.3 

func (m *UpdateRankDataRet) XXX_Size() int

func (*UpdateRankDataRet) XXX_Unmarshal added in v1.19.3 

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

type UpsetRankData added in v1.19.0 

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

UpsetRankData 更新排行榜数据

func (*UpsetRankData) Descriptor added in v1.19.0 

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

func (*UpsetRankData) GetFindNewRank added in v1.19.3 

func (m *UpsetRankData) GetFindNewRank() bool

func (*UpsetRankData) GetRankDataList added in v1.19.0 

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

func (*UpsetRankData) GetRankId added in v1.19.0 

func (m *UpsetRankData) GetRankId() uint64

func (*UpsetRankData) Marshal added in v1.19.0 

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

func (*UpsetRankData) MarshalTo added in v1.19.0 

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

func (*UpsetRankData) MarshalToSizedBuffer added in v1.19.0 

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

func (*UpsetRankData) ProtoMessage added in v1.19.0 

func (*UpsetRankData) ProtoMessage()

func (*UpsetRankData) Reset added in v1.19.0 

func (m *UpsetRankData) Reset()

func (*UpsetRankData) Size added in v1.19.0 

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

func (*UpsetRankData) String added in v1.19.0 

func (m *UpsetRankData) String() string

func (*UpsetRankData) Unmarshal added in v1.19.0 

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

func (*UpsetRankData) XXX_DiscardUnknown added in v1.19.0 

func (m *UpsetRankData) XXX_DiscardUnknown()

func (*UpsetRankData) XXX_Marshal added in v1.19.0 

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

func (*UpsetRankData) XXX_Merge added in v1.19.0 

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

func (*UpsetRankData) XXX_Size added in v1.19.0 

func (m *UpsetRankData) XXX_Size() int

func (*UpsetRankData) XXX_Unmarshal added in v1.19.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.