pdpb

package
v1.0.7 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package pdpb is a generated protocol buffer package.

It is generated from these files: 

pdpb.proto

It has these top-level messages: 

RequestHeader
ResponseHeader
Error
TsoRequest
Timestamp
TsoResponse
BootstrapRequest
BootstrapResponse
IsBootstrappedRequest
IsBootstrappedResponse
AllocIDRequest
AllocIDResponse
GetStoreRequest
GetStoreResponse
PutStoreRequest
PutStoreResponse
GetRegionRequest
GetRegionResponse
GetRegionByIDRequest
GetClusterConfigRequest
GetClusterConfigResponse
PutClusterConfigRequest
PutClusterConfigResponse
Member
GetMembersRequest
GetMembersResponse
PeerStats
RegionHeartbeatRequest
ChangePeer
TransferLeader
RegionHeartbeatResponse
AskSplitRequest
AskSplitResponse
ReportSplitRequest
ReportSplitResponse
StoreStats
StoreHeartbeatRequest
StoreHeartbeatResponse

Index

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 ConfChangeType_name = map[int32]string{
	0: "AddNode",
	1: "RemoveNode",
}
View Source 
var ConfChangeType_value = map[string]int32{
	"AddNode":    0,
	"RemoveNode": 1,
}
View Source 
var ErrorType_name = map[int32]string{
	0: "OK",
	1: "UNKNOWN",
	2: "NOT_BOOTSTRAPPED",
	3: "STORE_TOMBSTONE",
	4: "ALREADY_BOOTSTRAPPED",
}
View Source 
var ErrorType_value = map[string]int32{
	"OK":                   0,
	"UNKNOWN":              1,
	"NOT_BOOTSTRAPPED":     2,
	"STORE_TOMBSTONE":      3,
	"ALREADY_BOOTSTRAPPED": 4,
}

Functions

func RegisterPDServer 

func RegisterPDServer(s *grpc.Server, srv PDServer)

Types

type AllocIDRequest 

type AllocIDRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*AllocIDRequest) Descriptor 

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

func (*AllocIDRequest) GetHeader 

func (m *AllocIDRequest) GetHeader() *RequestHeader

func (*AllocIDRequest) Marshal 

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

func (*AllocIDRequest) MarshalTo 

func (m *AllocIDRequest) MarshalTo(dAtA []byte) (int, 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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Id     uint64          `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

func (*AllocIDResponse) Descriptor 

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

func (*AllocIDResponse) GetHeader 

func (m *AllocIDResponse) GetHeader() *ResponseHeader

func (*AllocIDResponse) GetId 

func (m *AllocIDResponse) GetId() uint64

func (*AllocIDResponse) Marshal 

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

func (*AllocIDResponse) MarshalTo 

func (m *AllocIDResponse) MarshalTo(dAtA []byte) (int, 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 {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Region *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
}

func (*AskSplitRequest) Descriptor 

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

func (*AskSplitRequest) GetHeader 

func (m *AskSplitRequest) GetHeader() *RequestHeader

func (*AskSplitRequest) GetRegion 

func (m *AskSplitRequest) GetRegion() *metapb.Region

func (*AskSplitRequest) Marshal 

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

func (*AskSplitRequest) MarshalTo 

func (m *AskSplitRequest) MarshalTo(dAtA []byte) (int, 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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// 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,2,opt,name=new_region_id,json=newRegionId,proto3" json:"new_region_id,omitempty"`
	// The peer ids for the new split region.
	NewPeerIds []uint64 `protobuf:"varint,3,rep,packed,name=new_peer_ids,json=newPeerIds" json:"new_peer_ids,omitempty"`
}

func (*AskSplitResponse) Descriptor 

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

func (*AskSplitResponse) GetHeader 

func (m *AskSplitResponse) GetHeader() *ResponseHeader

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

func (m *AskSplitResponse) MarshalTo(dAtA []byte) (int, 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 {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Store  *metapb.Store  `protobuf:"bytes,2,opt,name=store" json:"store,omitempty"`
	Region *metapb.Region `protobuf:"bytes,3,opt,name=region" json:"region,omitempty"`
}

func (*BootstrapRequest) Descriptor 

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

func (*BootstrapRequest) GetHeader 

func (m *BootstrapRequest) GetHeader() *RequestHeader

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

func (m *BootstrapRequest) MarshalTo(dAtA []byte) (int, 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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*BootstrapResponse) Descriptor 

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

func (*BootstrapResponse) GetHeader 

func (m *BootstrapResponse) GetHeader() *ResponseHeader

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 ChangePeer 

type ChangePeer struct {
	Peer *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
	// FIXME: replace with actual ConfChangeType once eraftpb uses proto3.
	ChangeType ConfChangeType `protobuf:"varint,2,opt,name=change_type,json=changeType,proto3,enum=pdpb.ConfChangeType" json:"change_type,omitempty"`
}

func (*ChangePeer) Descriptor 

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

func (*ChangePeer) GetChangeType 

func (m *ChangePeer) GetChangeType() ConfChangeType

func (*ChangePeer) GetPeer 

func (m *ChangePeer) GetPeer() *metapb.Peer

func (*ChangePeer) Marshal 

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

func (*ChangePeer) MarshalTo 

func (m *ChangePeer) MarshalTo(dAtA []byte) (int, 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 ConfChangeType 

type ConfChangeType int32

A clone of eraftpb.ConfChangeType, it exists because proto2 enums cannot be used directly in proto3 syntax. See more: https://developers.google.com/protocol-buffers/docs/proto3#using-proto2-message-types 

const (
	ConfChangeType_AddNode    ConfChangeType = 0
	ConfChangeType_RemoveNode ConfChangeType = 1
)

func (ConfChangeType) EnumDescriptor 

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

func (ConfChangeType) String 

func (x ConfChangeType) String() string

type Error 

type Error struct {
	Type    ErrorType `protobuf:"varint,1,opt,name=type,proto3,enum=pdpb.ErrorType" json:"type,omitempty"`
	Message string    `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*Error) Descriptor 

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

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetType 

func (m *Error) GetType() ErrorType

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

type ErrorType 

type ErrorType int32
const (
	ErrorType_OK                   ErrorType = 0
	ErrorType_UNKNOWN              ErrorType = 1
	ErrorType_NOT_BOOTSTRAPPED     ErrorType = 2
	ErrorType_STORE_TOMBSTONE      ErrorType = 3
	ErrorType_ALREADY_BOOTSTRAPPED ErrorType = 4
)

func (ErrorType) EnumDescriptor 

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

func (ErrorType) String 

func (x ErrorType) String() string

type GetClusterConfigRequest 

type GetClusterConfigRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*GetClusterConfigRequest) Descriptor 

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

func (*GetClusterConfigRequest) GetHeader 

func (m *GetClusterConfigRequest) GetHeader() *RequestHeader

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 {
	Header  *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Cluster *metapb.Cluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster,omitempty"`
}

func (*GetClusterConfigResponse) Descriptor 

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

func (*GetClusterConfigResponse) GetCluster 

func (m *GetClusterConfigResponse) GetCluster() *metapb.Cluster

func (*GetClusterConfigResponse) GetHeader 

func (m *GetClusterConfigResponse) GetHeader() *ResponseHeader

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 GetMembersRequest 

type GetMembersRequest struct {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*GetMembersRequest) Descriptor 

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

func (*GetMembersRequest) GetHeader 

func (m *GetMembersRequest) GetHeader() *RequestHeader

func (*GetMembersRequest) Marshal 

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

func (*GetMembersRequest) MarshalTo 

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

func (*GetMembersRequest) ProtoMessage 

func (*GetMembersRequest) ProtoMessage()

func (*GetMembersRequest) Reset 

func (m *GetMembersRequest) Reset()

func (*GetMembersRequest) Size 

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

func (*GetMembersRequest) String 

func (m *GetMembersRequest) String() string

func (*GetMembersRequest) Unmarshal 

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

type GetMembersResponse 

type GetMembersResponse struct {
	Header  *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Members []*Member       `protobuf:"bytes,2,rep,name=members" json:"members,omitempty"`
	Leader  *Member         `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"`
}

func (*GetMembersResponse) Descriptor 

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

func (*GetMembersResponse) GetHeader 

func (m *GetMembersResponse) GetHeader() *ResponseHeader

func (*GetMembersResponse) GetLeader 

func (m *GetMembersResponse) GetLeader() *Member

func (*GetMembersResponse) GetMembers 

func (m *GetMembersResponse) GetMembers() []*Member

func (*GetMembersResponse) Marshal 

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

func (*GetMembersResponse) MarshalTo 

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

func (*GetMembersResponse) ProtoMessage 

func (*GetMembersResponse) ProtoMessage()

func (*GetMembersResponse) Reset 

func (m *GetMembersResponse) Reset()

func (*GetMembersResponse) Size 

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

func (*GetMembersResponse) String 

func (m *GetMembersResponse) String() string

func (*GetMembersResponse) Unmarshal 

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

type GetRegionByIDRequest 

type GetRegionByIDRequest struct {
	Header   *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	RegionId uint64         `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
}

func (*GetRegionByIDRequest) Descriptor 

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

func (*GetRegionByIDRequest) GetHeader 

func (m *GetRegionByIDRequest) GetHeader() *RequestHeader

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 {
	Header    *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	RegionKey []byte         `protobuf:"bytes,2,opt,name=region_key,json=regionKey,proto3" json:"region_key,omitempty"`
}

func (*GetRegionRequest) Descriptor 

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

func (*GetRegionRequest) GetHeader 

func (m *GetRegionRequest) GetHeader() *RequestHeader

func (*GetRegionRequest) GetRegionKey 

func (m *GetRegionRequest) GetRegionKey() []byte

func (*GetRegionRequest) Marshal 

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

func (*GetRegionRequest) MarshalTo 

func (m *GetRegionRequest) MarshalTo(dAtA []byte) (int, 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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Region *metapb.Region  `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
	Leader *metapb.Peer    `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"`
}

func (*GetRegionResponse) Descriptor 

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

func (*GetRegionResponse) GetHeader 

func (m *GetRegionResponse) GetHeader() *ResponseHeader

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 {
	Header  *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	StoreId uint64         `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
}

func (*GetStoreRequest) Descriptor 

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

func (*GetStoreRequest) GetHeader 

func (m *GetStoreRequest) GetHeader() *RequestHeader

func (*GetStoreRequest) GetStoreId 

func (m *GetStoreRequest) GetStoreId() uint64

func (*GetStoreRequest) Marshal 

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

func (*GetStoreRequest) MarshalTo 

func (m *GetStoreRequest) MarshalTo(dAtA []byte) (int, 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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Store  *metapb.Store   `protobuf:"bytes,2,opt,name=store" json:"store,omitempty"`
}

func (*GetStoreResponse) Descriptor 

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

func (*GetStoreResponse) GetHeader 

func (m *GetStoreResponse) GetHeader() *ResponseHeader

func (*GetStoreResponse) GetStore 

func (m *GetStoreResponse) GetStore() *metapb.Store

func (*GetStoreResponse) Marshal 

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

func (*GetStoreResponse) MarshalTo 

func (m *GetStoreResponse) MarshalTo(dAtA []byte) (int, 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 {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*IsBootstrappedRequest) Descriptor 

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

func (*IsBootstrappedRequest) GetHeader 

func (m *IsBootstrappedRequest) GetHeader() *RequestHeader

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 {
	Header       *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Bootstrapped bool            `protobuf:"varint,2,opt,name=bootstrapped,proto3" json:"bootstrapped,omitempty"`
}

func (*IsBootstrappedResponse) Descriptor 

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

func (*IsBootstrappedResponse) GetBootstrapped 

func (m *IsBootstrappedResponse) GetBootstrapped() bool

func (*IsBootstrappedResponse) GetHeader 

func (m *IsBootstrappedResponse) GetHeader() *ResponseHeader

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 Member 

type Member struct {
	// name is the name of the PD member.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// member_id is the unique id of the PD member.
	MemberId   uint64   `protobuf:"varint,2,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	PeerUrls   []string `protobuf:"bytes,3,rep,name=peer_urls,json=peerUrls" json:"peer_urls,omitempty"`
	ClientUrls []string `protobuf:"bytes,4,rep,name=client_urls,json=clientUrls" json:"client_urls,omitempty"`
}

func (*Member) Descriptor 

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

func (*Member) GetClientUrls 

func (m *Member) GetClientUrls() []string

func (*Member) GetMemberId 

func (m *Member) GetMemberId() uint64

func (*Member) GetName 

func (m *Member) GetName() string

func (*Member) GetPeerUrls 

func (m *Member) GetPeerUrls() []string

func (*Member) Marshal 

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

func (*Member) MarshalTo 

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

func (*Member) ProtoMessage 

func (*Member) ProtoMessage()

func (*Member) Reset 

func (m *Member) Reset()

func (*Member) Size 

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

func (*Member) String 

func (m *Member) String() string

func (*Member) Unmarshal 

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

type PDClient 

type PDClient interface {
	// GetMembers get the member list of this cluster. It does not require
	// the cluster_id in request matchs the id of this cluster.
	GetMembers(ctx context.Context, in *GetMembersRequest, opts ...grpc.CallOption) (*GetMembersResponse, error)
	Tso(ctx context.Context, opts ...grpc.CallOption) (PD_TsoClient, error)
	Bootstrap(ctx context.Context, in *BootstrapRequest, opts ...grpc.CallOption) (*BootstrapResponse, error)
	IsBootstrapped(ctx context.Context, in *IsBootstrappedRequest, opts ...grpc.CallOption) (*IsBootstrappedResponse, error)
	AllocID(ctx context.Context, in *AllocIDRequest, opts ...grpc.CallOption) (*AllocIDResponse, error)
	GetStore(ctx context.Context, in *GetStoreRequest, opts ...grpc.CallOption) (*GetStoreResponse, error)
	PutStore(ctx context.Context, in *PutStoreRequest, opts ...grpc.CallOption) (*PutStoreResponse, error)
	StoreHeartbeat(ctx context.Context, in *StoreHeartbeatRequest, opts ...grpc.CallOption) (*StoreHeartbeatResponse, error)
	RegionHeartbeat(ctx context.Context, opts ...grpc.CallOption) (PD_RegionHeartbeatClient, error)
	GetRegion(ctx context.Context, in *GetRegionRequest, opts ...grpc.CallOption) (*GetRegionResponse, error)
	GetRegionByID(ctx context.Context, in *GetRegionByIDRequest, opts ...grpc.CallOption) (*GetRegionResponse, error)
	AskSplit(ctx context.Context, in *AskSplitRequest, opts ...grpc.CallOption) (*AskSplitResponse, error)
	ReportSplit(ctx context.Context, in *ReportSplitRequest, opts ...grpc.CallOption) (*ReportSplitResponse, error)
	GetClusterConfig(ctx context.Context, in *GetClusterConfigRequest, opts ...grpc.CallOption) (*GetClusterConfigResponse, error)
	PutClusterConfig(ctx context.Context, in *PutClusterConfigRequest, opts ...grpc.CallOption) (*PutClusterConfigResponse, error)
}

func NewPDClient 

func NewPDClient(cc *grpc.ClientConn) PDClient

type PDServer 

type PDServer interface {
	// GetMembers get the member list of this cluster. It does not require
	// the cluster_id in request matchs the id of this cluster.
	GetMembers(context.Context, *GetMembersRequest) (*GetMembersResponse, error)
	Tso(PD_TsoServer) error
	Bootstrap(context.Context, *BootstrapRequest) (*BootstrapResponse, error)
	IsBootstrapped(context.Context, *IsBootstrappedRequest) (*IsBootstrappedResponse, error)
	AllocID(context.Context, *AllocIDRequest) (*AllocIDResponse, error)
	GetStore(context.Context, *GetStoreRequest) (*GetStoreResponse, error)
	PutStore(context.Context, *PutStoreRequest) (*PutStoreResponse, error)
	StoreHeartbeat(context.Context, *StoreHeartbeatRequest) (*StoreHeartbeatResponse, error)
	RegionHeartbeat(PD_RegionHeartbeatServer) error
	GetRegion(context.Context, *GetRegionRequest) (*GetRegionResponse, error)
	GetRegionByID(context.Context, *GetRegionByIDRequest) (*GetRegionResponse, error)
	AskSplit(context.Context, *AskSplitRequest) (*AskSplitResponse, error)
	ReportSplit(context.Context, *ReportSplitRequest) (*ReportSplitResponse, error)
	GetClusterConfig(context.Context, *GetClusterConfigRequest) (*GetClusterConfigResponse, error)
	PutClusterConfig(context.Context, *PutClusterConfigRequest) (*PutClusterConfigResponse, error)
}

type PD_RegionHeartbeatClient 

type PD_RegionHeartbeatClient interface {
	Send(*RegionHeartbeatRequest) error
	Recv() (*RegionHeartbeatResponse, error)
	grpc.ClientStream
}

type PD_RegionHeartbeatServer 

type PD_RegionHeartbeatServer interface {
	Send(*RegionHeartbeatResponse) error
	Recv() (*RegionHeartbeatRequest, error)
	grpc.ServerStream
}

type PD_TsoClient 

type PD_TsoClient interface {
	Send(*TsoRequest) error
	Recv() (*TsoResponse, error)
	grpc.ClientStream
}

type PD_TsoServer 

type PD_TsoServer interface {
	Send(*TsoResponse) error
	Recv() (*TsoRequest, error)
	grpc.ServerStream
}

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,proto3" json:"down_seconds,omitempty"`
}

func (*PeerStats) Descriptor 

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

func (*PeerStats) GetDownSeconds 

func (m *PeerStats) GetDownSeconds() uint64

func (*PeerStats) GetPeer 

func (m *PeerStats) GetPeer() *metapb.Peer

func (*PeerStats) Marshal 

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

func (*PeerStats) MarshalTo 

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

func (*PeerStats) ProtoMessage 

func (*PeerStats) ProtoMessage()

func (*PeerStats) Reset 

func (m *PeerStats) Reset()

func (*PeerStats) Size 

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

func (*PeerStats) String 

func (m *PeerStats) String() string

func (*PeerStats) Unmarshal 

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

type PutClusterConfigRequest 

type PutClusterConfigRequest struct {
	Header  *RequestHeader  `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Cluster *metapb.Cluster `protobuf:"bytes,2,opt,name=cluster" json:"cluster,omitempty"`
}

func (*PutClusterConfigRequest) Descriptor 

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

func (*PutClusterConfigRequest) GetCluster 

func (m *PutClusterConfigRequest) GetCluster() *metapb.Cluster

func (*PutClusterConfigRequest) GetHeader 

func (m *PutClusterConfigRequest) GetHeader() *RequestHeader

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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*PutClusterConfigResponse) Descriptor 

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

func (*PutClusterConfigResponse) GetHeader 

func (m *PutClusterConfigResponse) GetHeader() *ResponseHeader

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 {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Store  *metapb.Store  `protobuf:"bytes,2,opt,name=store" json:"store,omitempty"`
}

func (*PutStoreRequest) Descriptor 

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

func (*PutStoreRequest) GetHeader 

func (m *PutStoreRequest) GetHeader() *RequestHeader

func (*PutStoreRequest) GetStore 

func (m *PutStoreRequest) GetStore() *metapb.Store

func (*PutStoreRequest) Marshal 

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

func (*PutStoreRequest) MarshalTo 

func (m *PutStoreRequest) MarshalTo(dAtA []byte) (int, 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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*PutStoreResponse) Descriptor 

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

func (*PutStoreResponse) GetHeader 

func (m *PutStoreResponse) GetHeader() *ResponseHeader

func (*PutStoreResponse) Marshal 

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

func (*PutStoreResponse) MarshalTo 

func (m *PutStoreResponse) MarshalTo(dAtA []byte) (int, 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 {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Region *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
	// Leader Peer sending the heartbeat.
	Leader *metapb.Peer `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"`
	// Leader considers that these peers are down.
	DownPeers []*PeerStats `protobuf:"bytes,4,rep,name=down_peers,json=downPeers" json:"down_peers,omitempty"`
	// Pending peers are the peers that the leader can't consider as
	// working followers.
	PendingPeers []*metapb.Peer `protobuf:"bytes,5,rep,name=pending_peers,json=pendingPeers" json:"pending_peers,omitempty"`
	// Bytes read/written during this period.
	BytesWritten uint64 `protobuf:"varint,6,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	BytesRead    uint64 `protobuf:"varint,7,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
	// Keys read/written during this period.
	KeysWritten uint64 `protobuf:"varint,8,opt,name=keys_written,json=keysWritten,proto3" json:"keys_written,omitempty"`
	KeysRead    uint64 `protobuf:"varint,9,opt,name=keys_read,json=keysRead,proto3" json:"keys_read,omitempty"`
	// Approximate region size.
	ApproximateSize uint64 `protobuf:"varint,10,opt,name=approximate_size,json=approximateSize,proto3" json:"approximate_size,omitempty"`
}

func (*RegionHeartbeatRequest) Descriptor 

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

func (*RegionHeartbeatRequest) GetApproximateSize 

func (m *RegionHeartbeatRequest) GetApproximateSize() uint64

func (*RegionHeartbeatRequest) GetBytesRead 

func (m *RegionHeartbeatRequest) GetBytesRead() uint64

func (*RegionHeartbeatRequest) GetBytesWritten 

func (m *RegionHeartbeatRequest) GetBytesWritten() uint64

func (*RegionHeartbeatRequest) GetDownPeers 

func (m *RegionHeartbeatRequest) GetDownPeers() []*PeerStats

func (*RegionHeartbeatRequest) GetHeader 

func (m *RegionHeartbeatRequest) GetHeader() *RequestHeader

func (*RegionHeartbeatRequest) GetKeysRead 

func (m *RegionHeartbeatRequest) GetKeysRead() uint64

func (*RegionHeartbeatRequest) GetKeysWritten 

func (m *RegionHeartbeatRequest) GetKeysWritten() uint64

func (*RegionHeartbeatRequest) GetLeader 

func (m *RegionHeartbeatRequest) GetLeader() *metapb.Peer

func (*RegionHeartbeatRequest) GetPendingPeers 

func (m *RegionHeartbeatRequest) GetPendingPeers() []*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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	// 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,2,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,3,opt,name=transfer_leader,json=transferLeader" json:"transfer_leader,omitempty"`
	// ID of the region
	RegionId    uint64              `protobuf:"varint,4,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,5,opt,name=region_epoch,json=regionEpoch" json:"region_epoch,omitempty"`
	// Leader of the region at the moment of the corresponding request was made.
	TargetPeer *metapb.Peer `protobuf:"bytes,6,opt,name=target_peer,json=targetPeer" json:"target_peer,omitempty"`
}

func (*RegionHeartbeatResponse) Descriptor 

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

func (*RegionHeartbeatResponse) GetChangePeer 

func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer

func (*RegionHeartbeatResponse) GetHeader 

func (m *RegionHeartbeatResponse) GetHeader() *ResponseHeader

func (*RegionHeartbeatResponse) GetRegionEpoch 

func (m *RegionHeartbeatResponse) GetRegionEpoch() *metapb.RegionEpoch

func (*RegionHeartbeatResponse) GetRegionId 

func (m *RegionHeartbeatResponse) GetRegionId() uint64

func (*RegionHeartbeatResponse) GetTargetPeer 

func (m *RegionHeartbeatResponse) GetTargetPeer() *metapb.Peer

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 {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Left   *metapb.Region `protobuf:"bytes,2,opt,name=left" json:"left,omitempty"`
	Right  *metapb.Region `protobuf:"bytes,3,opt,name=right" json:"right,omitempty"`
}

func (*ReportSplitRequest) Descriptor 

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

func (*ReportSplitRequest) GetHeader 

func (m *ReportSplitRequest) GetHeader() *RequestHeader

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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*ReportSplitResponse) Descriptor 

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

func (*ReportSplitResponse) GetHeader 

func (m *ReportSplitResponse) GetHeader() *ResponseHeader

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 RequestHeader 

type RequestHeader struct {
	// cluster_id is the ID of the cluster which be sent to.
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
}

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetClusterId 

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) Marshal 

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

func (*RequestHeader) MarshalTo 

func (m *RequestHeader) MarshalTo(dAtA []byte) (int, 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 ResponseHeader 

type ResponseHeader struct {
	// cluster_id is the ID of the cluster which sent the response.
	ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Error     *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

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

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

func (*ResponseHeader) MarshalTo 

func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, 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 {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Stats  *StoreStats    `protobuf:"bytes,2,opt,name=stats" json:"stats,omitempty"`
}

func (*StoreHeartbeatRequest) Descriptor 

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

func (*StoreHeartbeatRequest) GetHeader 

func (m *StoreHeartbeatRequest) GetHeader() *RequestHeader

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 {
	Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}

func (*StoreHeartbeatResponse) Descriptor 

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

func (*StoreHeartbeatResponse) GetHeader 

func (m *StoreHeartbeatResponse) GetHeader() *ResponseHeader

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 StoreStats 

type StoreStats struct {
	StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	// Capacity for the store.
	Capacity uint64 `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// Available size for the store.
	Available uint64 `protobuf:"varint,3,opt,name=available,proto3" json:"available,omitempty"`
	// Total region count in this store.
	RegionCount uint32 `protobuf:"varint,4,opt,name=region_count,json=regionCount,proto3" json:"region_count,omitempty"`
	// Current sending snapshot count.
	SendingSnapCount uint32 `protobuf:"varint,5,opt,name=sending_snap_count,json=sendingSnapCount,proto3" json:"sending_snap_count,omitempty"`
	// Current receiving snapshot count.
	ReceivingSnapCount uint32 `protobuf:"varint,6,opt,name=receiving_snap_count,json=receivingSnapCount,proto3" json:"receiving_snap_count,omitempty"`
	// When the store is started (unix timestamp in seconds).
	StartTime uint32 `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// How many region is applying snapshot.
	ApplyingSnapCount uint32 `protobuf:"varint,8,opt,name=applying_snap_count,json=applyingSnapCount,proto3" json:"applying_snap_count,omitempty"`
	// If the store is busy
	IsBusy bool `protobuf:"varint,9,opt,name=is_busy,json=isBusy,proto3" json:"is_busy,omitempty"`
	// Actually used space by db
	UsedSize uint64 `protobuf:"varint,10,opt,name=used_size,json=usedSize,proto3" json:"used_size,omitempty"`
	// Bytes written for the store.
	BytesWritten uint64 `protobuf:"varint,11,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	// Keys written for the store.
	KeysWritten uint64 `protobuf:"varint,12,opt,name=keys_written,json=keysWritten,proto3" json:"keys_written,omitempty"`
	// Bytes read for the store.
	BytesRead uint64 `protobuf:"varint,13,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
	// Keys read for the store.
	KeysRead uint64 `protobuf:"varint,14,opt,name=keys_read,json=keysRead,proto3" json:"keys_read,omitempty"`
}

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

func (m *StoreStats) GetBytesRead() uint64

func (*StoreStats) GetBytesWritten 

func (m *StoreStats) GetBytesWritten() uint64

func (*StoreStats) GetCapacity 

func (m *StoreStats) GetCapacity() uint64

func (*StoreStats) GetIsBusy 

func (m *StoreStats) GetIsBusy() bool

func (*StoreStats) GetKeysRead 

func (m *StoreStats) GetKeysRead() uint64

func (*StoreStats) GetKeysWritten 

func (m *StoreStats) GetKeysWritten() 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) GetUsedSize 

func (m *StoreStats) GetUsedSize() uint64

func (*StoreStats) Marshal 

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

func (*StoreStats) MarshalTo 

func (m *StoreStats) MarshalTo(dAtA []byte) (int, 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,proto3" json:"physical,omitempty"`
	Logical  int64 `protobuf:"varint,2,opt,name=logical,proto3" json:"logical,omitempty"`
}

func (*Timestamp) Descriptor 

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

func (*Timestamp) GetLogical 

func (m *Timestamp) GetLogical() int64

func (*Timestamp) GetPhysical 

func (m *Timestamp) GetPhysical() int64

func (*Timestamp) Marshal 

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

func (*Timestamp) MarshalTo 

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

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) Reset 

func (m *Timestamp) Reset()

func (*Timestamp) Size 

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

func (*Timestamp) String 

func (m *Timestamp) String() string

func (*Timestamp) Unmarshal 

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

type TransferLeader 

type TransferLeader struct {
	Peer *metapb.Peer `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
}

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

func (m *TransferLeader) MarshalTo(dAtA []byte) (int, 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 {
	Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Count  uint32         `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
}

func (*TsoRequest) Descriptor 

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

func (*TsoRequest) GetCount 

func (m *TsoRequest) GetCount() uint32

func (*TsoRequest) GetHeader 

func (m *TsoRequest) GetHeader() *RequestHeader

func (*TsoRequest) Marshal 

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

func (*TsoRequest) MarshalTo 

func (m *TsoRequest) MarshalTo(dAtA []byte) (int, 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 {
	Header    *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Count     uint32          `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Timestamp *Timestamp      `protobuf:"bytes,3,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*TsoResponse) Descriptor 

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

func (*TsoResponse) GetCount 

func (m *TsoResponse) GetCount() uint32

func (*TsoResponse) GetHeader 

func (m *TsoResponse) GetHeader() *ResponseHeader

func (*TsoResponse) GetTimestamp 

func (m *TsoResponse) GetTimestamp() *Timestamp

func (*TsoResponse) Marshal 

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

func (*TsoResponse) MarshalTo 

func (m *TsoResponse) MarshalTo(dAtA []byte) (int, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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