rpc

type AddRankList struct {
	AddList []*RankList `protobuf:"bytes,1,rep,name=AddList,proto3" json:"AddList,omitempty"` //添加的排行榜列表
	// contains filtered or unexported fields
}

type Call struct {
	Seq           uint64
	ServiceMethod string
	Reply         interface{}
	Response      *RpcResponse
	Err           error

	TimeOut time.Duration
	// contains filtered or unexported fields
}

type CallTimer struct {
	SeqId    uint64
	FireTime int64
}

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

type CancelRpc func()

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

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"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

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

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"`               //消费者Id
	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"`             //开始位置 ,格式前4位是时间戳秒，后面是序号。如果填0时，服务自动修改成：(4bit 当前时间秒)| (0000 4bit)
	OneBatchQuantity int32           `protobuf:"varint,8,opt,name=OneBatchQuantity,proto3" json:"OneBatchQuantity,omitempty"` //订阅一次发送的数量，不设置有默认值1000条
	// contains filtered or unexported fields
}

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

type DeleteByKey struct {
	RankId  uint64   `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`          //排行榜的分类ID
	KeyList []uint64 `protobuf:"varint,2,rep,packed,name=KeyList,proto3" json:"KeyList,omitempty"` //排行数据
	// contains filtered or unexported fields
}

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

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"`
	// contains filtered or unexported fields
}

type FindRankDataByKey struct {
	RankId uint64 `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"` //排行榜的ID
	Key    uint64 `protobuf:"varint,2,opt,name=Key,proto3" json:"Key,omitempty"`       //排行的key
	// contains filtered or unexported fields
}

type FindRankDataByRank struct {
	RankId uint64 `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"` //排行榜的ID
	Rank   uint64 `protobuf:"varint,2,opt,name=Rank,proto3" json:"Rank,omitempty"`     //排行名次
	// contains filtered or unexported fields
}

type FindRankDataList struct {
	RankId    uint64 `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`       //排行榜的ID
	StartRank uint64 `protobuf:"varint,2,opt,name=StartRank,proto3" json:"StartRank,omitempty"` //排行的位置 0开始
	Count     uint64 `protobuf:"varint,3,opt,name=Count,proto3" json:"Count,omitempty"`         //查询格式
	Key       uint64 `protobuf:"varint,4,opt,name=Key,proto3" json:"Key,omitempty"`             //附带一个Key查询排行信息
	// contains filtered or unexported fields
}

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

type FuncRpcServer func() *Server

type ICompressor interface {
	CompressBlock(src []byte) ([]byte, error)   //dst如果有预申请使用dst内存，传入nil时内部申请
	UncompressBlock(src []byte) ([]byte, error) //dst如果有预申请使用dst内存，传入nil时内部申请

	CompressBufferCollection(buffer []byte)   //压缩的Buffer内存回收
	UnCompressBufferCollection(buffer []byte) //解压缩的Buffer内存回收
}

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

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

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

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

	Run()
	OnClose()
}

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

	Call(serviceMethod string, args interface{}, reply interface{}) error
	CallNode(nodeId int, serviceMethod string, args interface{}, reply interface{}) error
	AsyncCall(serviceMethod string, args interface{}, callback interface{}) error
	AsyncCallNode(nodeId int, serviceMethod string, args interface{}, callback interface{}) error

	CallWithTimeout(timeout time.Duration, serviceMethod string, args interface{}, reply interface{}) error
	CallNodeWithTimeout(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, reply interface{}) error
	AsyncCallWithTimeout(timeout time.Duration, serviceMethod string, args interface{}, callback interface{}) (CancelRpc, error)
	AsyncCallNodeWithTimeout(timeout time.Duration, nodeId int, serviceMethod string, args interface{}, callback interface{}) (CancelRpc, error)

	Go(serviceMethod string, args 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 interface {
	PushRpcResponse(call *Call) error
	PushRpcRequest(rpcRequest *RpcRequest) error
}

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
}

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

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

type IncreaseRankData struct {
	RankId                  uint64                  `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`                                   //排行榜的ID
	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"`                   //是否查找最新排名，否则不返回排行Rank字段
	InsertDataOnNonExistent bool                    `protobuf:"varint,7,opt,name=InsertDataOnNonExistent,proto3" json:"InsertDataOnNonExistent,omitempty"` //为true时:存在不进行更新，不存在则插入InitData与InitSortData数据。为false时：忽略不对InitData与InitSortData数据
	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"`                //参与排行的数据
	// contains filtered or unexported fields
}

type IncreaseRankDataRet struct {
	PosData *RankPosData `protobuf:"bytes,1,opt,name=PosData,proto3" json:"PosData,omitempty"`
	// contains filtered or unexported fields
}

type JsonProcessor struct {
}

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
}

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

	//returns
	Reply []byte
}

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

type Lz4Compressor struct {
}

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"`
	Retire            bool     `protobuf:"varint,6,opt,name=Retire,proto3" json:"Retire,omitempty"`
	PublicServiceList []string `protobuf:"bytes,7,rep,name=PublicServiceList,proto3" json:"PublicServiceList,omitempty"`
	// contains filtered or unexported fields
}

type NodeRetireReq struct {
	NodeInfo *NodeInfo `protobuf:"bytes,1,opt,name=nodeInfo,proto3" json:"nodeInfo,omitempty"`
	// contains filtered or unexported fields
}

type PBProcessor struct {
}

type PBRpcRequestData 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"`
	// contains filtered or unexported fields
}

type PBRpcResponseData 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"`
	// contains filtered or unexported fields
}

type RClient struct {
	network.TCPClient

	TriggerRpcConnEvent
	// contains filtered or unexported fields
}

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"`             //扩展增量数据
	// contains filtered or unexported fields
}

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"`                 //附带的Key查询排行结果信息
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

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"` //排行榜level-生成的跳表的level, 8/16/32/64等
	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"`           //有效时间，0永不过期
	// contains filtered or unexported fields
}

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"` //扩展数据
	// contains filtered or unexported fields
}

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"`          //新的排名名次，只有UpsetRankData.FindNewRank为true时才生效
	// contains filtered or unexported fields
}

type RawRpcCallBack func(rawData []byte)

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

type Responder = RequestHandler

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

type RpcCancel struct {
	Cli     *Client
	CallSeq uint64
}

type RpcError string

type RpcHandleFinder interface {
	FindRpcHandler(serviceMethod string) IRpcHandler
}

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

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

type RpcProcessorType uint8

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

type RpcResponse struct {
	RpcResponseData IRpcResponseData
}

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

type ServiceDiscoverReq struct {
	NodeInfo *NodeInfo `protobuf:"bytes,1,opt,name=nodeInfo,proto3" json:"nodeInfo,omitempty"`
	// contains filtered or unexported fields
}

type SetSortAndExtendData struct {
	IsSortData bool  `protobuf:"varint,1,opt,name=IsSortData,proto3" json:"IsSortData,omitempty"` //是否为排序字段,为true时，修改Sort字段，否则修改Extend数据
	Pos        int32 `protobuf:"varint,2,opt,name=Pos,proto3" json:"Pos,omitempty"`               //排序位置
	Data       int64 `protobuf:"varint,3,opt,name=Data,proto3" json:"Data,omitempty"`             //排序值
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

type SubscribeMethod int32

type SubscribeType int32

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

type UpdateRankData struct {
	RankId uint64 `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"` //排行榜的ID
	Key    uint64 `protobuf:"varint,2,opt,name=Key,proto3" json:"Key,omitempty"`       //数据主建
	Data   []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`      //数据部分
	// contains filtered or unexported fields
}

type UpdateRankDataRet struct {
	Ret bool `protobuf:"varint,1,opt,name=Ret,proto3" json:"Ret,omitempty"`
	// contains filtered or unexported fields
}

type UpsetRankData struct {
	RankId       uint64      `protobuf:"varint,1,opt,name=RankId,proto3" json:"RankId,omitempty"`            //排行榜的ID
	RankDataList []*RankData `protobuf:"bytes,2,rep,name=RankDataList,proto3" json:"RankDataList,omitempty"` //排行数据
	FindNewRank  bool        `protobuf:"varint,3,opt,name=FindNewRank,proto3" json:"FindNewRank,omitempty"`  //是否查找最新排名
	// contains filtered or unexported fields
}