Documentation ¶
Overview ¶
Package pdpb is a generated protocol buffer package.
It is generated from these files:
pdpb.proto
It has these top-level messages:
Leader TsoRequest Timestamp TsoResponse BootstrapRequest BootstrapResponse IsBootstrappedRequest IsBootstrappedResponse AllocIdRequest AllocIdResponse GetStoreRequest GetStoreResponse GetRegionRequest GetRegionResponse GetRegionByIDRequest GetClusterConfigRequest GetClusterConfigResponse PutStoreRequest PutStoreResponse PDMember GetPDMembersRequest GetPDMembersResponse PeerStats RegionHeartbeatRequest ChangePeer TransferLeader RegionHeartbeatResponse PutClusterConfigRequest PutClusterConfigResponse AskSplitRequest AskSplitResponse StoreStats StoreHeartbeatRequest StoreHeartbeatResponse ReportSplitRequest ReportSplitResponse RequestHeader ResponseHeader Request Response BootstrappedError StoreIsTombstoneError Error
Index ¶
- Variables
- type AllocIdRequest
- func (*AllocIdRequest) Descriptor() ([]byte, []int)
- func (m *AllocIdRequest) Marshal() (data []byte, err error)
- func (m *AllocIdRequest) MarshalTo(data []byte) (int, error)
- func (*AllocIdRequest) ProtoMessage()
- func (m *AllocIdRequest) Reset()
- func (m *AllocIdRequest) Size() (n int)
- func (m *AllocIdRequest) String() string
- func (m *AllocIdRequest) Unmarshal(data []byte) error
- type AllocIdResponse
- func (*AllocIdResponse) Descriptor() ([]byte, []int)
- func (m *AllocIdResponse) GetId() uint64
- func (m *AllocIdResponse) Marshal() (data []byte, err error)
- func (m *AllocIdResponse) MarshalTo(data []byte) (int, error)
- func (*AllocIdResponse) ProtoMessage()
- func (m *AllocIdResponse) Reset()
- func (m *AllocIdResponse) Size() (n int)
- func (m *AllocIdResponse) String() string
- func (m *AllocIdResponse) Unmarshal(data []byte) error
- type AskSplitRequest
- func (*AskSplitRequest) Descriptor() ([]byte, []int)
- func (m *AskSplitRequest) GetRegion() *metapb.Region
- func (m *AskSplitRequest) Marshal() (data []byte, err error)
- func (m *AskSplitRequest) MarshalTo(data []byte) (int, error)
- func (*AskSplitRequest) ProtoMessage()
- func (m *AskSplitRequest) Reset()
- func (m *AskSplitRequest) Size() (n int)
- func (m *AskSplitRequest) String() string
- func (m *AskSplitRequest) Unmarshal(data []byte) error
- type AskSplitResponse
- func (*AskSplitResponse) Descriptor() ([]byte, []int)
- func (m *AskSplitResponse) GetNewPeerIds() []uint64
- func (m *AskSplitResponse) GetNewRegionId() uint64
- func (m *AskSplitResponse) Marshal() (data []byte, err error)
- func (m *AskSplitResponse) MarshalTo(data []byte) (int, error)
- func (*AskSplitResponse) ProtoMessage()
- func (m *AskSplitResponse) Reset()
- func (m *AskSplitResponse) Size() (n int)
- func (m *AskSplitResponse) String() string
- func (m *AskSplitResponse) Unmarshal(data []byte) error
- type BootstrapRequest
- func (*BootstrapRequest) Descriptor() ([]byte, []int)
- func (m *BootstrapRequest) GetRegion() *metapb.Region
- func (m *BootstrapRequest) GetStore() *metapb.Store
- func (m *BootstrapRequest) Marshal() (data []byte, err error)
- func (m *BootstrapRequest) MarshalTo(data []byte) (int, error)
- func (*BootstrapRequest) ProtoMessage()
- func (m *BootstrapRequest) Reset()
- func (m *BootstrapRequest) Size() (n int)
- func (m *BootstrapRequest) String() string
- func (m *BootstrapRequest) Unmarshal(data []byte) error
- type BootstrapResponse
- func (*BootstrapResponse) Descriptor() ([]byte, []int)
- func (m *BootstrapResponse) Marshal() (data []byte, err error)
- func (m *BootstrapResponse) MarshalTo(data []byte) (int, error)
- func (*BootstrapResponse) ProtoMessage()
- func (m *BootstrapResponse) Reset()
- func (m *BootstrapResponse) Size() (n int)
- func (m *BootstrapResponse) String() string
- func (m *BootstrapResponse) Unmarshal(data []byte) error
- type BootstrappedError
- func (*BootstrappedError) Descriptor() ([]byte, []int)
- func (m *BootstrappedError) Marshal() (data []byte, err error)
- func (m *BootstrappedError) MarshalTo(data []byte) (int, error)
- func (*BootstrappedError) ProtoMessage()
- func (m *BootstrappedError) Reset()
- func (m *BootstrappedError) Size() (n int)
- func (m *BootstrappedError) String() string
- func (m *BootstrappedError) Unmarshal(data []byte) error
- type ChangePeer
- func (*ChangePeer) Descriptor() ([]byte, []int)
- func (m *ChangePeer) GetChangeType() eraftpb.ConfChangeType
- func (m *ChangePeer) GetPeer() *metapb.Peer
- func (m *ChangePeer) Marshal() (data []byte, err error)
- func (m *ChangePeer) MarshalTo(data []byte) (int, error)
- func (*ChangePeer) ProtoMessage()
- func (m *ChangePeer) Reset()
- func (m *ChangePeer) Size() (n int)
- func (m *ChangePeer) String() string
- func (m *ChangePeer) Unmarshal(data []byte) error
- type CommandType
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetBootstrapped() *BootstrappedError
- func (m *Error) GetIsTombstone() *StoreIsTombstoneError
- func (m *Error) GetMessage() string
- func (m *Error) Marshal() (data []byte, err error)
- func (m *Error) MarshalTo(data []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(data []byte) error
- type GetClusterConfigRequest
- func (*GetClusterConfigRequest) Descriptor() ([]byte, []int)
- func (m *GetClusterConfigRequest) Marshal() (data []byte, err error)
- func (m *GetClusterConfigRequest) MarshalTo(data []byte) (int, error)
- func (*GetClusterConfigRequest) ProtoMessage()
- func (m *GetClusterConfigRequest) Reset()
- func (m *GetClusterConfigRequest) Size() (n int)
- func (m *GetClusterConfigRequest) String() string
- func (m *GetClusterConfigRequest) Unmarshal(data []byte) error
- type GetClusterConfigResponse
- func (*GetClusterConfigResponse) Descriptor() ([]byte, []int)
- func (m *GetClusterConfigResponse) GetCluster() *metapb.Cluster
- func (m *GetClusterConfigResponse) Marshal() (data []byte, err error)
- func (m *GetClusterConfigResponse) MarshalTo(data []byte) (int, error)
- func (*GetClusterConfigResponse) ProtoMessage()
- func (m *GetClusterConfigResponse) Reset()
- func (m *GetClusterConfigResponse) Size() (n int)
- func (m *GetClusterConfigResponse) String() string
- func (m *GetClusterConfigResponse) Unmarshal(data []byte) error
- type GetPDMembersRequest
- func (*GetPDMembersRequest) Descriptor() ([]byte, []int)
- func (m *GetPDMembersRequest) Marshal() (data []byte, err error)
- func (m *GetPDMembersRequest) MarshalTo(data []byte) (int, error)
- func (*GetPDMembersRequest) ProtoMessage()
- func (m *GetPDMembersRequest) Reset()
- func (m *GetPDMembersRequest) Size() (n int)
- func (m *GetPDMembersRequest) String() string
- func (m *GetPDMembersRequest) Unmarshal(data []byte) error
- type GetPDMembersResponse
- func (*GetPDMembersResponse) Descriptor() ([]byte, []int)
- func (m *GetPDMembersResponse) GetMembers() []*PDMember
- func (m *GetPDMembersResponse) Marshal() (data []byte, err error)
- func (m *GetPDMembersResponse) MarshalTo(data []byte) (int, error)
- func (*GetPDMembersResponse) ProtoMessage()
- func (m *GetPDMembersResponse) Reset()
- func (m *GetPDMembersResponse) Size() (n int)
- func (m *GetPDMembersResponse) String() string
- func (m *GetPDMembersResponse) Unmarshal(data []byte) error
- type GetRegionByIDRequest
- func (*GetRegionByIDRequest) Descriptor() ([]byte, []int)
- func (m *GetRegionByIDRequest) GetRegionId() uint64
- func (m *GetRegionByIDRequest) Marshal() (data []byte, err error)
- func (m *GetRegionByIDRequest) MarshalTo(data []byte) (int, error)
- func (*GetRegionByIDRequest) ProtoMessage()
- func (m *GetRegionByIDRequest) Reset()
- func (m *GetRegionByIDRequest) Size() (n int)
- func (m *GetRegionByIDRequest) String() string
- func (m *GetRegionByIDRequest) Unmarshal(data []byte) error
- type GetRegionRequest
- func (*GetRegionRequest) Descriptor() ([]byte, []int)
- func (m *GetRegionRequest) GetRegionKey() []byte
- func (m *GetRegionRequest) Marshal() (data []byte, err error)
- func (m *GetRegionRequest) MarshalTo(data []byte) (int, error)
- func (*GetRegionRequest) ProtoMessage()
- func (m *GetRegionRequest) Reset()
- func (m *GetRegionRequest) Size() (n int)
- func (m *GetRegionRequest) String() string
- func (m *GetRegionRequest) Unmarshal(data []byte) error
- type GetRegionResponse
- func (*GetRegionResponse) Descriptor() ([]byte, []int)
- func (m *GetRegionResponse) GetLeader() *metapb.Peer
- func (m *GetRegionResponse) GetRegion() *metapb.Region
- func (m *GetRegionResponse) Marshal() (data []byte, err error)
- func (m *GetRegionResponse) MarshalTo(data []byte) (int, error)
- func (*GetRegionResponse) ProtoMessage()
- func (m *GetRegionResponse) Reset()
- func (m *GetRegionResponse) Size() (n int)
- func (m *GetRegionResponse) String() string
- func (m *GetRegionResponse) Unmarshal(data []byte) error
- type GetStoreRequest
- func (*GetStoreRequest) Descriptor() ([]byte, []int)
- func (m *GetStoreRequest) GetStoreId() uint64
- func (m *GetStoreRequest) Marshal() (data []byte, err error)
- func (m *GetStoreRequest) MarshalTo(data []byte) (int, error)
- func (*GetStoreRequest) ProtoMessage()
- func (m *GetStoreRequest) Reset()
- func (m *GetStoreRequest) Size() (n int)
- func (m *GetStoreRequest) String() string
- func (m *GetStoreRequest) Unmarshal(data []byte) error
- type GetStoreResponse
- func (*GetStoreResponse) Descriptor() ([]byte, []int)
- func (m *GetStoreResponse) GetStore() *metapb.Store
- func (m *GetStoreResponse) Marshal() (data []byte, err error)
- func (m *GetStoreResponse) MarshalTo(data []byte) (int, error)
- func (*GetStoreResponse) ProtoMessage()
- func (m *GetStoreResponse) Reset()
- func (m *GetStoreResponse) Size() (n int)
- func (m *GetStoreResponse) String() string
- func (m *GetStoreResponse) Unmarshal(data []byte) error
- type IsBootstrappedRequest
- func (*IsBootstrappedRequest) Descriptor() ([]byte, []int)
- func (m *IsBootstrappedRequest) Marshal() (data []byte, err error)
- func (m *IsBootstrappedRequest) MarshalTo(data []byte) (int, error)
- func (*IsBootstrappedRequest) ProtoMessage()
- func (m *IsBootstrappedRequest) Reset()
- func (m *IsBootstrappedRequest) Size() (n int)
- func (m *IsBootstrappedRequest) String() string
- func (m *IsBootstrappedRequest) Unmarshal(data []byte) error
- type IsBootstrappedResponse
- func (*IsBootstrappedResponse) Descriptor() ([]byte, []int)
- func (m *IsBootstrappedResponse) GetBootstrapped() bool
- func (m *IsBootstrappedResponse) Marshal() (data []byte, err error)
- func (m *IsBootstrappedResponse) MarshalTo(data []byte) (int, error)
- func (*IsBootstrappedResponse) ProtoMessage()
- func (m *IsBootstrappedResponse) Reset()
- func (m *IsBootstrappedResponse) Size() (n int)
- func (m *IsBootstrappedResponse) String() string
- func (m *IsBootstrappedResponse) Unmarshal(data []byte) error
- type Leader
- func (*Leader) Descriptor() ([]byte, []int)
- func (m *Leader) GetAddr() string
- func (m *Leader) GetPid() int64
- func (m *Leader) Marshal() (data []byte, err error)
- func (m *Leader) MarshalTo(data []byte) (int, error)
- func (*Leader) ProtoMessage()
- func (m *Leader) Reset()
- func (m *Leader) Size() (n int)
- func (m *Leader) String() string
- func (m *Leader) Unmarshal(data []byte) error
- type PDMember
- func (*PDMember) Descriptor() ([]byte, []int)
- func (m *PDMember) GetClientUrls() []string
- func (m *PDMember) GetName() string
- func (m *PDMember) GetPeerUrls() []string
- func (m *PDMember) Marshal() (data []byte, err error)
- func (m *PDMember) MarshalTo(data []byte) (int, error)
- func (*PDMember) ProtoMessage()
- func (m *PDMember) Reset()
- func (m *PDMember) Size() (n int)
- func (m *PDMember) String() string
- func (m *PDMember) Unmarshal(data []byte) error
- type PeerStats
- func (*PeerStats) Descriptor() ([]byte, []int)
- func (m *PeerStats) GetDownSeconds() uint64
- func (m *PeerStats) GetPeer() *metapb.Peer
- func (m *PeerStats) Marshal() (data []byte, err error)
- func (m *PeerStats) MarshalTo(data []byte) (int, error)
- func (*PeerStats) ProtoMessage()
- func (m *PeerStats) Reset()
- func (m *PeerStats) Size() (n int)
- func (m *PeerStats) String() string
- func (m *PeerStats) Unmarshal(data []byte) error
- type PutClusterConfigRequest
- func (*PutClusterConfigRequest) Descriptor() ([]byte, []int)
- func (m *PutClusterConfigRequest) GetCluster() *metapb.Cluster
- func (m *PutClusterConfigRequest) Marshal() (data []byte, err error)
- func (m *PutClusterConfigRequest) MarshalTo(data []byte) (int, error)
- func (*PutClusterConfigRequest) ProtoMessage()
- func (m *PutClusterConfigRequest) Reset()
- func (m *PutClusterConfigRequest) Size() (n int)
- func (m *PutClusterConfigRequest) String() string
- func (m *PutClusterConfigRequest) Unmarshal(data []byte) error
- type PutClusterConfigResponse
- func (*PutClusterConfigResponse) Descriptor() ([]byte, []int)
- func (m *PutClusterConfigResponse) Marshal() (data []byte, err error)
- func (m *PutClusterConfigResponse) MarshalTo(data []byte) (int, error)
- func (*PutClusterConfigResponse) ProtoMessage()
- func (m *PutClusterConfigResponse) Reset()
- func (m *PutClusterConfigResponse) Size() (n int)
- func (m *PutClusterConfigResponse) String() string
- func (m *PutClusterConfigResponse) Unmarshal(data []byte) error
- type PutStoreRequest
- func (*PutStoreRequest) Descriptor() ([]byte, []int)
- func (m *PutStoreRequest) GetStore() *metapb.Store
- func (m *PutStoreRequest) Marshal() (data []byte, err error)
- func (m *PutStoreRequest) MarshalTo(data []byte) (int, error)
- func (*PutStoreRequest) ProtoMessage()
- func (m *PutStoreRequest) Reset()
- func (m *PutStoreRequest) Size() (n int)
- func (m *PutStoreRequest) String() string
- func (m *PutStoreRequest) Unmarshal(data []byte) error
- type PutStoreResponse
- func (*PutStoreResponse) Descriptor() ([]byte, []int)
- func (m *PutStoreResponse) Marshal() (data []byte, err error)
- func (m *PutStoreResponse) MarshalTo(data []byte) (int, error)
- func (*PutStoreResponse) ProtoMessage()
- func (m *PutStoreResponse) Reset()
- func (m *PutStoreResponse) Size() (n int)
- func (m *PutStoreResponse) String() string
- func (m *PutStoreResponse) Unmarshal(data []byte) error
- type RegionHeartbeatRequest
- func (*RegionHeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *RegionHeartbeatRequest) GetDownPeers() []*PeerStats
- func (m *RegionHeartbeatRequest) GetLeader() *metapb.Peer
- func (m *RegionHeartbeatRequest) GetRegion() *metapb.Region
- func (m *RegionHeartbeatRequest) Marshal() (data []byte, err error)
- func (m *RegionHeartbeatRequest) MarshalTo(data []byte) (int, error)
- func (*RegionHeartbeatRequest) ProtoMessage()
- func (m *RegionHeartbeatRequest) Reset()
- func (m *RegionHeartbeatRequest) Size() (n int)
- func (m *RegionHeartbeatRequest) String() string
- func (m *RegionHeartbeatRequest) Unmarshal(data []byte) error
- type RegionHeartbeatResponse
- func (*RegionHeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer
- func (m *RegionHeartbeatResponse) GetTransferLeader() *TransferLeader
- func (m *RegionHeartbeatResponse) Marshal() (data []byte, err error)
- func (m *RegionHeartbeatResponse) MarshalTo(data []byte) (int, error)
- func (*RegionHeartbeatResponse) ProtoMessage()
- func (m *RegionHeartbeatResponse) Reset()
- func (m *RegionHeartbeatResponse) Size() (n int)
- func (m *RegionHeartbeatResponse) String() string
- func (m *RegionHeartbeatResponse) Unmarshal(data []byte) error
- type ReportSplitRequest
- func (*ReportSplitRequest) Descriptor() ([]byte, []int)
- func (m *ReportSplitRequest) GetLeft() *metapb.Region
- func (m *ReportSplitRequest) GetRight() *metapb.Region
- func (m *ReportSplitRequest) Marshal() (data []byte, err error)
- func (m *ReportSplitRequest) MarshalTo(data []byte) (int, error)
- func (*ReportSplitRequest) ProtoMessage()
- func (m *ReportSplitRequest) Reset()
- func (m *ReportSplitRequest) Size() (n int)
- func (m *ReportSplitRequest) String() string
- func (m *ReportSplitRequest) Unmarshal(data []byte) error
- type ReportSplitResponse
- func (*ReportSplitResponse) Descriptor() ([]byte, []int)
- func (m *ReportSplitResponse) Marshal() (data []byte, err error)
- func (m *ReportSplitResponse) MarshalTo(data []byte) (int, error)
- func (*ReportSplitResponse) ProtoMessage()
- func (m *ReportSplitResponse) Reset()
- func (m *ReportSplitResponse) Size() (n int)
- func (m *ReportSplitResponse) String() string
- func (m *ReportSplitResponse) Unmarshal(data []byte) error
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetAllocId() *AllocIdRequest
- func (m *Request) GetAskSplit() *AskSplitRequest
- func (m *Request) GetBootstrap() *BootstrapRequest
- func (m *Request) GetCmdType() CommandType
- func (m *Request) GetGetClusterConfig() *GetClusterConfigRequest
- func (m *Request) GetGetPdMembers() *GetPDMembersRequest
- func (m *Request) GetGetRegion() *GetRegionRequest
- func (m *Request) GetGetRegionById() *GetRegionByIDRequest
- func (m *Request) GetGetStore() *GetStoreRequest
- func (m *Request) GetHeader() *RequestHeader
- func (m *Request) GetIsBootstrapped() *IsBootstrappedRequest
- func (m *Request) GetPutClusterConfig() *PutClusterConfigRequest
- func (m *Request) GetPutStore() *PutStoreRequest
- func (m *Request) GetRegionHeartbeat() *RegionHeartbeatRequest
- func (m *Request) GetReportSplit() *ReportSplitRequest
- func (m *Request) GetStoreHeartbeat() *StoreHeartbeatRequest
- func (m *Request) GetTso() *TsoRequest
- func (m *Request) Marshal() (data []byte, err error)
- func (m *Request) MarshalTo(data []byte) (int, error)
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) Size() (n int)
- func (m *Request) String() string
- func (m *Request) Unmarshal(data []byte) error
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)
- func (m *RequestHeader) GetClusterId() uint64
- func (m *RequestHeader) GetUuid() []byte
- func (m *RequestHeader) Marshal() (data []byte, err error)
- func (m *RequestHeader) MarshalTo(data []byte) (int, error)
- func (*RequestHeader) ProtoMessage()
- func (m *RequestHeader) Reset()
- func (m *RequestHeader) Size() (n int)
- func (m *RequestHeader) String() string
- func (m *RequestHeader) Unmarshal(data []byte) error
- type Response
- func (*Response) Descriptor() ([]byte, []int)
- func (m *Response) GetAllocId() *AllocIdResponse
- func (m *Response) GetAskSplit() *AskSplitResponse
- func (m *Response) GetBootstrap() *BootstrapResponse
- func (m *Response) GetCmdType() CommandType
- func (m *Response) GetGetClusterConfig() *GetClusterConfigResponse
- func (m *Response) GetGetPdMembers() *GetPDMembersResponse
- func (m *Response) GetGetRegion() *GetRegionResponse
- func (m *Response) GetGetRegionById() *GetRegionResponse
- func (m *Response) GetGetStore() *GetStoreResponse
- func (m *Response) GetHeader() *ResponseHeader
- func (m *Response) GetIsBootstrapped() *IsBootstrappedResponse
- func (m *Response) GetPutClusterConfig() *PutClusterConfigResponse
- func (m *Response) GetPutStore() *PutStoreResponse
- func (m *Response) GetRegionHeartbeat() *RegionHeartbeatResponse
- func (m *Response) GetReportSplit() *ReportSplitResponse
- func (m *Response) GetStoreHeartbeat() *StoreHeartbeatResponse
- func (m *Response) GetTso() *TsoResponse
- func (m *Response) Marshal() (data []byte, err error)
- func (m *Response) MarshalTo(data []byte) (int, error)
- func (*Response) ProtoMessage()
- func (m *Response) Reset()
- func (m *Response) Size() (n int)
- func (m *Response) String() string
- func (m *Response) Unmarshal(data []byte) error
- type ResponseHeader
- func (*ResponseHeader) Descriptor() ([]byte, []int)
- func (m *ResponseHeader) GetClusterId() uint64
- func (m *ResponseHeader) GetError() *Error
- func (m *ResponseHeader) GetUuid() []byte
- func (m *ResponseHeader) Marshal() (data []byte, err error)
- func (m *ResponseHeader) MarshalTo(data []byte) (int, error)
- func (*ResponseHeader) ProtoMessage()
- func (m *ResponseHeader) Reset()
- func (m *ResponseHeader) Size() (n int)
- func (m *ResponseHeader) String() string
- func (m *ResponseHeader) Unmarshal(data []byte) error
- type StoreHeartbeatRequest
- func (*StoreHeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *StoreHeartbeatRequest) GetStats() *StoreStats
- func (m *StoreHeartbeatRequest) Marshal() (data []byte, err error)
- func (m *StoreHeartbeatRequest) MarshalTo(data []byte) (int, error)
- func (*StoreHeartbeatRequest) ProtoMessage()
- func (m *StoreHeartbeatRequest) Reset()
- func (m *StoreHeartbeatRequest) Size() (n int)
- func (m *StoreHeartbeatRequest) String() string
- func (m *StoreHeartbeatRequest) Unmarshal(data []byte) error
- type StoreHeartbeatResponse
- func (*StoreHeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *StoreHeartbeatResponse) Marshal() (data []byte, err error)
- func (m *StoreHeartbeatResponse) MarshalTo(data []byte) (int, error)
- func (*StoreHeartbeatResponse) ProtoMessage()
- func (m *StoreHeartbeatResponse) Reset()
- func (m *StoreHeartbeatResponse) Size() (n int)
- func (m *StoreHeartbeatResponse) String() string
- func (m *StoreHeartbeatResponse) Unmarshal(data []byte) error
- type StoreIsTombstoneError
- func (*StoreIsTombstoneError) Descriptor() ([]byte, []int)
- func (m *StoreIsTombstoneError) Marshal() (data []byte, err error)
- func (m *StoreIsTombstoneError) MarshalTo(data []byte) (int, error)
- func (*StoreIsTombstoneError) ProtoMessage()
- func (m *StoreIsTombstoneError) Reset()
- func (m *StoreIsTombstoneError) Size() (n int)
- func (m *StoreIsTombstoneError) String() string
- func (m *StoreIsTombstoneError) Unmarshal(data []byte) error
- type StoreStats
- func (*StoreStats) Descriptor() ([]byte, []int)
- func (m *StoreStats) GetApplyingSnapCount() uint32
- func (m *StoreStats) GetAvailable() uint64
- func (m *StoreStats) GetCapacity() uint64
- func (m *StoreStats) GetReceivingSnapCount() uint32
- func (m *StoreStats) GetRegionCount() uint32
- func (m *StoreStats) GetSendingSnapCount() uint32
- func (m *StoreStats) GetStartTime() uint32
- func (m *StoreStats) GetStoreId() uint64
- func (m *StoreStats) Marshal() (data []byte, err error)
- func (m *StoreStats) MarshalTo(data []byte) (int, error)
- func (*StoreStats) ProtoMessage()
- func (m *StoreStats) Reset()
- func (m *StoreStats) Size() (n int)
- func (m *StoreStats) String() string
- func (m *StoreStats) Unmarshal(data []byte) error
- type Timestamp
- func (*Timestamp) Descriptor() ([]byte, []int)
- func (m *Timestamp) GetLogical() int64
- func (m *Timestamp) GetPhysical() int64
- func (m *Timestamp) Marshal() (data []byte, err error)
- func (m *Timestamp) MarshalTo(data []byte) (int, error)
- func (*Timestamp) ProtoMessage()
- func (m *Timestamp) Reset()
- func (m *Timestamp) Size() (n int)
- func (m *Timestamp) String() string
- func (m *Timestamp) Unmarshal(data []byte) error
- type TransferLeader
- func (*TransferLeader) Descriptor() ([]byte, []int)
- func (m *TransferLeader) GetPeer() *metapb.Peer
- func (m *TransferLeader) Marshal() (data []byte, err error)
- func (m *TransferLeader) MarshalTo(data []byte) (int, error)
- func (*TransferLeader) ProtoMessage()
- func (m *TransferLeader) Reset()
- func (m *TransferLeader) Size() (n int)
- func (m *TransferLeader) String() string
- func (m *TransferLeader) Unmarshal(data []byte) error
- type TsoRequest
- func (*TsoRequest) Descriptor() ([]byte, []int)
- func (m *TsoRequest) GetCount() uint32
- func (m *TsoRequest) Marshal() (data []byte, err error)
- func (m *TsoRequest) MarshalTo(data []byte) (int, error)
- func (*TsoRequest) ProtoMessage()
- func (m *TsoRequest) Reset()
- func (m *TsoRequest) Size() (n int)
- func (m *TsoRequest) String() string
- func (m *TsoRequest) Unmarshal(data []byte) error
- type TsoResponse
- func (*TsoResponse) Descriptor() ([]byte, []int)
- func (m *TsoResponse) GetCount() uint32
- func (m *TsoResponse) GetTimestamp() Timestamp
- func (m *TsoResponse) Marshal() (data []byte, err error)
- func (m *TsoResponse) MarshalTo(data []byte) (int, error)
- func (*TsoResponse) ProtoMessage()
- func (m *TsoResponse) Reset()
- func (m *TsoResponse) Size() (n int)
- func (m *TsoResponse) String() string
- func (m *TsoResponse) Unmarshal(data []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthPdpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPdpb = fmt.Errorf("proto: integer overflow") )
View Source
var CommandType_name = map[int32]string{
0: "Invalid",
1: "Tso",
2: "Bootstrap",
3: "IsBootstrapped",
4: "AllocId",
5: "GetStore",
6: "PutStore",
7: "AskSplit",
8: "GetRegion",
9: "RegionHeartbeat",
10: "GetClusterConfig",
11: "PutClusterConfig",
12: "StoreHeartbeat",
13: "ReportSplit",
14: "GetRegionByID",
15: "GetPDMembers",
}
View Source
var CommandType_value = map[string]int32{
"Invalid": 0,
"Tso": 1,
"Bootstrap": 2,
"IsBootstrapped": 3,
"AllocId": 4,
"GetStore": 5,
"PutStore": 6,
"AskSplit": 7,
"GetRegion": 8,
"RegionHeartbeat": 9,
"GetClusterConfig": 10,
"PutClusterConfig": 11,
"StoreHeartbeat": 12,
"ReportSplit": 13,
"GetRegionByID": 14,
"GetPDMembers": 15,
}
Functions ¶
This section is empty.
Types ¶
type AllocIdRequest ¶
type AllocIdRequest struct {
XXX_unrecognized []byte `json:"-"`
}
func (*AllocIdRequest) Descriptor ¶
func (*AllocIdRequest) Descriptor() ([]byte, []int)
func (*AllocIdRequest) Marshal ¶
func (m *AllocIdRequest) Marshal() (data []byte, err error)
func (*AllocIdRequest) ProtoMessage ¶
func (*AllocIdRequest) ProtoMessage()
func (*AllocIdRequest) Reset ¶
func (m *AllocIdRequest) Reset()
func (*AllocIdRequest) Size ¶
func (m *AllocIdRequest) Size() (n int)
func (*AllocIdRequest) String ¶
func (m *AllocIdRequest) String() string
func (*AllocIdRequest) Unmarshal ¶
func (m *AllocIdRequest) Unmarshal(data []byte) error
type AllocIdResponse ¶
type AllocIdResponse struct { Id uint64 `protobuf:"varint,1,opt,name=id" json:"id"` XXX_unrecognized []byte `json:"-"` }
func (*AllocIdResponse) Descriptor ¶
func (*AllocIdResponse) Descriptor() ([]byte, []int)
func (*AllocIdResponse) GetId ¶
func (m *AllocIdResponse) GetId() uint64
func (*AllocIdResponse) Marshal ¶
func (m *AllocIdResponse) Marshal() (data []byte, err error)
func (*AllocIdResponse) ProtoMessage ¶
func (*AllocIdResponse) ProtoMessage()
func (*AllocIdResponse) Reset ¶
func (m *AllocIdResponse) Reset()
func (*AllocIdResponse) Size ¶
func (m *AllocIdResponse) Size() (n int)
func (*AllocIdResponse) String ¶
func (m *AllocIdResponse) String() string
func (*AllocIdResponse) Unmarshal ¶
func (m *AllocIdResponse) Unmarshal(data []byte) error
type AskSplitRequest ¶
type AskSplitRequest struct { Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AskSplitRequest) Descriptor ¶
func (*AskSplitRequest) Descriptor() ([]byte, []int)
func (*AskSplitRequest) GetRegion ¶
func (m *AskSplitRequest) GetRegion() *metapb.Region
func (*AskSplitRequest) Marshal ¶
func (m *AskSplitRequest) Marshal() (data []byte, err error)
func (*AskSplitRequest) ProtoMessage ¶
func (*AskSplitRequest) ProtoMessage()
func (*AskSplitRequest) Reset ¶
func (m *AskSplitRequest) Reset()
func (*AskSplitRequest) Size ¶
func (m *AskSplitRequest) Size() (n int)
func (*AskSplitRequest) String ¶
func (m *AskSplitRequest) String() string
func (*AskSplitRequest) Unmarshal ¶
func (m *AskSplitRequest) Unmarshal(data []byte) error
type AskSplitResponse ¶
type AskSplitResponse struct { // We split the region into two, first uses the origin // parent region id, and the second uses the new_region_id. // We must guarantee that the new_region_id is global unique. NewRegionId uint64 `protobuf:"varint,1,opt,name=new_region_id,json=newRegionId" json:"new_region_id"` // The peer ids for the new split region. NewPeerIds []uint64 `protobuf:"varint,2,rep,name=new_peer_ids,json=newPeerIds" json:"new_peer_ids,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AskSplitResponse) Descriptor ¶
func (*AskSplitResponse) Descriptor() ([]byte, []int)
func (*AskSplitResponse) GetNewPeerIds ¶
func (m *AskSplitResponse) GetNewPeerIds() []uint64
func (*AskSplitResponse) GetNewRegionId ¶
func (m *AskSplitResponse) GetNewRegionId() uint64
func (*AskSplitResponse) Marshal ¶
func (m *AskSplitResponse) Marshal() (data []byte, err error)
func (*AskSplitResponse) ProtoMessage ¶
func (*AskSplitResponse) ProtoMessage()
func (*AskSplitResponse) Reset ¶
func (m *AskSplitResponse) Reset()
func (*AskSplitResponse) Size ¶
func (m *AskSplitResponse) Size() (n int)
func (*AskSplitResponse) String ¶
func (m *AskSplitResponse) String() string
func (*AskSplitResponse) Unmarshal ¶
func (m *AskSplitResponse) Unmarshal(data []byte) error
type BootstrapRequest ¶
type BootstrapRequest struct { Store *metapb.Store `protobuf:"bytes,1,opt,name=store" json:"store,omitempty"` Region *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*BootstrapRequest) Descriptor ¶
func (*BootstrapRequest) Descriptor() ([]byte, []int)
func (*BootstrapRequest) GetRegion ¶
func (m *BootstrapRequest) GetRegion() *metapb.Region
func (*BootstrapRequest) GetStore ¶
func (m *BootstrapRequest) GetStore() *metapb.Store
func (*BootstrapRequest) Marshal ¶
func (m *BootstrapRequest) Marshal() (data []byte, err error)
func (*BootstrapRequest) ProtoMessage ¶
func (*BootstrapRequest) ProtoMessage()
func (*BootstrapRequest) Reset ¶
func (m *BootstrapRequest) Reset()
func (*BootstrapRequest) Size ¶
func (m *BootstrapRequest) Size() (n int)
func (*BootstrapRequest) String ¶
func (m *BootstrapRequest) String() string
func (*BootstrapRequest) Unmarshal ¶
func (m *BootstrapRequest) Unmarshal(data []byte) error
type BootstrapResponse ¶
type BootstrapResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*BootstrapResponse) Descriptor ¶
func (*BootstrapResponse) Descriptor() ([]byte, []int)
func (*BootstrapResponse) Marshal ¶
func (m *BootstrapResponse) Marshal() (data []byte, err error)
func (*BootstrapResponse) MarshalTo ¶
func (m *BootstrapResponse) MarshalTo(data []byte) (int, error)
func (*BootstrapResponse) ProtoMessage ¶
func (*BootstrapResponse) ProtoMessage()
func (*BootstrapResponse) Reset ¶
func (m *BootstrapResponse) Reset()
func (*BootstrapResponse) Size ¶
func (m *BootstrapResponse) Size() (n int)
func (*BootstrapResponse) String ¶
func (m *BootstrapResponse) String() string
func (*BootstrapResponse) Unmarshal ¶
func (m *BootstrapResponse) Unmarshal(data []byte) error
type BootstrappedError ¶
type BootstrappedError struct {
XXX_unrecognized []byte `json:"-"`
}
func (*BootstrappedError) Descriptor ¶
func (*BootstrappedError) Descriptor() ([]byte, []int)
func (*BootstrappedError) Marshal ¶
func (m *BootstrappedError) Marshal() (data []byte, err error)
func (*BootstrappedError) MarshalTo ¶
func (m *BootstrappedError) MarshalTo(data []byte) (int, error)
func (*BootstrappedError) ProtoMessage ¶
func (*BootstrappedError) ProtoMessage()
func (*BootstrappedError) Reset ¶
func (m *BootstrappedError) Reset()
func (*BootstrappedError) Size ¶
func (m *BootstrappedError) Size() (n int)
func (*BootstrappedError) String ¶
func (m *BootstrappedError) String() string
func (*BootstrappedError) Unmarshal ¶
func (m *BootstrappedError) Unmarshal(data []byte) error
type ChangePeer ¶
type ChangePeer struct { ChangeType *eraftpb.ConfChangeType `protobuf:"varint,1,opt,name=change_type,json=changeType,enum=eraftpb.ConfChangeType" json:"change_type,omitempty"` Peer *metapb.Peer `protobuf:"bytes,2,opt,name=peer" json:"peer,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ChangePeer) Descriptor ¶
func (*ChangePeer) Descriptor() ([]byte, []int)
func (*ChangePeer) GetChangeType ¶
func (m *ChangePeer) GetChangeType() eraftpb.ConfChangeType
func (*ChangePeer) GetPeer ¶
func (m *ChangePeer) GetPeer() *metapb.Peer
func (*ChangePeer) Marshal ¶
func (m *ChangePeer) Marshal() (data []byte, err error)
func (*ChangePeer) ProtoMessage ¶
func (*ChangePeer) ProtoMessage()
func (*ChangePeer) Reset ¶
func (m *ChangePeer) Reset()
func (*ChangePeer) Size ¶
func (m *ChangePeer) Size() (n int)
func (*ChangePeer) String ¶
func (m *ChangePeer) String() string
func (*ChangePeer) Unmarshal ¶
func (m *ChangePeer) Unmarshal(data []byte) error
type CommandType ¶
type CommandType int32
const ( CommandType_Invalid CommandType = 0 CommandType_Tso CommandType = 1 CommandType_Bootstrap CommandType = 2 CommandType_IsBootstrapped CommandType = 3 CommandType_AllocId CommandType = 4 CommandType_GetStore CommandType = 5 CommandType_PutStore CommandType = 6 CommandType_AskSplit CommandType = 7 CommandType_GetRegion CommandType = 8 CommandType_RegionHeartbeat CommandType = 9 CommandType_GetClusterConfig CommandType = 10 CommandType_PutClusterConfig CommandType = 11 CommandType_StoreHeartbeat CommandType = 12 CommandType_ReportSplit CommandType = 13 CommandType_GetRegionByID CommandType = 14 CommandType_GetPDMembers CommandType = 15 )
func (CommandType) Enum ¶
func (x CommandType) Enum() *CommandType
func (CommandType) EnumDescriptor ¶
func (CommandType) EnumDescriptor() ([]byte, []int)
func (CommandType) String ¶
func (x CommandType) String() string
func (*CommandType) UnmarshalJSON ¶
func (x *CommandType) UnmarshalJSON(data []byte) error
type Error ¶
type Error struct { Message *string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"` Bootstrapped *BootstrappedError `protobuf:"bytes,2,opt,name=bootstrapped" json:"bootstrapped,omitempty"` IsTombstone *StoreIsTombstoneError `protobuf:"bytes,3,opt,name=is_tombstone,json=isTombstone" json:"is_tombstone,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Error) Descriptor ¶
func (*Error) GetBootstrapped ¶
func (m *Error) GetBootstrapped() *BootstrappedError
func (*Error) GetIsTombstone ¶
func (m *Error) GetIsTombstone() *StoreIsTombstoneError
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
type GetClusterConfigRequest ¶
type GetClusterConfigRequest struct {
XXX_unrecognized []byte `json:"-"`
}
func (*GetClusterConfigRequest) Descriptor ¶
func (*GetClusterConfigRequest) Descriptor() ([]byte, []int)
func (*GetClusterConfigRequest) Marshal ¶
func (m *GetClusterConfigRequest) Marshal() (data []byte, err error)
func (*GetClusterConfigRequest) MarshalTo ¶
func (m *GetClusterConfigRequest) MarshalTo(data []byte) (int, error)
func (*GetClusterConfigRequest) ProtoMessage ¶
func (*GetClusterConfigRequest) ProtoMessage()
func (*GetClusterConfigRequest) Reset ¶
func (m *GetClusterConfigRequest) Reset()
func (*GetClusterConfigRequest) Size ¶
func (m *GetClusterConfigRequest) Size() (n int)
func (*GetClusterConfigRequest) String ¶
func (m *GetClusterConfigRequest) String() string
func (*GetClusterConfigRequest) Unmarshal ¶
func (m *GetClusterConfigRequest) Unmarshal(data []byte) error
type GetClusterConfigResponse ¶
type GetClusterConfigResponse struct { Cluster *metapb.Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetClusterConfigResponse) Descriptor ¶
func (*GetClusterConfigResponse) Descriptor() ([]byte, []int)
func (*GetClusterConfigResponse) GetCluster ¶
func (m *GetClusterConfigResponse) GetCluster() *metapb.Cluster
func (*GetClusterConfigResponse) Marshal ¶
func (m *GetClusterConfigResponse) Marshal() (data []byte, err error)
func (*GetClusterConfigResponse) MarshalTo ¶
func (m *GetClusterConfigResponse) MarshalTo(data []byte) (int, error)
func (*GetClusterConfigResponse) ProtoMessage ¶
func (*GetClusterConfigResponse) ProtoMessage()
func (*GetClusterConfigResponse) Reset ¶
func (m *GetClusterConfigResponse) Reset()
func (*GetClusterConfigResponse) Size ¶
func (m *GetClusterConfigResponse) Size() (n int)
func (*GetClusterConfigResponse) String ¶
func (m *GetClusterConfigResponse) String() string
func (*GetClusterConfigResponse) Unmarshal ¶
func (m *GetClusterConfigResponse) Unmarshal(data []byte) error
type GetPDMembersRequest ¶
type GetPDMembersRequest struct {
XXX_unrecognized []byte `json:"-"`
}
func (*GetPDMembersRequest) Descriptor ¶
func (*GetPDMembersRequest) Descriptor() ([]byte, []int)
func (*GetPDMembersRequest) Marshal ¶
func (m *GetPDMembersRequest) Marshal() (data []byte, err error)
func (*GetPDMembersRequest) MarshalTo ¶
func (m *GetPDMembersRequest) MarshalTo(data []byte) (int, error)
func (*GetPDMembersRequest) ProtoMessage ¶
func (*GetPDMembersRequest) ProtoMessage()
func (*GetPDMembersRequest) Reset ¶
func (m *GetPDMembersRequest) Reset()
func (*GetPDMembersRequest) Size ¶
func (m *GetPDMembersRequest) Size() (n int)
func (*GetPDMembersRequest) String ¶
func (m *GetPDMembersRequest) String() string
func (*GetPDMembersRequest) Unmarshal ¶
func (m *GetPDMembersRequest) Unmarshal(data []byte) error
type GetPDMembersResponse ¶
type GetPDMembersResponse struct { Members []*PDMember `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetPDMembersResponse) Descriptor ¶
func (*GetPDMembersResponse) Descriptor() ([]byte, []int)
func (*GetPDMembersResponse) GetMembers ¶
func (m *GetPDMembersResponse) GetMembers() []*PDMember
func (*GetPDMembersResponse) Marshal ¶
func (m *GetPDMembersResponse) Marshal() (data []byte, err error)
func (*GetPDMembersResponse) MarshalTo ¶
func (m *GetPDMembersResponse) MarshalTo(data []byte) (int, error)
func (*GetPDMembersResponse) ProtoMessage ¶
func (*GetPDMembersResponse) ProtoMessage()
func (*GetPDMembersResponse) Reset ¶
func (m *GetPDMembersResponse) Reset()
func (*GetPDMembersResponse) Size ¶
func (m *GetPDMembersResponse) Size() (n int)
func (*GetPDMembersResponse) String ¶
func (m *GetPDMembersResponse) String() string
func (*GetPDMembersResponse) Unmarshal ¶
func (m *GetPDMembersResponse) Unmarshal(data []byte) error
type GetRegionByIDRequest ¶
type GetRegionByIDRequest struct { RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId" json:"region_id"` XXX_unrecognized []byte `json:"-"` }
func (*GetRegionByIDRequest) Descriptor ¶
func (*GetRegionByIDRequest) Descriptor() ([]byte, []int)
func (*GetRegionByIDRequest) GetRegionId ¶
func (m *GetRegionByIDRequest) GetRegionId() uint64
func (*GetRegionByIDRequest) Marshal ¶
func (m *GetRegionByIDRequest) Marshal() (data []byte, err error)
func (*GetRegionByIDRequest) MarshalTo ¶
func (m *GetRegionByIDRequest) MarshalTo(data []byte) (int, error)
func (*GetRegionByIDRequest) ProtoMessage ¶
func (*GetRegionByIDRequest) ProtoMessage()
func (*GetRegionByIDRequest) Reset ¶
func (m *GetRegionByIDRequest) Reset()
func (*GetRegionByIDRequest) Size ¶
func (m *GetRegionByIDRequest) Size() (n int)
func (*GetRegionByIDRequest) String ¶
func (m *GetRegionByIDRequest) String() string
func (*GetRegionByIDRequest) Unmarshal ¶
func (m *GetRegionByIDRequest) Unmarshal(data []byte) error
type GetRegionRequest ¶
type GetRegionRequest struct { RegionKey []byte `protobuf:"bytes,1,opt,name=region_key,json=regionKey" json:"region_key,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetRegionRequest) Descriptor ¶
func (*GetRegionRequest) Descriptor() ([]byte, []int)
func (*GetRegionRequest) GetRegionKey ¶
func (m *GetRegionRequest) GetRegionKey() []byte
func (*GetRegionRequest) Marshal ¶
func (m *GetRegionRequest) Marshal() (data []byte, err error)
func (*GetRegionRequest) ProtoMessage ¶
func (*GetRegionRequest) ProtoMessage()
func (*GetRegionRequest) Reset ¶
func (m *GetRegionRequest) Reset()
func (*GetRegionRequest) Size ¶
func (m *GetRegionRequest) Size() (n int)
func (*GetRegionRequest) String ¶
func (m *GetRegionRequest) String() string
func (*GetRegionRequest) Unmarshal ¶
func (m *GetRegionRequest) Unmarshal(data []byte) error
type GetRegionResponse ¶
type GetRegionResponse struct { Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"` Leader *metapb.Peer `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetRegionResponse) Descriptor ¶
func (*GetRegionResponse) Descriptor() ([]byte, []int)
func (*GetRegionResponse) GetLeader ¶
func (m *GetRegionResponse) GetLeader() *metapb.Peer
func (*GetRegionResponse) GetRegion ¶
func (m *GetRegionResponse) GetRegion() *metapb.Region
func (*GetRegionResponse) Marshal ¶
func (m *GetRegionResponse) Marshal() (data []byte, err error)
func (*GetRegionResponse) MarshalTo ¶
func (m *GetRegionResponse) MarshalTo(data []byte) (int, error)
func (*GetRegionResponse) ProtoMessage ¶
func (*GetRegionResponse) ProtoMessage()
func (*GetRegionResponse) Reset ¶
func (m *GetRegionResponse) Reset()
func (*GetRegionResponse) Size ¶
func (m *GetRegionResponse) Size() (n int)
func (*GetRegionResponse) String ¶
func (m *GetRegionResponse) String() string
func (*GetRegionResponse) Unmarshal ¶
func (m *GetRegionResponse) Unmarshal(data []byte) error
type GetStoreRequest ¶
type GetStoreRequest struct { StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId" json:"store_id"` XXX_unrecognized []byte `json:"-"` }
func (*GetStoreRequest) Descriptor ¶
func (*GetStoreRequest) Descriptor() ([]byte, []int)
func (*GetStoreRequest) GetStoreId ¶
func (m *GetStoreRequest) GetStoreId() uint64
func (*GetStoreRequest) Marshal ¶
func (m *GetStoreRequest) Marshal() (data []byte, err error)
func (*GetStoreRequest) ProtoMessage ¶
func (*GetStoreRequest) ProtoMessage()
func (*GetStoreRequest) Reset ¶
func (m *GetStoreRequest) Reset()
func (*GetStoreRequest) Size ¶
func (m *GetStoreRequest) Size() (n int)
func (*GetStoreRequest) String ¶
func (m *GetStoreRequest) String() string
func (*GetStoreRequest) Unmarshal ¶
func (m *GetStoreRequest) Unmarshal(data []byte) error
type GetStoreResponse ¶
type GetStoreResponse struct { Store *metapb.Store `protobuf:"bytes,1,opt,name=store" json:"store,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetStoreResponse) Descriptor ¶
func (*GetStoreResponse) Descriptor() ([]byte, []int)
func (*GetStoreResponse) GetStore ¶
func (m *GetStoreResponse) GetStore() *metapb.Store
func (*GetStoreResponse) Marshal ¶
func (m *GetStoreResponse) Marshal() (data []byte, err error)
func (*GetStoreResponse) ProtoMessage ¶
func (*GetStoreResponse) ProtoMessage()
func (*GetStoreResponse) Reset ¶
func (m *GetStoreResponse) Reset()
func (*GetStoreResponse) Size ¶
func (m *GetStoreResponse) Size() (n int)
func (*GetStoreResponse) String ¶
func (m *GetStoreResponse) String() string
func (*GetStoreResponse) Unmarshal ¶
func (m *GetStoreResponse) Unmarshal(data []byte) error
type IsBootstrappedRequest ¶
type IsBootstrappedRequest struct {
XXX_unrecognized []byte `json:"-"`
}
func (*IsBootstrappedRequest) Descriptor ¶
func (*IsBootstrappedRequest) Descriptor() ([]byte, []int)
func (*IsBootstrappedRequest) Marshal ¶
func (m *IsBootstrappedRequest) Marshal() (data []byte, err error)
func (*IsBootstrappedRequest) MarshalTo ¶
func (m *IsBootstrappedRequest) MarshalTo(data []byte) (int, error)
func (*IsBootstrappedRequest) ProtoMessage ¶
func (*IsBootstrappedRequest) ProtoMessage()
func (*IsBootstrappedRequest) Reset ¶
func (m *IsBootstrappedRequest) Reset()
func (*IsBootstrappedRequest) Size ¶
func (m *IsBootstrappedRequest) Size() (n int)
func (*IsBootstrappedRequest) String ¶
func (m *IsBootstrappedRequest) String() string
func (*IsBootstrappedRequest) Unmarshal ¶
func (m *IsBootstrappedRequest) Unmarshal(data []byte) error
type IsBootstrappedResponse ¶
type IsBootstrappedResponse struct { Bootstrapped *bool `protobuf:"varint,1,opt,name=bootstrapped" json:"bootstrapped,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*IsBootstrappedResponse) Descriptor ¶
func (*IsBootstrappedResponse) Descriptor() ([]byte, []int)
func (*IsBootstrappedResponse) GetBootstrapped ¶
func (m *IsBootstrappedResponse) GetBootstrapped() bool
func (*IsBootstrappedResponse) Marshal ¶
func (m *IsBootstrappedResponse) Marshal() (data []byte, err error)
func (*IsBootstrappedResponse) MarshalTo ¶
func (m *IsBootstrappedResponse) MarshalTo(data []byte) (int, error)
func (*IsBootstrappedResponse) ProtoMessage ¶
func (*IsBootstrappedResponse) ProtoMessage()
func (*IsBootstrappedResponse) Reset ¶
func (m *IsBootstrappedResponse) Reset()
func (*IsBootstrappedResponse) Size ¶
func (m *IsBootstrappedResponse) Size() (n int)
func (*IsBootstrappedResponse) String ¶
func (m *IsBootstrappedResponse) String() string
func (*IsBootstrappedResponse) Unmarshal ¶
func (m *IsBootstrappedResponse) Unmarshal(data []byte) error
type Leader ¶
type Leader struct { Addr string `protobuf:"bytes,1,opt,name=addr" json:"addr"` Pid int64 `protobuf:"varint,2,opt,name=pid" json:"pid"` XXX_unrecognized []byte `json:"-"` }
func (*Leader) Descriptor ¶
func (*Leader) ProtoMessage ¶
func (*Leader) ProtoMessage()
type PDMember ¶
type PDMember struct { Name *string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"` ClientUrls []string `protobuf:"bytes,2,rep,name=client_urls,json=clientUrls" json:"client_urls,omitempty"` PeerUrls []string `protobuf:"bytes,3,rep,name=peer_urls,json=peerUrls" json:"peer_urls,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*PDMember) Descriptor ¶
func (*PDMember) GetClientUrls ¶
func (*PDMember) GetPeerUrls ¶
func (*PDMember) ProtoMessage ¶
func (*PDMember) ProtoMessage()
type PeerStats ¶
type PeerStats struct { Peer *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"` DownSeconds *uint64 `protobuf:"varint,2,opt,name=down_seconds,json=downSeconds" json:"down_seconds,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*PeerStats) Descriptor ¶
func (*PeerStats) GetDownSeconds ¶
func (*PeerStats) ProtoMessage ¶
func (*PeerStats) ProtoMessage()
type PutClusterConfigRequest ¶
type PutClusterConfigRequest struct { Cluster *metapb.Cluster `protobuf:"bytes,1,opt,name=cluster" json:"cluster,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*PutClusterConfigRequest) Descriptor ¶
func (*PutClusterConfigRequest) Descriptor() ([]byte, []int)
func (*PutClusterConfigRequest) GetCluster ¶
func (m *PutClusterConfigRequest) GetCluster() *metapb.Cluster
func (*PutClusterConfigRequest) Marshal ¶
func (m *PutClusterConfigRequest) Marshal() (data []byte, err error)
func (*PutClusterConfigRequest) MarshalTo ¶
func (m *PutClusterConfigRequest) MarshalTo(data []byte) (int, error)
func (*PutClusterConfigRequest) ProtoMessage ¶
func (*PutClusterConfigRequest) ProtoMessage()
func (*PutClusterConfigRequest) Reset ¶
func (m *PutClusterConfigRequest) Reset()
func (*PutClusterConfigRequest) Size ¶
func (m *PutClusterConfigRequest) Size() (n int)
func (*PutClusterConfigRequest) String ¶
func (m *PutClusterConfigRequest) String() string
func (*PutClusterConfigRequest) Unmarshal ¶
func (m *PutClusterConfigRequest) Unmarshal(data []byte) error
type PutClusterConfigResponse ¶
type PutClusterConfigResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*PutClusterConfigResponse) Descriptor ¶
func (*PutClusterConfigResponse) Descriptor() ([]byte, []int)
func (*PutClusterConfigResponse) Marshal ¶
func (m *PutClusterConfigResponse) Marshal() (data []byte, err error)
func (*PutClusterConfigResponse) MarshalTo ¶
func (m *PutClusterConfigResponse) MarshalTo(data []byte) (int, error)
func (*PutClusterConfigResponse) ProtoMessage ¶
func (*PutClusterConfigResponse) ProtoMessage()
func (*PutClusterConfigResponse) Reset ¶
func (m *PutClusterConfigResponse) Reset()
func (*PutClusterConfigResponse) Size ¶
func (m *PutClusterConfigResponse) Size() (n int)
func (*PutClusterConfigResponse) String ¶
func (m *PutClusterConfigResponse) String() string
func (*PutClusterConfigResponse) Unmarshal ¶
func (m *PutClusterConfigResponse) Unmarshal(data []byte) error
type PutStoreRequest ¶
type PutStoreRequest struct { Store *metapb.Store `protobuf:"bytes,1,opt,name=store" json:"store,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*PutStoreRequest) Descriptor ¶
func (*PutStoreRequest) Descriptor() ([]byte, []int)
func (*PutStoreRequest) GetStore ¶
func (m *PutStoreRequest) GetStore() *metapb.Store
func (*PutStoreRequest) Marshal ¶
func (m *PutStoreRequest) Marshal() (data []byte, err error)
func (*PutStoreRequest) ProtoMessage ¶
func (*PutStoreRequest) ProtoMessage()
func (*PutStoreRequest) Reset ¶
func (m *PutStoreRequest) Reset()
func (*PutStoreRequest) Size ¶
func (m *PutStoreRequest) Size() (n int)
func (*PutStoreRequest) String ¶
func (m *PutStoreRequest) String() string
func (*PutStoreRequest) Unmarshal ¶
func (m *PutStoreRequest) Unmarshal(data []byte) error
type PutStoreResponse ¶
type PutStoreResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*PutStoreResponse) Descriptor ¶
func (*PutStoreResponse) Descriptor() ([]byte, []int)
func (*PutStoreResponse) Marshal ¶
func (m *PutStoreResponse) Marshal() (data []byte, err error)
func (*PutStoreResponse) ProtoMessage ¶
func (*PutStoreResponse) ProtoMessage()
func (*PutStoreResponse) Reset ¶
func (m *PutStoreResponse) Reset()
func (*PutStoreResponse) Size ¶
func (m *PutStoreResponse) Size() (n int)
func (*PutStoreResponse) String ¶
func (m *PutStoreResponse) String() string
func (*PutStoreResponse) Unmarshal ¶
func (m *PutStoreResponse) Unmarshal(data []byte) error
type RegionHeartbeatRequest ¶
type RegionHeartbeatRequest struct { Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"` // Leader Peer sending the heartbeat. Leader *metapb.Peer `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"` // Leader considers that these peers are down. DownPeers []*PeerStats `protobuf:"bytes,3,rep,name=down_peers,json=downPeers" json:"down_peers,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RegionHeartbeatRequest) Descriptor ¶
func (*RegionHeartbeatRequest) Descriptor() ([]byte, []int)
func (*RegionHeartbeatRequest) GetDownPeers ¶
func (m *RegionHeartbeatRequest) GetDownPeers() []*PeerStats
func (*RegionHeartbeatRequest) GetLeader ¶
func (m *RegionHeartbeatRequest) GetLeader() *metapb.Peer
func (*RegionHeartbeatRequest) GetRegion ¶
func (m *RegionHeartbeatRequest) GetRegion() *metapb.Region
func (*RegionHeartbeatRequest) Marshal ¶
func (m *RegionHeartbeatRequest) Marshal() (data []byte, err error)
func (*RegionHeartbeatRequest) MarshalTo ¶
func (m *RegionHeartbeatRequest) MarshalTo(data []byte) (int, error)
func (*RegionHeartbeatRequest) ProtoMessage ¶
func (*RegionHeartbeatRequest) ProtoMessage()
func (*RegionHeartbeatRequest) Reset ¶
func (m *RegionHeartbeatRequest) Reset()
func (*RegionHeartbeatRequest) Size ¶
func (m *RegionHeartbeatRequest) Size() (n int)
func (*RegionHeartbeatRequest) String ¶
func (m *RegionHeartbeatRequest) String() string
func (*RegionHeartbeatRequest) Unmarshal ¶
func (m *RegionHeartbeatRequest) Unmarshal(data []byte) error
type RegionHeartbeatResponse ¶
type RegionHeartbeatResponse struct { // Notice, Pd only allows handling reported epoch >= current pd's. // Leader peer reports region status with RegionHeartbeatRequest // to pd regularly, pd will determine whether this region // should do ChangePeer or not. // E,g, max peer number is 3, region A, first only peer 1 in A. // 1. Pd region state -> Peers (1), ConfVer (1). // 2. Leader peer 1 reports region state to pd, pd finds the // peer number is < 3, so first changes its current region // state -> Peers (1, 2), ConfVer (1), and returns ChangePeer Adding 2. // 3. Leader does ChangePeer, then reports Peers (1, 2), ConfVer (2), // pd updates its state -> Peers (1, 2), ConfVer (2). // 4. Leader may report old Peers (1), ConfVer (1) to pd before ConfChange // finished, pd stills responses ChangePeer Adding 2, of course, we must // guarantee the second ChangePeer can't be applied in TiKV. ChangePeer *ChangePeer `protobuf:"bytes,1,opt,name=change_peer,json=changePeer" json:"change_peer,omitempty"` // Pd can return transfer_leader to let TiKV does leader transfer itself. TransferLeader *TransferLeader `protobuf:"bytes,2,opt,name=transfer_leader,json=transferLeader" json:"transfer_leader,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RegionHeartbeatResponse) Descriptor ¶
func (*RegionHeartbeatResponse) Descriptor() ([]byte, []int)
func (*RegionHeartbeatResponse) GetChangePeer ¶
func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer
func (*RegionHeartbeatResponse) GetTransferLeader ¶
func (m *RegionHeartbeatResponse) GetTransferLeader() *TransferLeader
func (*RegionHeartbeatResponse) Marshal ¶
func (m *RegionHeartbeatResponse) Marshal() (data []byte, err error)
func (*RegionHeartbeatResponse) MarshalTo ¶
func (m *RegionHeartbeatResponse) MarshalTo(data []byte) (int, error)
func (*RegionHeartbeatResponse) ProtoMessage ¶
func (*RegionHeartbeatResponse) ProtoMessage()
func (*RegionHeartbeatResponse) Reset ¶
func (m *RegionHeartbeatResponse) Reset()
func (*RegionHeartbeatResponse) Size ¶
func (m *RegionHeartbeatResponse) Size() (n int)
func (*RegionHeartbeatResponse) String ¶
func (m *RegionHeartbeatResponse) String() string
func (*RegionHeartbeatResponse) Unmarshal ¶
func (m *RegionHeartbeatResponse) Unmarshal(data []byte) error
type ReportSplitRequest ¶
type ReportSplitRequest struct { Left *metapb.Region `protobuf:"bytes,1,opt,name=left" json:"left,omitempty"` Right *metapb.Region `protobuf:"bytes,2,opt,name=right" json:"right,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ReportSplitRequest) Descriptor ¶
func (*ReportSplitRequest) Descriptor() ([]byte, []int)
func (*ReportSplitRequest) GetLeft ¶
func (m *ReportSplitRequest) GetLeft() *metapb.Region
func (*ReportSplitRequest) GetRight ¶
func (m *ReportSplitRequest) GetRight() *metapb.Region
func (*ReportSplitRequest) Marshal ¶
func (m *ReportSplitRequest) Marshal() (data []byte, err error)
func (*ReportSplitRequest) MarshalTo ¶
func (m *ReportSplitRequest) MarshalTo(data []byte) (int, error)
func (*ReportSplitRequest) ProtoMessage ¶
func (*ReportSplitRequest) ProtoMessage()
func (*ReportSplitRequest) Reset ¶
func (m *ReportSplitRequest) Reset()
func (*ReportSplitRequest) Size ¶
func (m *ReportSplitRequest) Size() (n int)
func (*ReportSplitRequest) String ¶
func (m *ReportSplitRequest) String() string
func (*ReportSplitRequest) Unmarshal ¶
func (m *ReportSplitRequest) Unmarshal(data []byte) error
type ReportSplitResponse ¶
type ReportSplitResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*ReportSplitResponse) Descriptor ¶
func (*ReportSplitResponse) Descriptor() ([]byte, []int)
func (*ReportSplitResponse) Marshal ¶
func (m *ReportSplitResponse) Marshal() (data []byte, err error)
func (*ReportSplitResponse) MarshalTo ¶
func (m *ReportSplitResponse) MarshalTo(data []byte) (int, error)
func (*ReportSplitResponse) ProtoMessage ¶
func (*ReportSplitResponse) ProtoMessage()
func (*ReportSplitResponse) Reset ¶
func (m *ReportSplitResponse) Reset()
func (*ReportSplitResponse) Size ¶
func (m *ReportSplitResponse) Size() (n int)
func (*ReportSplitResponse) String ¶
func (m *ReportSplitResponse) String() string
func (*ReportSplitResponse) Unmarshal ¶
func (m *ReportSplitResponse) Unmarshal(data []byte) error
type Request ¶
type Request struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` CmdType CommandType `protobuf:"varint,2,opt,name=cmd_type,json=cmdType,enum=pdpb.CommandType" json:"cmd_type"` Tso *TsoRequest `protobuf:"bytes,3,opt,name=tso" json:"tso,omitempty"` Bootstrap *BootstrapRequest `protobuf:"bytes,4,opt,name=bootstrap" json:"bootstrap,omitempty"` IsBootstrapped *IsBootstrappedRequest `protobuf:"bytes,5,opt,name=is_bootstrapped,json=isBootstrapped" json:"is_bootstrapped,omitempty"` AllocId *AllocIdRequest `protobuf:"bytes,6,opt,name=alloc_id,json=allocId" json:"alloc_id,omitempty"` GetStore *GetStoreRequest `protobuf:"bytes,7,opt,name=get_store,json=getStore" json:"get_store,omitempty"` PutStore *PutStoreRequest `protobuf:"bytes,8,opt,name=put_store,json=putStore" json:"put_store,omitempty"` AskSplit *AskSplitRequest `protobuf:"bytes,9,opt,name=ask_split,json=askSplit" json:"ask_split,omitempty"` GetRegion *GetRegionRequest `protobuf:"bytes,10,opt,name=get_region,json=getRegion" json:"get_region,omitempty"` RegionHeartbeat *RegionHeartbeatRequest `protobuf:"bytes,11,opt,name=region_heartbeat,json=regionHeartbeat" json:"region_heartbeat,omitempty"` GetClusterConfig *GetClusterConfigRequest `protobuf:"bytes,12,opt,name=get_cluster_config,json=getClusterConfig" json:"get_cluster_config,omitempty"` PutClusterConfig *PutClusterConfigRequest `protobuf:"bytes,13,opt,name=put_cluster_config,json=putClusterConfig" json:"put_cluster_config,omitempty"` StoreHeartbeat *StoreHeartbeatRequest `protobuf:"bytes,14,opt,name=store_heartbeat,json=storeHeartbeat" json:"store_heartbeat,omitempty"` ReportSplit *ReportSplitRequest `protobuf:"bytes,15,opt,name=report_split,json=reportSplit" json:"report_split,omitempty"` GetRegionById *GetRegionByIDRequest `protobuf:"bytes,16,opt,name=get_region_by_id,json=getRegionById" json:"get_region_by_id,omitempty"` GetPdMembers *GetPDMembersRequest `protobuf:"bytes,17,opt,name=get_pd_members,json=getPdMembers" json:"get_pd_members,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Request) Descriptor ¶
func (*Request) GetAllocId ¶
func (m *Request) GetAllocId() *AllocIdRequest
func (*Request) GetAskSplit ¶
func (m *Request) GetAskSplit() *AskSplitRequest
func (*Request) GetBootstrap ¶
func (m *Request) GetBootstrap() *BootstrapRequest
func (*Request) GetCmdType ¶
func (m *Request) GetCmdType() CommandType
func (*Request) GetGetClusterConfig ¶
func (m *Request) GetGetClusterConfig() *GetClusterConfigRequest
func (*Request) GetGetPdMembers ¶
func (m *Request) GetGetPdMembers() *GetPDMembersRequest
func (*Request) GetGetRegion ¶
func (m *Request) GetGetRegion() *GetRegionRequest
func (*Request) GetGetRegionById ¶
func (m *Request) GetGetRegionById() *GetRegionByIDRequest
func (*Request) GetGetStore ¶
func (m *Request) GetGetStore() *GetStoreRequest
func (*Request) GetHeader ¶
func (m *Request) GetHeader() *RequestHeader
func (*Request) GetIsBootstrapped ¶
func (m *Request) GetIsBootstrapped() *IsBootstrappedRequest
func (*Request) GetPutClusterConfig ¶
func (m *Request) GetPutClusterConfig() *PutClusterConfigRequest
func (*Request) GetPutStore ¶
func (m *Request) GetPutStore() *PutStoreRequest
func (*Request) GetRegionHeartbeat ¶
func (m *Request) GetRegionHeartbeat() *RegionHeartbeatRequest
func (*Request) GetReportSplit ¶
func (m *Request) GetReportSplit() *ReportSplitRequest
func (*Request) GetStoreHeartbeat ¶
func (m *Request) GetStoreHeartbeat() *StoreHeartbeatRequest
func (*Request) GetTso ¶
func (m *Request) GetTso() *TsoRequest
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
type RequestHeader ¶
type RequestHeader struct { // 16 bytes, to distinguish request. Uuid []byte `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"` ClusterId uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId" json:"cluster_id"` XXX_unrecognized []byte `json:"-"` }
func (*RequestHeader) Descriptor ¶
func (*RequestHeader) Descriptor() ([]byte, []int)
func (*RequestHeader) GetClusterId ¶
func (m *RequestHeader) GetClusterId() uint64
func (*RequestHeader) GetUuid ¶
func (m *RequestHeader) GetUuid() []byte
func (*RequestHeader) Marshal ¶
func (m *RequestHeader) Marshal() (data []byte, err error)
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) Reset ¶
func (m *RequestHeader) Reset()
func (*RequestHeader) Size ¶
func (m *RequestHeader) Size() (n int)
func (*RequestHeader) String ¶
func (m *RequestHeader) String() string
func (*RequestHeader) Unmarshal ¶
func (m *RequestHeader) Unmarshal(data []byte) error
type Response ¶
type Response struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` CmdType CommandType `protobuf:"varint,2,opt,name=cmd_type,json=cmdType,enum=pdpb.CommandType" json:"cmd_type"` Tso *TsoResponse `protobuf:"bytes,3,opt,name=tso" json:"tso,omitempty"` Bootstrap *BootstrapResponse `protobuf:"bytes,4,opt,name=bootstrap" json:"bootstrap,omitempty"` IsBootstrapped *IsBootstrappedResponse `protobuf:"bytes,5,opt,name=is_bootstrapped,json=isBootstrapped" json:"is_bootstrapped,omitempty"` AllocId *AllocIdResponse `protobuf:"bytes,6,opt,name=alloc_id,json=allocId" json:"alloc_id,omitempty"` GetStore *GetStoreResponse `protobuf:"bytes,7,opt,name=get_store,json=getStore" json:"get_store,omitempty"` PutStore *PutStoreResponse `protobuf:"bytes,8,opt,name=put_store,json=putStore" json:"put_store,omitempty"` AskSplit *AskSplitResponse `protobuf:"bytes,9,opt,name=ask_split,json=askSplit" json:"ask_split,omitempty"` GetRegion *GetRegionResponse `protobuf:"bytes,10,opt,name=get_region,json=getRegion" json:"get_region,omitempty"` RegionHeartbeat *RegionHeartbeatResponse `protobuf:"bytes,11,opt,name=region_heartbeat,json=regionHeartbeat" json:"region_heartbeat,omitempty"` GetClusterConfig *GetClusterConfigResponse `protobuf:"bytes,12,opt,name=get_cluster_config,json=getClusterConfig" json:"get_cluster_config,omitempty"` PutClusterConfig *PutClusterConfigResponse `protobuf:"bytes,13,opt,name=put_cluster_config,json=putClusterConfig" json:"put_cluster_config,omitempty"` StoreHeartbeat *StoreHeartbeatResponse `protobuf:"bytes,14,opt,name=store_heartbeat,json=storeHeartbeat" json:"store_heartbeat,omitempty"` ReportSplit *ReportSplitResponse `protobuf:"bytes,15,opt,name=report_split,json=reportSplit" json:"report_split,omitempty"` GetRegionById *GetRegionResponse `protobuf:"bytes,16,opt,name=get_region_by_id,json=getRegionById" json:"get_region_by_id,omitempty"` GetPdMembers *GetPDMembersResponse `protobuf:"bytes,17,opt,name=get_pd_members,json=getPdMembers" json:"get_pd_members,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Response) Descriptor ¶
func (*Response) GetAllocId ¶
func (m *Response) GetAllocId() *AllocIdResponse
func (*Response) GetAskSplit ¶
func (m *Response) GetAskSplit() *AskSplitResponse
func (*Response) GetBootstrap ¶
func (m *Response) GetBootstrap() *BootstrapResponse
func (*Response) GetCmdType ¶
func (m *Response) GetCmdType() CommandType
func (*Response) GetGetClusterConfig ¶
func (m *Response) GetGetClusterConfig() *GetClusterConfigResponse
func (*Response) GetGetPdMembers ¶
func (m *Response) GetGetPdMembers() *GetPDMembersResponse
func (*Response) GetGetRegion ¶
func (m *Response) GetGetRegion() *GetRegionResponse
func (*Response) GetGetRegionById ¶
func (m *Response) GetGetRegionById() *GetRegionResponse
func (*Response) GetGetStore ¶
func (m *Response) GetGetStore() *GetStoreResponse
func (*Response) GetHeader ¶
func (m *Response) GetHeader() *ResponseHeader
func (*Response) GetIsBootstrapped ¶
func (m *Response) GetIsBootstrapped() *IsBootstrappedResponse
func (*Response) GetPutClusterConfig ¶
func (m *Response) GetPutClusterConfig() *PutClusterConfigResponse
func (*Response) GetPutStore ¶
func (m *Response) GetPutStore() *PutStoreResponse
func (*Response) GetRegionHeartbeat ¶
func (m *Response) GetRegionHeartbeat() *RegionHeartbeatResponse
func (*Response) GetReportSplit ¶
func (m *Response) GetReportSplit() *ReportSplitResponse
func (*Response) GetStoreHeartbeat ¶
func (m *Response) GetStoreHeartbeat() *StoreHeartbeatResponse
func (*Response) GetTso ¶
func (m *Response) GetTso() *TsoResponse
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
type ResponseHeader ¶
type ResponseHeader struct { // 16 bytes, to distinguish request. Uuid []byte `protobuf:"bytes,1,opt,name=uuid" json:"uuid,omitempty"` ClusterId uint64 `protobuf:"varint,2,opt,name=cluster_id,json=clusterId" json:"cluster_id"` Error *Error `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ResponseHeader) Descriptor ¶
func (*ResponseHeader) Descriptor() ([]byte, []int)
func (*ResponseHeader) GetClusterId ¶
func (m *ResponseHeader) GetClusterId() uint64
func (*ResponseHeader) GetError ¶
func (m *ResponseHeader) GetError() *Error
func (*ResponseHeader) GetUuid ¶
func (m *ResponseHeader) GetUuid() []byte
func (*ResponseHeader) Marshal ¶
func (m *ResponseHeader) Marshal() (data []byte, err error)
func (*ResponseHeader) ProtoMessage ¶
func (*ResponseHeader) ProtoMessage()
func (*ResponseHeader) Reset ¶
func (m *ResponseHeader) Reset()
func (*ResponseHeader) Size ¶
func (m *ResponseHeader) Size() (n int)
func (*ResponseHeader) String ¶
func (m *ResponseHeader) String() string
func (*ResponseHeader) Unmarshal ¶
func (m *ResponseHeader) Unmarshal(data []byte) error
type StoreHeartbeatRequest ¶
type StoreHeartbeatRequest struct { Stats *StoreStats `protobuf:"bytes,1,opt,name=stats" json:"stats,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StoreHeartbeatRequest) Descriptor ¶
func (*StoreHeartbeatRequest) Descriptor() ([]byte, []int)
func (*StoreHeartbeatRequest) GetStats ¶
func (m *StoreHeartbeatRequest) GetStats() *StoreStats
func (*StoreHeartbeatRequest) Marshal ¶
func (m *StoreHeartbeatRequest) Marshal() (data []byte, err error)
func (*StoreHeartbeatRequest) MarshalTo ¶
func (m *StoreHeartbeatRequest) MarshalTo(data []byte) (int, error)
func (*StoreHeartbeatRequest) ProtoMessage ¶
func (*StoreHeartbeatRequest) ProtoMessage()
func (*StoreHeartbeatRequest) Reset ¶
func (m *StoreHeartbeatRequest) Reset()
func (*StoreHeartbeatRequest) Size ¶
func (m *StoreHeartbeatRequest) Size() (n int)
func (*StoreHeartbeatRequest) String ¶
func (m *StoreHeartbeatRequest) String() string
func (*StoreHeartbeatRequest) Unmarshal ¶
func (m *StoreHeartbeatRequest) Unmarshal(data []byte) error
type StoreHeartbeatResponse ¶
type StoreHeartbeatResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*StoreHeartbeatResponse) Descriptor ¶
func (*StoreHeartbeatResponse) Descriptor() ([]byte, []int)
func (*StoreHeartbeatResponse) Marshal ¶
func (m *StoreHeartbeatResponse) Marshal() (data []byte, err error)
func (*StoreHeartbeatResponse) MarshalTo ¶
func (m *StoreHeartbeatResponse) MarshalTo(data []byte) (int, error)
func (*StoreHeartbeatResponse) ProtoMessage ¶
func (*StoreHeartbeatResponse) ProtoMessage()
func (*StoreHeartbeatResponse) Reset ¶
func (m *StoreHeartbeatResponse) Reset()
func (*StoreHeartbeatResponse) Size ¶
func (m *StoreHeartbeatResponse) Size() (n int)
func (*StoreHeartbeatResponse) String ¶
func (m *StoreHeartbeatResponse) String() string
func (*StoreHeartbeatResponse) Unmarshal ¶
func (m *StoreHeartbeatResponse) Unmarshal(data []byte) error
type StoreIsTombstoneError ¶
type StoreIsTombstoneError struct {
XXX_unrecognized []byte `json:"-"`
}
func (*StoreIsTombstoneError) Descriptor ¶
func (*StoreIsTombstoneError) Descriptor() ([]byte, []int)
func (*StoreIsTombstoneError) Marshal ¶
func (m *StoreIsTombstoneError) Marshal() (data []byte, err error)
func (*StoreIsTombstoneError) MarshalTo ¶
func (m *StoreIsTombstoneError) MarshalTo(data []byte) (int, error)
func (*StoreIsTombstoneError) ProtoMessage ¶
func (*StoreIsTombstoneError) ProtoMessage()
func (*StoreIsTombstoneError) Reset ¶
func (m *StoreIsTombstoneError) Reset()
func (*StoreIsTombstoneError) Size ¶
func (m *StoreIsTombstoneError) Size() (n int)
func (*StoreIsTombstoneError) String ¶
func (m *StoreIsTombstoneError) String() string
func (*StoreIsTombstoneError) Unmarshal ¶
func (m *StoreIsTombstoneError) Unmarshal(data []byte) error
type StoreStats ¶
type StoreStats struct { StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId" json:"store_id"` // Capacity for the store. Capacity uint64 `protobuf:"varint,2,opt,name=capacity" json:"capacity"` // Available size for the store. Available uint64 `protobuf:"varint,3,opt,name=available" json:"available"` // Total region count in this store. RegionCount uint32 `protobuf:"varint,4,opt,name=region_count,json=regionCount" json:"region_count"` // Current sending snapshot count. SendingSnapCount uint32 `protobuf:"varint,5,opt,name=sending_snap_count,json=sendingSnapCount" json:"sending_snap_count"` // Current receiving snapshot count. ReceivingSnapCount uint32 `protobuf:"varint,6,opt,name=receiving_snap_count,json=receivingSnapCount" json:"receiving_snap_count"` // When the store is started (unix timestamp in seconds). StartTime uint32 `protobuf:"varint,7,opt,name=start_time,json=startTime" json:"start_time"` // How many region is applying snapshot. ApplyingSnapCount uint32 `protobuf:"varint,8,opt,name=applying_snap_count,json=applyingSnapCount" json:"applying_snap_count"` XXX_unrecognized []byte `json:"-"` }
func (*StoreStats) Descriptor ¶
func (*StoreStats) Descriptor() ([]byte, []int)
func (*StoreStats) GetApplyingSnapCount ¶
func (m *StoreStats) GetApplyingSnapCount() uint32
func (*StoreStats) GetAvailable ¶
func (m *StoreStats) GetAvailable() uint64
func (*StoreStats) GetCapacity ¶
func (m *StoreStats) GetCapacity() uint64
func (*StoreStats) GetReceivingSnapCount ¶
func (m *StoreStats) GetReceivingSnapCount() uint32
func (*StoreStats) GetRegionCount ¶
func (m *StoreStats) GetRegionCount() uint32
func (*StoreStats) GetSendingSnapCount ¶
func (m *StoreStats) GetSendingSnapCount() uint32
func (*StoreStats) GetStartTime ¶
func (m *StoreStats) GetStartTime() uint32
func (*StoreStats) GetStoreId ¶
func (m *StoreStats) GetStoreId() uint64
func (*StoreStats) Marshal ¶
func (m *StoreStats) Marshal() (data []byte, err error)
func (*StoreStats) ProtoMessage ¶
func (*StoreStats) ProtoMessage()
func (*StoreStats) Reset ¶
func (m *StoreStats) Reset()
func (*StoreStats) Size ¶
func (m *StoreStats) Size() (n int)
func (*StoreStats) String ¶
func (m *StoreStats) String() string
func (*StoreStats) Unmarshal ¶
func (m *StoreStats) Unmarshal(data []byte) error
type Timestamp ¶
type Timestamp struct { Physical int64 `protobuf:"varint,1,opt,name=physical" json:"physical"` Logical int64 `protobuf:"varint,2,opt,name=logical" json:"logical"` XXX_unrecognized []byte `json:"-"` }
func (*Timestamp) Descriptor ¶
func (*Timestamp) GetLogical ¶
func (*Timestamp) GetPhysical ¶
func (*Timestamp) ProtoMessage ¶
func (*Timestamp) ProtoMessage()
type TransferLeader ¶
type TransferLeader struct { Peer *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*TransferLeader) Descriptor ¶
func (*TransferLeader) Descriptor() ([]byte, []int)
func (*TransferLeader) GetPeer ¶
func (m *TransferLeader) GetPeer() *metapb.Peer
func (*TransferLeader) Marshal ¶
func (m *TransferLeader) Marshal() (data []byte, err error)
func (*TransferLeader) ProtoMessage ¶
func (*TransferLeader) ProtoMessage()
func (*TransferLeader) Reset ¶
func (m *TransferLeader) Reset()
func (*TransferLeader) Size ¶
func (m *TransferLeader) Size() (n int)
func (*TransferLeader) String ¶
func (m *TransferLeader) String() string
func (*TransferLeader) Unmarshal ¶
func (m *TransferLeader) Unmarshal(data []byte) error
type TsoRequest ¶
type TsoRequest struct { Count uint32 `protobuf:"varint,1,opt,name=count" json:"count"` XXX_unrecognized []byte `json:"-"` }
func (*TsoRequest) Descriptor ¶
func (*TsoRequest) Descriptor() ([]byte, []int)
func (*TsoRequest) GetCount ¶
func (m *TsoRequest) GetCount() uint32
func (*TsoRequest) Marshal ¶
func (m *TsoRequest) Marshal() (data []byte, err error)
func (*TsoRequest) ProtoMessage ¶
func (*TsoRequest) ProtoMessage()
func (*TsoRequest) Reset ¶
func (m *TsoRequest) Reset()
func (*TsoRequest) Size ¶
func (m *TsoRequest) Size() (n int)
func (*TsoRequest) String ¶
func (m *TsoRequest) String() string
func (*TsoRequest) Unmarshal ¶
func (m *TsoRequest) Unmarshal(data []byte) error
type TsoResponse ¶
type TsoResponse struct { Count uint32 `protobuf:"varint,1,opt,name=count" json:"count"` Timestamp Timestamp `protobuf:"bytes,2,opt,name=timestamp" json:"timestamp"` XXX_unrecognized []byte `json:"-"` }
func (*TsoResponse) Descriptor ¶
func (*TsoResponse) Descriptor() ([]byte, []int)
func (*TsoResponse) GetCount ¶
func (m *TsoResponse) GetCount() uint32
func (*TsoResponse) GetTimestamp ¶
func (m *TsoResponse) GetTimestamp() Timestamp
func (*TsoResponse) Marshal ¶
func (m *TsoResponse) Marshal() (data []byte, err error)
func (*TsoResponse) ProtoMessage ¶
func (*TsoResponse) ProtoMessage()
func (*TsoResponse) Reset ¶
func (m *TsoResponse) Reset()
func (*TsoResponse) Size ¶
func (m *TsoResponse) Size() (n int)
func (*TsoResponse) String ¶
func (m *TsoResponse) String() string
func (*TsoResponse) Unmarshal ¶
func (m *TsoResponse) Unmarshal(data []byte) error
Click to show internal directories.
Click to hide internal directories.