Versions in this module Expand all Collapse all v1 v1.0.0 Oct 16, 2017 Changes in this version + var ConfChangeType_name = map[int32]string + var ConfChangeType_value = map[string]int32 + var ErrIntOverflowPdpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPdpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrorType_name = map[int32]string + var ErrorType_value = map[string]int32 + func RegisterPDServer(s *grpc.Server, srv PDServer) + type AllocIDRequest struct + Header *RequestHeader + func (*AllocIDRequest) Descriptor() ([]byte, []int) + func (*AllocIDRequest) ProtoMessage() + func (m *AllocIDRequest) GetHeader() *RequestHeader + func (m *AllocIDRequest) Marshal() (dAtA []byte, err error) + func (m *AllocIDRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AllocIDRequest) Reset() + func (m *AllocIDRequest) Size() (n int) + func (m *AllocIDRequest) String() string + func (m *AllocIDRequest) Unmarshal(dAtA []byte) error + type AllocIDResponse struct + Header *ResponseHeader + Id uint64 + func (*AllocIDResponse) Descriptor() ([]byte, []int) + func (*AllocIDResponse) ProtoMessage() + func (m *AllocIDResponse) GetHeader() *ResponseHeader + func (m *AllocIDResponse) GetId() uint64 + func (m *AllocIDResponse) Marshal() (dAtA []byte, err error) + func (m *AllocIDResponse) MarshalTo(dAtA []byte) (int, error) + func (m *AllocIDResponse) Reset() + func (m *AllocIDResponse) Size() (n int) + func (m *AllocIDResponse) String() string + func (m *AllocIDResponse) Unmarshal(dAtA []byte) error + type AskSplitRequest struct + Header *RequestHeader + Region *metapb.Region + func (*AskSplitRequest) Descriptor() ([]byte, []int) + func (*AskSplitRequest) ProtoMessage() + func (m *AskSplitRequest) GetHeader() *RequestHeader + func (m *AskSplitRequest) GetRegion() *metapb.Region + func (m *AskSplitRequest) Marshal() (dAtA []byte, err error) + func (m *AskSplitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *AskSplitRequest) Reset() + func (m *AskSplitRequest) Size() (n int) + func (m *AskSplitRequest) String() string + func (m *AskSplitRequest) Unmarshal(dAtA []byte) error + type AskSplitResponse struct + Header *ResponseHeader + NewPeerIds []uint64 + NewRegionId uint64 + func (*AskSplitResponse) Descriptor() ([]byte, []int) + func (*AskSplitResponse) ProtoMessage() + func (m *AskSplitResponse) GetHeader() *ResponseHeader + 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 (m *AskSplitResponse) Reset() + func (m *AskSplitResponse) Size() (n int) + func (m *AskSplitResponse) String() string + func (m *AskSplitResponse) Unmarshal(dAtA []byte) error + type BootstrapRequest struct + Header *RequestHeader + Region *metapb.Region + Store *metapb.Store + func (*BootstrapRequest) Descriptor() ([]byte, []int) + func (*BootstrapRequest) ProtoMessage() + func (m *BootstrapRequest) GetHeader() *RequestHeader + 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 (m *BootstrapRequest) Reset() + func (m *BootstrapRequest) Size() (n int) + func (m *BootstrapRequest) String() string + func (m *BootstrapRequest) Unmarshal(dAtA []byte) error + type BootstrapResponse struct + Header *ResponseHeader + func (*BootstrapResponse) Descriptor() ([]byte, []int) + func (*BootstrapResponse) ProtoMessage() + func (m *BootstrapResponse) GetHeader() *ResponseHeader + func (m *BootstrapResponse) Marshal() (dAtA []byte, err error) + func (m *BootstrapResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BootstrapResponse) Reset() + func (m *BootstrapResponse) Size() (n int) + func (m *BootstrapResponse) String() string + func (m *BootstrapResponse) Unmarshal(dAtA []byte) error + type ChangePeer struct + ChangeType ConfChangeType + Peer *metapb.Peer + func (*ChangePeer) Descriptor() ([]byte, []int) + func (*ChangePeer) ProtoMessage() + func (m *ChangePeer) GetChangeType() ConfChangeType + func (m *ChangePeer) GetPeer() *metapb.Peer + func (m *ChangePeer) Marshal() (dAtA []byte, err error) + func (m *ChangePeer) MarshalTo(dAtA []byte) (int, error) + func (m *ChangePeer) Reset() + func (m *ChangePeer) Size() (n int) + func (m *ChangePeer) String() string + func (m *ChangePeer) Unmarshal(dAtA []byte) error + type ConfChangeType int32 + const ConfChangeType_AddNode + const ConfChangeType_RemoveNode + func (ConfChangeType) EnumDescriptor() ([]byte, []int) + func (x ConfChangeType) String() string + type Error struct + Message string + Type ErrorType + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetMessage() string + func (m *Error) GetType() ErrorType + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + type ErrorType int32 + const ErrorType_ALREADY_BOOTSTRAPPED + const ErrorType_NOT_BOOTSTRAPPED + const ErrorType_OK + const ErrorType_STORE_TOMBSTONE + const ErrorType_UNKNOWN + func (ErrorType) EnumDescriptor() ([]byte, []int) + func (x ErrorType) String() string + type GetClusterConfigRequest struct + Header *RequestHeader + func (*GetClusterConfigRequest) Descriptor() ([]byte, []int) + func (*GetClusterConfigRequest) ProtoMessage() + func (m *GetClusterConfigRequest) GetHeader() *RequestHeader + func (m *GetClusterConfigRequest) Marshal() (dAtA []byte, err error) + func (m *GetClusterConfigRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetClusterConfigRequest) Reset() + func (m *GetClusterConfigRequest) Size() (n int) + func (m *GetClusterConfigRequest) String() string + func (m *GetClusterConfigRequest) Unmarshal(dAtA []byte) error + type GetClusterConfigResponse struct + Cluster *metapb.Cluster + Header *ResponseHeader + func (*GetClusterConfigResponse) Descriptor() ([]byte, []int) + func (*GetClusterConfigResponse) ProtoMessage() + func (m *GetClusterConfigResponse) GetCluster() *metapb.Cluster + func (m *GetClusterConfigResponse) GetHeader() *ResponseHeader + func (m *GetClusterConfigResponse) Marshal() (dAtA []byte, err error) + func (m *GetClusterConfigResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetClusterConfigResponse) Reset() + func (m *GetClusterConfigResponse) Size() (n int) + func (m *GetClusterConfigResponse) String() string + func (m *GetClusterConfigResponse) Unmarshal(dAtA []byte) error + type GetMembersRequest struct + Header *RequestHeader + func (*GetMembersRequest) Descriptor() ([]byte, []int) + func (*GetMembersRequest) ProtoMessage() + func (m *GetMembersRequest) GetHeader() *RequestHeader + func (m *GetMembersRequest) Marshal() (dAtA []byte, err error) + func (m *GetMembersRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetMembersRequest) Reset() + func (m *GetMembersRequest) Size() (n int) + func (m *GetMembersRequest) String() string + func (m *GetMembersRequest) Unmarshal(dAtA []byte) error + type GetMembersResponse struct + Header *ResponseHeader + Leader *Member + Members []*Member + func (*GetMembersResponse) Descriptor() ([]byte, []int) + func (*GetMembersResponse) ProtoMessage() + func (m *GetMembersResponse) GetHeader() *ResponseHeader + func (m *GetMembersResponse) GetLeader() *Member + func (m *GetMembersResponse) GetMembers() []*Member + func (m *GetMembersResponse) Marshal() (dAtA []byte, err error) + func (m *GetMembersResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetMembersResponse) Reset() + func (m *GetMembersResponse) Size() (n int) + func (m *GetMembersResponse) String() string + func (m *GetMembersResponse) Unmarshal(dAtA []byte) error + type GetRegionByIDRequest struct + Header *RequestHeader + RegionId uint64 + func (*GetRegionByIDRequest) Descriptor() ([]byte, []int) + func (*GetRegionByIDRequest) ProtoMessage() + func (m *GetRegionByIDRequest) GetHeader() *RequestHeader + func (m *GetRegionByIDRequest) GetRegionId() uint64 + func (m *GetRegionByIDRequest) Marshal() (dAtA []byte, err error) + func (m *GetRegionByIDRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRegionByIDRequest) Reset() + func (m *GetRegionByIDRequest) Size() (n int) + func (m *GetRegionByIDRequest) String() string + func (m *GetRegionByIDRequest) Unmarshal(dAtA []byte) error + type GetRegionRequest struct + Header *RequestHeader + RegionKey []byte + func (*GetRegionRequest) Descriptor() ([]byte, []int) + func (*GetRegionRequest) ProtoMessage() + func (m *GetRegionRequest) GetHeader() *RequestHeader + func (m *GetRegionRequest) GetRegionKey() []byte + func (m *GetRegionRequest) Marshal() (dAtA []byte, err error) + func (m *GetRegionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetRegionRequest) Reset() + func (m *GetRegionRequest) Size() (n int) + func (m *GetRegionRequest) String() string + func (m *GetRegionRequest) Unmarshal(dAtA []byte) error + type GetRegionResponse struct + Header *ResponseHeader + Leader *metapb.Peer + Region *metapb.Region + func (*GetRegionResponse) Descriptor() ([]byte, []int) + func (*GetRegionResponse) ProtoMessage() + func (m *GetRegionResponse) GetHeader() *ResponseHeader + 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 (m *GetRegionResponse) Reset() + func (m *GetRegionResponse) Size() (n int) + func (m *GetRegionResponse) String() string + func (m *GetRegionResponse) Unmarshal(dAtA []byte) error + type GetStoreRequest struct + Header *RequestHeader + StoreId uint64 + func (*GetStoreRequest) Descriptor() ([]byte, []int) + func (*GetStoreRequest) ProtoMessage() + func (m *GetStoreRequest) GetHeader() *RequestHeader + func (m *GetStoreRequest) GetStoreId() uint64 + func (m *GetStoreRequest) Marshal() (dAtA []byte, err error) + func (m *GetStoreRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetStoreRequest) Reset() + func (m *GetStoreRequest) Size() (n int) + func (m *GetStoreRequest) String() string + func (m *GetStoreRequest) Unmarshal(dAtA []byte) error + type GetStoreResponse struct + Header *ResponseHeader + Store *metapb.Store + func (*GetStoreResponse) Descriptor() ([]byte, []int) + func (*GetStoreResponse) ProtoMessage() + func (m *GetStoreResponse) GetHeader() *ResponseHeader + func (m *GetStoreResponse) GetStore() *metapb.Store + func (m *GetStoreResponse) Marshal() (dAtA []byte, err error) + func (m *GetStoreResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetStoreResponse) Reset() + func (m *GetStoreResponse) Size() (n int) + func (m *GetStoreResponse) String() string + func (m *GetStoreResponse) Unmarshal(dAtA []byte) error + type IsBootstrappedRequest struct + Header *RequestHeader + func (*IsBootstrappedRequest) Descriptor() ([]byte, []int) + func (*IsBootstrappedRequest) ProtoMessage() + func (m *IsBootstrappedRequest) GetHeader() *RequestHeader + func (m *IsBootstrappedRequest) Marshal() (dAtA []byte, err error) + func (m *IsBootstrappedRequest) MarshalTo(dAtA []byte) (int, error) + func (m *IsBootstrappedRequest) Reset() + func (m *IsBootstrappedRequest) Size() (n int) + func (m *IsBootstrappedRequest) String() string + func (m *IsBootstrappedRequest) Unmarshal(dAtA []byte) error + type IsBootstrappedResponse struct + Bootstrapped bool + Header *ResponseHeader + func (*IsBootstrappedResponse) Descriptor() ([]byte, []int) + func (*IsBootstrappedResponse) ProtoMessage() + func (m *IsBootstrappedResponse) GetBootstrapped() bool + func (m *IsBootstrappedResponse) GetHeader() *ResponseHeader + func (m *IsBootstrappedResponse) Marshal() (dAtA []byte, err error) + func (m *IsBootstrappedResponse) MarshalTo(dAtA []byte) (int, error) + func (m *IsBootstrappedResponse) Reset() + func (m *IsBootstrappedResponse) Size() (n int) + func (m *IsBootstrappedResponse) String() string + func (m *IsBootstrappedResponse) Unmarshal(dAtA []byte) error + type Member struct + ClientUrls []string + MemberId uint64 + Name string + PeerUrls []string + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + func (m *Member) GetClientUrls() []string + func (m *Member) GetMemberId() uint64 + func (m *Member) GetName() string + func (m *Member) GetPeerUrls() []string + func (m *Member) Marshal() (dAtA []byte, err error) + func (m *Member) MarshalTo(dAtA []byte) (int, error) + func (m *Member) Reset() + func (m *Member) Size() (n int) + func (m *Member) String() string + func (m *Member) Unmarshal(dAtA []byte) error + type PDClient interface + AllocID func(ctx context.Context, in *AllocIDRequest, opts ...grpc.CallOption) (*AllocIDResponse, error) + AskSplit func(ctx context.Context, in *AskSplitRequest, opts ...grpc.CallOption) (*AskSplitResponse, error) + Bootstrap func(ctx context.Context, in *BootstrapRequest, opts ...grpc.CallOption) (*BootstrapResponse, error) + GetClusterConfig func(ctx context.Context, in *GetClusterConfigRequest, opts ...grpc.CallOption) (*GetClusterConfigResponse, error) + GetMembers func(ctx context.Context, in *GetMembersRequest, opts ...grpc.CallOption) (*GetMembersResponse, error) + GetRegion func(ctx context.Context, in *GetRegionRequest, opts ...grpc.CallOption) (*GetRegionResponse, error) + GetRegionByID func(ctx context.Context, in *GetRegionByIDRequest, opts ...grpc.CallOption) (*GetRegionResponse, error) + GetStore func(ctx context.Context, in *GetStoreRequest, opts ...grpc.CallOption) (*GetStoreResponse, error) + IsBootstrapped func(ctx context.Context, in *IsBootstrappedRequest, opts ...grpc.CallOption) (*IsBootstrappedResponse, error) + PutClusterConfig func(ctx context.Context, in *PutClusterConfigRequest, opts ...grpc.CallOption) (*PutClusterConfigResponse, error) + PutStore func(ctx context.Context, in *PutStoreRequest, opts ...grpc.CallOption) (*PutStoreResponse, error) + RegionHeartbeat func(ctx context.Context, opts ...grpc.CallOption) (PD_RegionHeartbeatClient, error) + ReportSplit func(ctx context.Context, in *ReportSplitRequest, opts ...grpc.CallOption) (*ReportSplitResponse, error) + StoreHeartbeat func(ctx context.Context, in *StoreHeartbeatRequest, opts ...grpc.CallOption) (*StoreHeartbeatResponse, error) + Tso func(ctx context.Context, opts ...grpc.CallOption) (PD_TsoClient, error) + func NewPDClient(cc *grpc.ClientConn) PDClient + type PDServer interface + AllocID func(context.Context, *AllocIDRequest) (*AllocIDResponse, error) + AskSplit func(context.Context, *AskSplitRequest) (*AskSplitResponse, error) + Bootstrap func(context.Context, *BootstrapRequest) (*BootstrapResponse, error) + GetClusterConfig func(context.Context, *GetClusterConfigRequest) (*GetClusterConfigResponse, error) + GetMembers func(context.Context, *GetMembersRequest) (*GetMembersResponse, error) + GetRegion func(context.Context, *GetRegionRequest) (*GetRegionResponse, error) + GetRegionByID func(context.Context, *GetRegionByIDRequest) (*GetRegionResponse, error) + GetStore func(context.Context, *GetStoreRequest) (*GetStoreResponse, error) + IsBootstrapped func(context.Context, *IsBootstrappedRequest) (*IsBootstrappedResponse, error) + PutClusterConfig func(context.Context, *PutClusterConfigRequest) (*PutClusterConfigResponse, error) + PutStore func(context.Context, *PutStoreRequest) (*PutStoreResponse, error) + RegionHeartbeat func(PD_RegionHeartbeatServer) error + ReportSplit func(context.Context, *ReportSplitRequest) (*ReportSplitResponse, error) + StoreHeartbeat func(context.Context, *StoreHeartbeatRequest) (*StoreHeartbeatResponse, error) + Tso func(PD_TsoServer) error + type PD_RegionHeartbeatClient interface + Recv func() (*RegionHeartbeatResponse, error) + Send func(*RegionHeartbeatRequest) error + type PD_RegionHeartbeatServer interface + Recv func() (*RegionHeartbeatRequest, error) + Send func(*RegionHeartbeatResponse) error + type PD_TsoClient interface + Recv func() (*TsoResponse, error) + Send func(*TsoRequest) error + type PD_TsoServer interface + Recv func() (*TsoRequest, error) + Send func(*TsoResponse) error + type PeerStats struct + DownSeconds uint64 + Peer *metapb.Peer + func (*PeerStats) Descriptor() ([]byte, []int) + func (*PeerStats) ProtoMessage() + 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 (m *PeerStats) Reset() + func (m *PeerStats) Size() (n int) + func (m *PeerStats) String() string + func (m *PeerStats) Unmarshal(dAtA []byte) error + type PutClusterConfigRequest struct + Cluster *metapb.Cluster + Header *RequestHeader + func (*PutClusterConfigRequest) Descriptor() ([]byte, []int) + func (*PutClusterConfigRequest) ProtoMessage() + func (m *PutClusterConfigRequest) GetCluster() *metapb.Cluster + func (m *PutClusterConfigRequest) GetHeader() *RequestHeader + func (m *PutClusterConfigRequest) Marshal() (dAtA []byte, err error) + func (m *PutClusterConfigRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutClusterConfigRequest) Reset() + func (m *PutClusterConfigRequest) Size() (n int) + func (m *PutClusterConfigRequest) String() string + func (m *PutClusterConfigRequest) Unmarshal(dAtA []byte) error + type PutClusterConfigResponse struct + Header *ResponseHeader + func (*PutClusterConfigResponse) Descriptor() ([]byte, []int) + func (*PutClusterConfigResponse) ProtoMessage() + func (m *PutClusterConfigResponse) GetHeader() *ResponseHeader + func (m *PutClusterConfigResponse) Marshal() (dAtA []byte, err error) + func (m *PutClusterConfigResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutClusterConfigResponse) Reset() + func (m *PutClusterConfigResponse) Size() (n int) + func (m *PutClusterConfigResponse) String() string + func (m *PutClusterConfigResponse) Unmarshal(dAtA []byte) error + type PutStoreRequest struct + Header *RequestHeader + Store *metapb.Store + func (*PutStoreRequest) Descriptor() ([]byte, []int) + func (*PutStoreRequest) ProtoMessage() + func (m *PutStoreRequest) GetHeader() *RequestHeader + func (m *PutStoreRequest) GetStore() *metapb.Store + func (m *PutStoreRequest) Marshal() (dAtA []byte, err error) + func (m *PutStoreRequest) MarshalTo(dAtA []byte) (int, error) + func (m *PutStoreRequest) Reset() + func (m *PutStoreRequest) Size() (n int) + func (m *PutStoreRequest) String() string + func (m *PutStoreRequest) Unmarshal(dAtA []byte) error + type PutStoreResponse struct + Header *ResponseHeader + func (*PutStoreResponse) Descriptor() ([]byte, []int) + func (*PutStoreResponse) ProtoMessage() + func (m *PutStoreResponse) GetHeader() *ResponseHeader + func (m *PutStoreResponse) Marshal() (dAtA []byte, err error) + func (m *PutStoreResponse) MarshalTo(dAtA []byte) (int, error) + func (m *PutStoreResponse) Reset() + func (m *PutStoreResponse) Size() (n int) + func (m *PutStoreResponse) String() string + func (m *PutStoreResponse) Unmarshal(dAtA []byte) error + type RegionHeartbeatRequest struct + ApproximateSize uint64 + BytesRead uint64 + BytesWritten uint64 + DownPeers []*PeerStats + Header *RequestHeader + KeysRead uint64 + KeysWritten uint64 + Leader *metapb.Peer + PendingPeers []*metapb.Peer + Region *metapb.Region + func (*RegionHeartbeatRequest) Descriptor() ([]byte, []int) + func (*RegionHeartbeatRequest) ProtoMessage() + func (m *RegionHeartbeatRequest) GetApproximateSize() uint64 + func (m *RegionHeartbeatRequest) GetBytesRead() uint64 + func (m *RegionHeartbeatRequest) GetBytesWritten() uint64 + func (m *RegionHeartbeatRequest) GetDownPeers() []*PeerStats + func (m *RegionHeartbeatRequest) GetHeader() *RequestHeader + func (m *RegionHeartbeatRequest) GetKeysRead() uint64 + func (m *RegionHeartbeatRequest) GetKeysWritten() uint64 + func (m *RegionHeartbeatRequest) GetLeader() *metapb.Peer + func (m *RegionHeartbeatRequest) GetPendingPeers() []*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 (m *RegionHeartbeatRequest) Reset() + func (m *RegionHeartbeatRequest) Size() (n int) + func (m *RegionHeartbeatRequest) String() string + func (m *RegionHeartbeatRequest) Unmarshal(dAtA []byte) error + type RegionHeartbeatResponse struct + ChangePeer *ChangePeer + Header *ResponseHeader + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + TargetPeer *metapb.Peer + TransferLeader *TransferLeader + func (*RegionHeartbeatResponse) Descriptor() ([]byte, []int) + func (*RegionHeartbeatResponse) ProtoMessage() + func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer + func (m *RegionHeartbeatResponse) GetHeader() *ResponseHeader + func (m *RegionHeartbeatResponse) GetRegionEpoch() *metapb.RegionEpoch + func (m *RegionHeartbeatResponse) GetRegionId() uint64 + func (m *RegionHeartbeatResponse) GetTargetPeer() *metapb.Peer + func (m *RegionHeartbeatResponse) GetTransferLeader() *TransferLeader + func (m *RegionHeartbeatResponse) Marshal() (dAtA []byte, err error) + func (m *RegionHeartbeatResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RegionHeartbeatResponse) Reset() + func (m *RegionHeartbeatResponse) Size() (n int) + func (m *RegionHeartbeatResponse) String() string + func (m *RegionHeartbeatResponse) Unmarshal(dAtA []byte) error + type ReportSplitRequest struct + Header *RequestHeader + Left *metapb.Region + Right *metapb.Region + func (*ReportSplitRequest) Descriptor() ([]byte, []int) + func (*ReportSplitRequest) ProtoMessage() + func (m *ReportSplitRequest) GetHeader() *RequestHeader + 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 (m *ReportSplitRequest) Reset() + func (m *ReportSplitRequest) Size() (n int) + func (m *ReportSplitRequest) String() string + func (m *ReportSplitRequest) Unmarshal(dAtA []byte) error + type ReportSplitResponse struct + Header *ResponseHeader + func (*ReportSplitResponse) Descriptor() ([]byte, []int) + func (*ReportSplitResponse) ProtoMessage() + func (m *ReportSplitResponse) GetHeader() *ResponseHeader + func (m *ReportSplitResponse) Marshal() (dAtA []byte, err error) + func (m *ReportSplitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ReportSplitResponse) Reset() + func (m *ReportSplitResponse) Size() (n int) + func (m *ReportSplitResponse) String() string + func (m *ReportSplitResponse) Unmarshal(dAtA []byte) error + type RequestHeader struct + ClusterId uint64 + func (*RequestHeader) Descriptor() ([]byte, []int) + func (*RequestHeader) ProtoMessage() + func (m *RequestHeader) GetClusterId() uint64 + func (m *RequestHeader) Marshal() (dAtA []byte, err error) + func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error) + func (m *RequestHeader) Reset() + func (m *RequestHeader) Size() (n int) + func (m *RequestHeader) String() string + func (m *RequestHeader) Unmarshal(dAtA []byte) error + type ResponseHeader struct + ClusterId uint64 + Error *Error + func (*ResponseHeader) Descriptor() ([]byte, []int) + func (*ResponseHeader) ProtoMessage() + func (m *ResponseHeader) GetClusterId() uint64 + func (m *ResponseHeader) GetError() *Error + func (m *ResponseHeader) Marshal() (dAtA []byte, err error) + func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) Size() (n int) + func (m *ResponseHeader) String() string + func (m *ResponseHeader) Unmarshal(dAtA []byte) error + type StoreHeartbeatRequest struct + Header *RequestHeader + Stats *StoreStats + func (*StoreHeartbeatRequest) Descriptor() ([]byte, []int) + func (*StoreHeartbeatRequest) ProtoMessage() + func (m *StoreHeartbeatRequest) GetHeader() *RequestHeader + func (m *StoreHeartbeatRequest) GetStats() *StoreStats + func (m *StoreHeartbeatRequest) Marshal() (dAtA []byte, err error) + func (m *StoreHeartbeatRequest) MarshalTo(dAtA []byte) (int, error) + func (m *StoreHeartbeatRequest) Reset() + func (m *StoreHeartbeatRequest) Size() (n int) + func (m *StoreHeartbeatRequest) String() string + func (m *StoreHeartbeatRequest) Unmarshal(dAtA []byte) error + type StoreHeartbeatResponse struct + Header *ResponseHeader + func (*StoreHeartbeatResponse) Descriptor() ([]byte, []int) + func (*StoreHeartbeatResponse) ProtoMessage() + func (m *StoreHeartbeatResponse) GetHeader() *ResponseHeader + func (m *StoreHeartbeatResponse) Marshal() (dAtA []byte, err error) + func (m *StoreHeartbeatResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StoreHeartbeatResponse) Reset() + func (m *StoreHeartbeatResponse) Size() (n int) + func (m *StoreHeartbeatResponse) String() string + func (m *StoreHeartbeatResponse) Unmarshal(dAtA []byte) error + type StoreStats struct + ApplyingSnapCount uint32 + Available uint64 + BytesRead uint64 + BytesWritten uint64 + Capacity uint64 + IsBusy bool + KeysRead uint64 + KeysWritten uint64 + ReceivingSnapCount uint32 + RegionCount uint32 + SendingSnapCount uint32 + StartTime uint32 + StoreId uint64 + UsedSize uint64 + func (*StoreStats) Descriptor() ([]byte, []int) + func (*StoreStats) ProtoMessage() + func (m *StoreStats) GetApplyingSnapCount() uint32 + func (m *StoreStats) GetAvailable() uint64 + func (m *StoreStats) GetBytesRead() uint64 + func (m *StoreStats) GetBytesWritten() uint64 + func (m *StoreStats) GetCapacity() uint64 + func (m *StoreStats) GetIsBusy() bool + func (m *StoreStats) GetKeysRead() uint64 + func (m *StoreStats) GetKeysWritten() 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) GetUsedSize() uint64 + func (m *StoreStats) Marshal() (dAtA []byte, err error) + func (m *StoreStats) MarshalTo(dAtA []byte) (int, error) + func (m *StoreStats) Reset() + func (m *StoreStats) Size() (n int) + func (m *StoreStats) String() string + func (m *StoreStats) Unmarshal(dAtA []byte) error + type Timestamp struct + Logical int64 + Physical int64 + func (*Timestamp) Descriptor() ([]byte, []int) + func (*Timestamp) ProtoMessage() + 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 (m *Timestamp) Reset() + func (m *Timestamp) Size() (n int) + func (m *Timestamp) String() string + func (m *Timestamp) Unmarshal(dAtA []byte) error + type TransferLeader struct + Peer *metapb.Peer + func (*TransferLeader) Descriptor() ([]byte, []int) + func (*TransferLeader) ProtoMessage() + func (m *TransferLeader) GetPeer() *metapb.Peer + func (m *TransferLeader) Marshal() (dAtA []byte, err error) + func (m *TransferLeader) MarshalTo(dAtA []byte) (int, error) + func (m *TransferLeader) Reset() + func (m *TransferLeader) Size() (n int) + func (m *TransferLeader) String() string + func (m *TransferLeader) Unmarshal(dAtA []byte) error + type TsoRequest struct + Count uint32 + Header *RequestHeader + func (*TsoRequest) Descriptor() ([]byte, []int) + func (*TsoRequest) ProtoMessage() + func (m *TsoRequest) GetCount() uint32 + func (m *TsoRequest) GetHeader() *RequestHeader + func (m *TsoRequest) Marshal() (dAtA []byte, err error) + func (m *TsoRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TsoRequest) Reset() + func (m *TsoRequest) Size() (n int) + func (m *TsoRequest) String() string + func (m *TsoRequest) Unmarshal(dAtA []byte) error + type TsoResponse struct + Count uint32 + Header *ResponseHeader + Timestamp *Timestamp + func (*TsoResponse) Descriptor() ([]byte, []int) + func (*TsoResponse) ProtoMessage() + func (m *TsoResponse) GetCount() uint32 + func (m *TsoResponse) GetHeader() *ResponseHeader + func (m *TsoResponse) GetTimestamp() *Timestamp + func (m *TsoResponse) Marshal() (dAtA []byte, err error) + func (m *TsoResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TsoResponse) Reset() + func (m *TsoResponse) Size() (n int) + func (m *TsoResponse) String() string + func (m *TsoResponse) Unmarshal(dAtA []byte) error