rpc

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Nov 23, 2022 License: Apache-2.0 Imports: 21 Imported by: 6

Documentation

Index

Constants

View Source 
const ConnectInterval = 2 * time.Second
View Source 
const Default_ReadWriteDeadline = 15 * time.Second
View Source 
const MaxCheckCallRpcCount = 1000
View Source 
const MaxPendingWriteNum = 200000

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) 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 {
	network.TCPClient

	TriggerRpcEvent
	// contains filtered or unexported fields
}

func (*Client) AddPending 

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

func (*Client) AsyncCall 

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

func (*Client) Close 

func (client *Client) Close(waitDone bool)

func (*Client) Connect 

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

func (*Client) FindPending 

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

func (*Client) GetClientSeq 

func (client *Client) GetClientSeq() uint32

func (*Client) GetId 

func (client *Client) GetId() int

func (*Client) Go 

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

func (*Client) IsConnected 

func (client *Client) IsConnected() bool

func (*Client) NewClientAgent 

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

func (*Client) OnClose 

func (client *Client) OnClose()

func (*Client) RawGo 

func (client *Client) RawGo(processor IRpcProcessor, noReply bool, rpcMethodId uint32, serviceMethod string, args []byte, reply interface{}) *Call

func (*Client) RemovePending 

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

func (*Client) ResetPending 

func (client *Client) ResetPending()

func (*Client) Run 

func (client *Client) Run()

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

type IRawInputArgs interface {
	GetRawData() []byte //获取原始数据
	DoFree()            //处理完成,回收内存
	DoEscape()          //逃逸,GC自动回收
}

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 IRawInputArgs) error
	CastGo(serviceMethod string, args interface{}) error
	IsSingleCoroutine() bool
	UnmarshalInParam(rpcProcessor IRpcProcessor, serviceMethod string, rawRpcMethodId uint32, inParam []byte) (interface{}, error)
}

type IRpcHandlerChannel 

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

type IRpcProcessor 

type IRpcProcessor interface {
	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 JsonProcessor 

type JsonProcessor struct {
}

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 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 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"`
	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) 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 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"`
	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) 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"`
	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) 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 interface {
	Unmarshal(data []byte) (interface{}, error)
	CB(data interface{})
}

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) 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 IRawInputArgs) 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 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 TriggerRpcEvent 

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

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"`
	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) 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.