pdpb

package
Version: v1.1.0-alpha Latest Latest
Warning

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

Go to latest
Published: Oct 31, 2017 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 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL