Documentation

Index

Constants

This section is empty.

Variables

var (
	ErrInvalidLengthPdpb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPdpb   = fmt.Errorf("proto: integer overflow")
)

var CheckPolicy_name = map[int32]string{
	0: "SCAN",
	1: "APPROXIMATE",
	2: "USEKEY",
}

var CheckPolicy_value = map[string]int32{
	"SCAN":        0,
	"APPROXIMATE": 1,
	"USEKEY":      2,
}

var ErrorType_name = map[int32]string{
	0: "OK",
	1: "UNKNOWN",
	2: "NOT_BOOTSTRAPPED",
	3: "STORE_TOMBSTONE",
	4: "ALREADY_BOOTSTRAPPED",
	5: "INCOMPATIBLE_VERSION",
	6: "REGION_NOT_FOUND",
}

var ErrorType_value = map[string]int32{
	"OK":                   0,
	"UNKNOWN":              1,
	"NOT_BOOTSTRAPPED":     2,
	"STORE_TOMBSTONE":      3,
	"ALREADY_BOOTSTRAPPED": 4,
	"INCOMPATIBLE_VERSION": 5,
	"REGION_NOT_FOUND":     6,
}

var OperatorStatus_name = map[int32]string{
	0: "SUCCESS",
	1: "TIMEOUT",
	2: "CANCEL",
	3: "REPLACE",
	4: "RUNNING",
}

var OperatorStatus_value = map[string]int32{
	"SUCCESS": 0,
	"TIMEOUT": 1,
	"CANCEL":  2,
	"REPLACE": 3,
	"RUNNING": 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*AllocIDRequest) XXX_DiscardUnknown

func (m *AllocIDRequest) XXX_DiscardUnknown()

func (*AllocIDRequest) XXX_Marshal

func (m *AllocIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllocIDRequest) XXX_Merge

func (dst *AllocIDRequest) XXX_Merge(src proto.Message)

func (*AllocIDRequest) XXX_Size

func (m *AllocIDRequest) XXX_Size() int

func (*AllocIDRequest) XXX_Unmarshal

func (m *AllocIDRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*AllocIDResponse) XXX_DiscardUnknown

func (m *AllocIDResponse) XXX_DiscardUnknown()

func (*AllocIDResponse) XXX_Marshal

func (m *AllocIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AllocIDResponse) XXX_Merge

func (dst *AllocIDResponse) XXX_Merge(src proto.Message)

func (*AllocIDResponse) XXX_Size

func (m *AllocIDResponse) XXX_Size() int

func (*AllocIDResponse) XXX_Unmarshal

func (m *AllocIDResponse) XXX_Unmarshal(b []byte) error

type AskBatchSplitRequest

type AskBatchSplitRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Region               *metapb.Region `protobuf:"bytes,2,opt,name=region" json:"region,omitempty"`
	SplitCount           uint32         `protobuf:"varint,3,opt,name=split_count,json=splitCount,proto3" json:"split_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AskBatchSplitRequest) Descriptor

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

func (*AskBatchSplitRequest) GetHeader

func (m *AskBatchSplitRequest) GetHeader() *RequestHeader

func (*AskBatchSplitRequest) GetRegion

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

func (*AskBatchSplitRequest) GetSplitCount

func (m *AskBatchSplitRequest) GetSplitCount() uint32

func (*AskBatchSplitRequest) Marshal

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

func (*AskBatchSplitRequest) MarshalTo

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

func (*AskBatchSplitRequest) ProtoMessage

func (*AskBatchSplitRequest) ProtoMessage()

func (*AskBatchSplitRequest) Reset

func (m *AskBatchSplitRequest) Reset()

func (*AskBatchSplitRequest) Size

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

func (*AskBatchSplitRequest) String

func (m *AskBatchSplitRequest) String() string

func (*AskBatchSplitRequest) Unmarshal

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

func (*AskBatchSplitRequest) XXX_DiscardUnknown

func (m *AskBatchSplitRequest) XXX_DiscardUnknown()

func (*AskBatchSplitRequest) XXX_Marshal

func (m *AskBatchSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AskBatchSplitRequest) XXX_Merge

func (dst *AskBatchSplitRequest) XXX_Merge(src proto.Message)

func (*AskBatchSplitRequest) XXX_Size

func (m *AskBatchSplitRequest) XXX_Size() int

func (*AskBatchSplitRequest) XXX_Unmarshal

func (m *AskBatchSplitRequest) XXX_Unmarshal(b []byte) error

type AskBatchSplitResponse

type AskBatchSplitResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Ids                  []*SplitID      `protobuf:"bytes,2,rep,name=ids" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*AskBatchSplitResponse) Descriptor

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

func (*AskBatchSplitResponse) GetHeader

func (m *AskBatchSplitResponse) GetHeader() *ResponseHeader

func (*AskBatchSplitResponse) GetIds

func (m *AskBatchSplitResponse) GetIds() []*SplitID

func (*AskBatchSplitResponse) Marshal

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

func (*AskBatchSplitResponse) MarshalTo

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

func (*AskBatchSplitResponse) ProtoMessage

func (*AskBatchSplitResponse) ProtoMessage()

func (*AskBatchSplitResponse) Reset

func (m *AskBatchSplitResponse) Reset()

func (*AskBatchSplitResponse) Size

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

func (*AskBatchSplitResponse) String

func (m *AskBatchSplitResponse) String() string

func (*AskBatchSplitResponse) Unmarshal

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

func (*AskBatchSplitResponse) XXX_DiscardUnknown

func (m *AskBatchSplitResponse) XXX_DiscardUnknown()

func (*AskBatchSplitResponse) XXX_Marshal

func (m *AskBatchSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AskBatchSplitResponse) XXX_Merge

func (dst *AskBatchSplitResponse) XXX_Merge(src proto.Message)

func (*AskBatchSplitResponse) XXX_Size

func (m *AskBatchSplitResponse) XXX_Size() int

func (*AskBatchSplitResponse) XXX_Unmarshal

func (m *AskBatchSplitResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*AskSplitRequest) XXX_DiscardUnknown

func (m *AskSplitRequest) XXX_DiscardUnknown()

func (*AskSplitRequest) XXX_Marshal

func (m *AskSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AskSplitRequest) XXX_Merge

func (dst *AskSplitRequest) XXX_Merge(src proto.Message)

func (*AskSplitRequest) XXX_Size

func (m *AskSplitRequest) XXX_Size() int

func (*AskSplitRequest) XXX_Unmarshal

func (m *AskSplitRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*AskSplitResponse) XXX_DiscardUnknown

func (m *AskSplitResponse) XXX_DiscardUnknown()

func (*AskSplitResponse) XXX_Marshal

func (m *AskSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AskSplitResponse) XXX_Merge

func (dst *AskSplitResponse) XXX_Merge(src proto.Message)

func (*AskSplitResponse) XXX_Size

func (m *AskSplitResponse) XXX_Size() int

func (*AskSplitResponse) XXX_Unmarshal

func (m *AskSplitResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*BootstrapRequest) XXX_DiscardUnknown

func (m *BootstrapRequest) XXX_DiscardUnknown()

func (*BootstrapRequest) XXX_Marshal

func (m *BootstrapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BootstrapRequest) XXX_Merge

func (dst *BootstrapRequest) XXX_Merge(src proto.Message)

func (*BootstrapRequest) XXX_Size

func (m *BootstrapRequest) XXX_Size() int

func (*BootstrapRequest) XXX_Unmarshal

func (m *BootstrapRequest) XXX_Unmarshal(b []byte) error

type BootstrapResponse

type BootstrapResponse struct {
	Header               *ResponseHeader                       `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	ReplicationStatus    *replication_modepb.ReplicationStatus `protobuf:"bytes,2,opt,name=replication_status,json=replicationStatus" json:"replication_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*BootstrapResponse) Descriptor

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

func (*BootstrapResponse) GetHeader

func (m *BootstrapResponse) GetHeader() *ResponseHeader

func (*BootstrapResponse) GetReplicationStatus

func (m *BootstrapResponse) GetReplicationStatus() *replication_modepb.ReplicationStatus

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

func (*BootstrapResponse) XXX_DiscardUnknown

func (m *BootstrapResponse) XXX_DiscardUnknown()

func (*BootstrapResponse) XXX_Marshal

func (m *BootstrapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BootstrapResponse) XXX_Merge

func (dst *BootstrapResponse) XXX_Merge(src proto.Message)

func (*BootstrapResponse) XXX_Size

func (m *BootstrapResponse) XXX_Size() int

func (*BootstrapResponse) XXX_Unmarshal

func (m *BootstrapResponse) XXX_Unmarshal(b []byte) error

type ChangePeer

type ChangePeer struct {
	Peer                 *metapb.Peer           `protobuf:"bytes,1,opt,name=peer" json:"peer,omitempty"`
	ChangeType           eraftpb.ConfChangeType `protobuf:"varint,2,opt,name=change_type,json=changeType,proto3,enum=eraftpb.ConfChangeType" json:"change_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ChangePeer) Descriptor

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

func (*ChangePeer) GetChangeType

func (m *ChangePeer) GetChangeType() eraftpb.ConfChangeType

func (*ChangePeer) GetPeer

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

func (*ChangePeer) Marshal

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

func (*ChangePeer) 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

func (*ChangePeer) XXX_DiscardUnknown

func (m *ChangePeer) XXX_DiscardUnknown()

func (*ChangePeer) XXX_Marshal

func (m *ChangePeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangePeer) XXX_Merge

func (dst *ChangePeer) XXX_Merge(src proto.Message)

func (*ChangePeer) XXX_Size

func (m *ChangePeer) XXX_Size() int

func (*ChangePeer) XXX_Unmarshal

func (m *ChangePeer) XXX_Unmarshal(b []byte) error

type ChangePeerV2

type ChangePeerV2 struct {
	// If changes is empty, it means that to exit joint state.
	Changes              []*ChangePeer `protobuf:"bytes,1,rep,name=changes" json:"changes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ChangePeerV2) Descriptor

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

func (*ChangePeerV2) GetChanges

func (m *ChangePeerV2) GetChanges() []*ChangePeer

func (*ChangePeerV2) Marshal

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

func (*ChangePeerV2) MarshalTo

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

func (*ChangePeerV2) ProtoMessage

func (*ChangePeerV2) ProtoMessage()

func (*ChangePeerV2) Reset

func (m *ChangePeerV2) Reset()

func (*ChangePeerV2) Size

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

func (*ChangePeerV2) String

func (m *ChangePeerV2) String() string

func (*ChangePeerV2) Unmarshal

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

func (*ChangePeerV2) XXX_DiscardUnknown

func (m *ChangePeerV2) XXX_DiscardUnknown()

func (*ChangePeerV2) XXX_Marshal

func (m *ChangePeerV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangePeerV2) XXX_Merge

func (dst *ChangePeerV2) XXX_Merge(src proto.Message)

func (*ChangePeerV2) XXX_Size

func (m *ChangePeerV2) XXX_Size() int

func (*ChangePeerV2) XXX_Unmarshal

func (m *ChangePeerV2) XXX_Unmarshal(b []byte) error

type CheckPolicy

type CheckPolicy int32
const (
	CheckPolicy_SCAN        CheckPolicy = 0
	CheckPolicy_APPROXIMATE CheckPolicy = 1
	CheckPolicy_USEKEY      CheckPolicy = 2
)

func (CheckPolicy) EnumDescriptor

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

func (CheckPolicy) String

func (x CheckPolicy) 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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge

func (dst *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

func (m *Error) XXX_Unmarshal(b []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
	ErrorType_INCOMPATIBLE_VERSION ErrorType = 5
	ErrorType_REGION_NOT_FOUND     ErrorType = 6
)

func (ErrorType) EnumDescriptor

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

func (ErrorType) String

func (x ErrorType) String() string

type GetAllStoresRequest

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

	ExcludeTombstoneStores bool     "" /* 130 byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{} `json:"-"`
	XXX_unrecognized       []byte   `json:"-"`
	XXX_sizecache          int32    `json:"-"`
}

func (*GetAllStoresRequest) Descriptor

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

func (*GetAllStoresRequest) GetExcludeTombstoneStores

func (m *GetAllStoresRequest) GetExcludeTombstoneStores() bool

func (*GetAllStoresRequest) GetHeader

func (m *GetAllStoresRequest) GetHeader() *RequestHeader

func (*GetAllStoresRequest) Marshal

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

func (*GetAllStoresRequest) MarshalTo

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

func (*GetAllStoresRequest) ProtoMessage

func (*GetAllStoresRequest) ProtoMessage()

func (*GetAllStoresRequest) Reset

func (m *GetAllStoresRequest) Reset()

func (*GetAllStoresRequest) Size

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

func (*GetAllStoresRequest) String

func (m *GetAllStoresRequest) String() string

func (*GetAllStoresRequest) Unmarshal

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

func (*GetAllStoresRequest) XXX_DiscardUnknown

func (m *GetAllStoresRequest) XXX_DiscardUnknown()

func (*GetAllStoresRequest) XXX_Marshal

func (m *GetAllStoresRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllStoresRequest) XXX_Merge

func (dst *GetAllStoresRequest) XXX_Merge(src proto.Message)

func (*GetAllStoresRequest) XXX_Size

func (m *GetAllStoresRequest) XXX_Size() int

func (*GetAllStoresRequest) XXX_Unmarshal

func (m *GetAllStoresRequest) XXX_Unmarshal(b []byte) error

type GetAllStoresResponse

type GetAllStoresResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Stores               []*metapb.Store `protobuf:"bytes,2,rep,name=stores" json:"stores,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetAllStoresResponse) Descriptor

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

func (*GetAllStoresResponse) GetHeader

func (m *GetAllStoresResponse) GetHeader() *ResponseHeader

func (*GetAllStoresResponse) GetStores

func (m *GetAllStoresResponse) GetStores() []*metapb.Store

func (*GetAllStoresResponse) Marshal

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

func (*GetAllStoresResponse) MarshalTo

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

func (*GetAllStoresResponse) ProtoMessage

func (*GetAllStoresResponse) ProtoMessage()

func (*GetAllStoresResponse) Reset

func (m *GetAllStoresResponse) Reset()

func (*GetAllStoresResponse) Size

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

func (*GetAllStoresResponse) String

func (m *GetAllStoresResponse) String() string

func (*GetAllStoresResponse) Unmarshal

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

func (*GetAllStoresResponse) XXX_DiscardUnknown

func (m *GetAllStoresResponse) XXX_DiscardUnknown()

func (*GetAllStoresResponse) XXX_Marshal

func (m *GetAllStoresResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllStoresResponse) XXX_Merge

func (dst *GetAllStoresResponse) XXX_Merge(src proto.Message)

func (*GetAllStoresResponse) XXX_Size

func (m *GetAllStoresResponse) XXX_Size() int

func (*GetAllStoresResponse) XXX_Unmarshal

func (m *GetAllStoresResponse) XXX_Unmarshal(b []byte) error

type GetClusterConfigRequest

type GetClusterConfigRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*GetClusterConfigRequest) XXX_DiscardUnknown

func (m *GetClusterConfigRequest) XXX_DiscardUnknown()

func (*GetClusterConfigRequest) XXX_Marshal

func (m *GetClusterConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterConfigRequest) XXX_Merge

func (dst *GetClusterConfigRequest) XXX_Merge(src proto.Message)

func (*GetClusterConfigRequest) XXX_Size

func (m *GetClusterConfigRequest) XXX_Size() int

func (*GetClusterConfigRequest) XXX_Unmarshal

func (m *GetClusterConfigRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*GetClusterConfigResponse) XXX_DiscardUnknown

func (m *GetClusterConfigResponse) XXX_DiscardUnknown()

func (*GetClusterConfigResponse) XXX_Marshal

func (m *GetClusterConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetClusterConfigResponse) XXX_Merge

func (dst *GetClusterConfigResponse) XXX_Merge(src proto.Message)

func (*GetClusterConfigResponse) XXX_Size

func (m *GetClusterConfigResponse) XXX_Size() int

func (*GetClusterConfigResponse) XXX_Unmarshal

func (m *GetClusterConfigResponse) XXX_Unmarshal(b []byte) error

type GetDCLocationsRequest

type GetDCLocationsRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetDCLocationsRequest) Descriptor

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

func (*GetDCLocationsRequest) GetHeader

func (m *GetDCLocationsRequest) GetHeader() *RequestHeader

func (*GetDCLocationsRequest) Marshal

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

func (*GetDCLocationsRequest) MarshalTo

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

func (*GetDCLocationsRequest) ProtoMessage

func (*GetDCLocationsRequest) ProtoMessage()

func (*GetDCLocationsRequest) Reset

func (m *GetDCLocationsRequest) Reset()

func (*GetDCLocationsRequest) Size

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

func (*GetDCLocationsRequest) String

func (m *GetDCLocationsRequest) String() string

func (*GetDCLocationsRequest) Unmarshal

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

func (*GetDCLocationsRequest) XXX_DiscardUnknown

func (m *GetDCLocationsRequest) XXX_DiscardUnknown()

func (*GetDCLocationsRequest) XXX_Marshal

func (m *GetDCLocationsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDCLocationsRequest) XXX_Merge

func (dst *GetDCLocationsRequest) XXX_Merge(src proto.Message)

func (*GetDCLocationsRequest) XXX_Size

func (m *GetDCLocationsRequest) XXX_Size() int

func (*GetDCLocationsRequest) XXX_Unmarshal

func (m *GetDCLocationsRequest) XXX_Unmarshal(b []byte) error

type GetDCLocationsResponse

type GetDCLocationsResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	DcLocations          []string        `protobuf:"bytes,2,rep,name=dc_locations,json=dcLocations" json:"dc_locations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetDCLocationsResponse) Descriptor

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

func (*GetDCLocationsResponse) GetDcLocations

func (m *GetDCLocationsResponse) GetDcLocations() []string

func (*GetDCLocationsResponse) GetHeader

func (m *GetDCLocationsResponse) GetHeader() *ResponseHeader

func (*GetDCLocationsResponse) Marshal

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

func (*GetDCLocationsResponse) MarshalTo

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

func (*GetDCLocationsResponse) ProtoMessage

func (*GetDCLocationsResponse) ProtoMessage()

func (*GetDCLocationsResponse) Reset

func (m *GetDCLocationsResponse) Reset()

func (*GetDCLocationsResponse) Size

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

func (*GetDCLocationsResponse) String

func (m *GetDCLocationsResponse) String() string

func (*GetDCLocationsResponse) Unmarshal

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

func (*GetDCLocationsResponse) XXX_DiscardUnknown

func (m *GetDCLocationsResponse) XXX_DiscardUnknown()

func (*GetDCLocationsResponse) XXX_Marshal

func (m *GetDCLocationsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDCLocationsResponse) XXX_Merge

func (dst *GetDCLocationsResponse) XXX_Merge(src proto.Message)

func (*GetDCLocationsResponse) XXX_Size

func (m *GetDCLocationsResponse) XXX_Size() int

func (*GetDCLocationsResponse) XXX_Unmarshal

func (m *GetDCLocationsResponse) XXX_Unmarshal(b []byte) error

type GetGCSafePointRequest

type GetGCSafePointRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetGCSafePointRequest) Descriptor

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

func (*GetGCSafePointRequest) GetHeader

func (m *GetGCSafePointRequest) GetHeader() *RequestHeader

func (*GetGCSafePointRequest) Marshal

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

func (*GetGCSafePointRequest) MarshalTo

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

func (*GetGCSafePointRequest) ProtoMessage

func (*GetGCSafePointRequest) ProtoMessage()

func (*GetGCSafePointRequest) Reset

func (m *GetGCSafePointRequest) Reset()

func (*GetGCSafePointRequest) Size

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

func (*GetGCSafePointRequest) String

func (m *GetGCSafePointRequest) String() string

func (*GetGCSafePointRequest) Unmarshal

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

func (*GetGCSafePointRequest) XXX_DiscardUnknown

func (m *GetGCSafePointRequest) XXX_DiscardUnknown()

func (*GetGCSafePointRequest) XXX_Marshal

func (m *GetGCSafePointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetGCSafePointRequest) XXX_Merge

func (dst *GetGCSafePointRequest) XXX_Merge(src proto.Message)

func (*GetGCSafePointRequest) XXX_Size

func (m *GetGCSafePointRequest) XXX_Size() int

func (*GetGCSafePointRequest) XXX_Unmarshal

func (m *GetGCSafePointRequest) XXX_Unmarshal(b []byte) error

type GetGCSafePointResponse

type GetGCSafePointResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	SafePoint            uint64          `protobuf:"varint,2,opt,name=safe_point,json=safePoint,proto3" json:"safe_point,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetGCSafePointResponse) Descriptor

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

func (*GetGCSafePointResponse) GetHeader

func (m *GetGCSafePointResponse) GetHeader() *ResponseHeader

func (*GetGCSafePointResponse) GetSafePoint

func (m *GetGCSafePointResponse) GetSafePoint() uint64

func (*GetGCSafePointResponse) Marshal

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

func (*GetGCSafePointResponse) MarshalTo

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

func (*GetGCSafePointResponse) ProtoMessage

func (*GetGCSafePointResponse) ProtoMessage()

func (*GetGCSafePointResponse) Reset

func (m *GetGCSafePointResponse) Reset()

func (*GetGCSafePointResponse) Size

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

func (*GetGCSafePointResponse) String

func (m *GetGCSafePointResponse) String() string

func (*GetGCSafePointResponse) Unmarshal

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

func (*GetGCSafePointResponse) XXX_DiscardUnknown

func (m *GetGCSafePointResponse) XXX_DiscardUnknown()

func (*GetGCSafePointResponse) XXX_Marshal

func (m *GetGCSafePointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetGCSafePointResponse) XXX_Merge

func (dst *GetGCSafePointResponse) XXX_Merge(src proto.Message)

func (*GetGCSafePointResponse) XXX_Size

func (m *GetGCSafePointResponse) XXX_Size() int

func (*GetGCSafePointResponse) XXX_Unmarshal

func (m *GetGCSafePointResponse) XXX_Unmarshal(b []byte) error

type GetMembersRequest

type GetMembersRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*GetMembersRequest) XXX_DiscardUnknown

func (m *GetMembersRequest) XXX_DiscardUnknown()

func (*GetMembersRequest) XXX_Marshal

func (m *GetMembersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMembersRequest) XXX_Merge

func (dst *GetMembersRequest) XXX_Merge(src proto.Message)

func (*GetMembersRequest) XXX_Size

func (m *GetMembersRequest) XXX_Size() int

func (*GetMembersRequest) XXX_Unmarshal

func (m *GetMembersRequest) XXX_Unmarshal(b []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"`
	EtcdLeader           *Member            `protobuf:"bytes,4,opt,name=etcd_leader,json=etcdLeader" json:"etcd_leader,omitempty"`
	TsoAllocatorLeaders  map[string]*Member "" /* 194 byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*GetMembersResponse) Descriptor

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

func (*GetMembersResponse) GetEtcdLeader

func (m *GetMembersResponse) GetEtcdLeader() *Member

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

func (m *GetMembersResponse) GetTsoAllocatorLeaders() map[string]*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

func (*GetMembersResponse) XXX_DiscardUnknown

func (m *GetMembersResponse) XXX_DiscardUnknown()

func (*GetMembersResponse) XXX_Marshal

func (m *GetMembersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMembersResponse) XXX_Merge

func (dst *GetMembersResponse) XXX_Merge(src proto.Message)

func (*GetMembersResponse) XXX_Size

func (m *GetMembersResponse) XXX_Size() int

func (*GetMembersResponse) XXX_Unmarshal

func (m *GetMembersResponse) XXX_Unmarshal(b []byte) error

type GetOperatorRequest

type GetOperatorRequest 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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetOperatorRequest) Descriptor

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

func (*GetOperatorRequest) GetHeader

func (m *GetOperatorRequest) GetHeader() *RequestHeader

func (*GetOperatorRequest) GetRegionId

func (m *GetOperatorRequest) GetRegionId() uint64

func (*GetOperatorRequest) Marshal

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

func (*GetOperatorRequest) MarshalTo

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

func (*GetOperatorRequest) ProtoMessage

func (*GetOperatorRequest) ProtoMessage()

func (*GetOperatorRequest) Reset

func (m *GetOperatorRequest) Reset()

func (*GetOperatorRequest) Size

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

func (*GetOperatorRequest) String

func (m *GetOperatorRequest) String() string

func (*GetOperatorRequest) Unmarshal

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

func (*GetOperatorRequest) XXX_DiscardUnknown

func (m *GetOperatorRequest) XXX_DiscardUnknown()

func (*GetOperatorRequest) XXX_Marshal

func (m *GetOperatorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOperatorRequest) XXX_Merge

func (dst *GetOperatorRequest) XXX_Merge(src proto.Message)

func (*GetOperatorRequest) XXX_Size

func (m *GetOperatorRequest) XXX_Size() int

func (*GetOperatorRequest) XXX_Unmarshal

func (m *GetOperatorRequest) XXX_Unmarshal(b []byte) error

type GetOperatorResponse

type GetOperatorResponse struct {
	Header               *ResponseHeader `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"`
	Desc                 []byte          `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	Status               OperatorStatus  `protobuf:"varint,4,opt,name=status,proto3,enum=pdpb.OperatorStatus" json:"status,omitempty"`
	Kind                 []byte          `protobuf:"bytes,5,opt,name=kind,proto3" json:"kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetOperatorResponse) Descriptor

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

func (*GetOperatorResponse) GetDesc

func (m *GetOperatorResponse) GetDesc() []byte

func (*GetOperatorResponse) GetHeader

func (m *GetOperatorResponse) GetHeader() *ResponseHeader

func (*GetOperatorResponse) GetKind

func (m *GetOperatorResponse) GetKind() []byte

func (*GetOperatorResponse) GetRegionId

func (m *GetOperatorResponse) GetRegionId() uint64

func (*GetOperatorResponse) GetStatus

func (m *GetOperatorResponse) GetStatus() OperatorStatus

func (*GetOperatorResponse) Marshal

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

func (*GetOperatorResponse) MarshalTo

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

func (*GetOperatorResponse) ProtoMessage

func (*GetOperatorResponse) ProtoMessage()

func (*GetOperatorResponse) Reset

func (m *GetOperatorResponse) Reset()

func (*GetOperatorResponse) Size

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

func (*GetOperatorResponse) String

func (m *GetOperatorResponse) String() string

func (*GetOperatorResponse) Unmarshal

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

func (*GetOperatorResponse) XXX_DiscardUnknown

func (m *GetOperatorResponse) XXX_DiscardUnknown()

func (*GetOperatorResponse) XXX_Marshal

func (m *GetOperatorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetOperatorResponse) XXX_Merge

func (dst *GetOperatorResponse) XXX_Merge(src proto.Message)

func (*GetOperatorResponse) XXX_Size

func (m *GetOperatorResponse) XXX_Size() int

func (*GetOperatorResponse) XXX_Unmarshal

func (m *GetOperatorResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*GetRegionByIDRequest) XXX_DiscardUnknown

func (m *GetRegionByIDRequest) XXX_DiscardUnknown()

func (*GetRegionByIDRequest) XXX_Marshal

func (m *GetRegionByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRegionByIDRequest) XXX_Merge

func (dst *GetRegionByIDRequest) XXX_Merge(src proto.Message)

func (*GetRegionByIDRequest) XXX_Size

func (m *GetRegionByIDRequest) XXX_Size() int

func (*GetRegionByIDRequest) XXX_Unmarshal

func (m *GetRegionByIDRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*GetRegionRequest) XXX_DiscardUnknown

func (m *GetRegionRequest) XXX_DiscardUnknown()

func (*GetRegionRequest) XXX_Marshal

func (m *GetRegionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRegionRequest) XXX_Merge

func (dst *GetRegionRequest) XXX_Merge(src proto.Message)

func (*GetRegionRequest) XXX_Size

func (m *GetRegionRequest) XXX_Size() int

func (*GetRegionRequest) XXX_Unmarshal

func (m *GetRegionRequest) XXX_Unmarshal(b []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"`
	// Leader considers that these peers are down.
	DownPeers []*PeerStats `protobuf:"bytes,5,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,6,rep,name=pending_peers,json=pendingPeers" json:"pending_peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetRegionResponse) Descriptor

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

func (*GetRegionResponse) GetDownPeers

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

func (*GetRegionResponse) GetHeader

func (m *GetRegionResponse) GetHeader() *ResponseHeader

func (*GetRegionResponse) GetLeader

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

func (*GetRegionResponse) GetPendingPeers

func (m *GetRegionResponse) GetPendingPeers() []*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

func (*GetRegionResponse) XXX_DiscardUnknown

func (m *GetRegionResponse) XXX_DiscardUnknown()

func (*GetRegionResponse) XXX_Marshal

func (m *GetRegionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRegionResponse) XXX_Merge

func (dst *GetRegionResponse) XXX_Merge(src proto.Message)

func (*GetRegionResponse) XXX_Size

func (m *GetRegionResponse) XXX_Size() int

func (*GetRegionResponse) XXX_Unmarshal

func (m *GetRegionResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*GetStoreRequest) XXX_DiscardUnknown

func (m *GetStoreRequest) XXX_DiscardUnknown()

func (*GetStoreRequest) XXX_Marshal

func (m *GetStoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStoreRequest) XXX_Merge

func (dst *GetStoreRequest) XXX_Merge(src proto.Message)

func (*GetStoreRequest) XXX_Size

func (m *GetStoreRequest) XXX_Size() int

func (*GetStoreRequest) XXX_Unmarshal

func (m *GetStoreRequest) XXX_Unmarshal(b []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"`
	Stats                *StoreStats     `protobuf:"bytes,3,opt,name=stats" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetStoreResponse) Descriptor

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

func (*GetStoreResponse) GetHeader

func (m *GetStoreResponse) GetHeader() *ResponseHeader

func (*GetStoreResponse) GetStats

func (m *GetStoreResponse) GetStats() *StoreStats

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

func (*GetStoreResponse) XXX_DiscardUnknown

func (m *GetStoreResponse) XXX_DiscardUnknown()

func (*GetStoreResponse) XXX_Marshal

func (m *GetStoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStoreResponse) XXX_Merge

func (dst *GetStoreResponse) XXX_Merge(src proto.Message)

func (*GetStoreResponse) XXX_Size

func (m *GetStoreResponse) XXX_Size() int

func (*GetStoreResponse) XXX_Unmarshal

func (m *GetStoreResponse) XXX_Unmarshal(b []byte) error

type IsBootstrappedRequest

type IsBootstrappedRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*IsBootstrappedRequest) XXX_DiscardUnknown

func (m *IsBootstrappedRequest) XXX_DiscardUnknown()

func (*IsBootstrappedRequest) XXX_Marshal

func (m *IsBootstrappedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IsBootstrappedRequest) XXX_Merge

func (dst *IsBootstrappedRequest) XXX_Merge(src proto.Message)

func (*IsBootstrappedRequest) XXX_Size

func (m *IsBootstrappedRequest) XXX_Size() int

func (*IsBootstrappedRequest) XXX_Unmarshal

func (m *IsBootstrappedRequest) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*IsBootstrappedResponse) XXX_DiscardUnknown

func (m *IsBootstrappedResponse) XXX_DiscardUnknown()

func (*IsBootstrappedResponse) XXX_Marshal

func (m *IsBootstrappedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IsBootstrappedResponse) XXX_Merge

func (dst *IsBootstrappedResponse) XXX_Merge(src proto.Message)

func (*IsBootstrappedResponse) XXX_Size

func (m *IsBootstrappedResponse) XXX_Size() int

func (*IsBootstrappedResponse) XXX_Unmarshal

func (m *IsBootstrappedResponse) XXX_Unmarshal(b []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"`
	LeaderPriority       int32    `protobuf:"varint,5,opt,name=leader_priority,json=leaderPriority,proto3" json:"leader_priority,omitempty"`
	DeployPath           string   `protobuf:"bytes,6,opt,name=deploy_path,json=deployPath,proto3" json:"deploy_path,omitempty"`
	BinaryVersion        string   `protobuf:"bytes,7,opt,name=binary_version,json=binaryVersion,proto3" json:"binary_version,omitempty"`
	GitHash              string   `protobuf:"bytes,8,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Member) Descriptor

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

func (*Member) GetBinaryVersion

func (m *Member) GetBinaryVersion() string

func (*Member) GetClientUrls

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

func (*Member) GetDeployPath

func (m *Member) GetDeployPath() string

func (*Member) GetGitHash

func (m *Member) GetGitHash() string

func (*Member) GetLeaderPriority

func (m *Member) GetLeaderPriority() int32

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

func (*Member) XXX_DiscardUnknown

func (m *Member) XXX_DiscardUnknown()

func (*Member) XXX_Marshal

func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Member) XXX_Merge

func (dst *Member) XXX_Merge(src proto.Message)

func (*Member) XXX_Size

func (m *Member) XXX_Size() int

func (*Member) XXX_Unmarshal

func (m *Member) XXX_Unmarshal(b []byte) error

type Merge

type Merge struct {
	Target               *metapb.Region `protobuf:"bytes,1,opt,name=target" json:"target,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Merge) Descriptor

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

func (*Merge) GetTarget

func (m *Merge) GetTarget() *metapb.Region

func (*Merge) Marshal

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

func (*Merge) MarshalTo

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

func (*Merge) ProtoMessage

func (*Merge) ProtoMessage()

func (*Merge) Reset

func (m *Merge) Reset()

func (*Merge) Size

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

func (*Merge) String

func (m *Merge) String() string

func (*Merge) Unmarshal

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

func (*Merge) XXX_DiscardUnknown

func (m *Merge) XXX_DiscardUnknown()

func (*Merge) XXX_Marshal

func (m *Merge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Merge) XXX_Merge

func (dst *Merge) XXX_Merge(src proto.Message)

func (*Merge) XXX_Size

func (m *Merge) XXX_Size() int

func (*Merge) XXX_Unmarshal

func (m *Merge) XXX_Unmarshal(b []byte) error

type OperatorStatus

type OperatorStatus int32
const (
	OperatorStatus_SUCCESS OperatorStatus = 0
	OperatorStatus_TIMEOUT OperatorStatus = 1
	OperatorStatus_CANCEL  OperatorStatus = 2
	OperatorStatus_REPLACE OperatorStatus = 3
	OperatorStatus_RUNNING OperatorStatus = 4
)

func (OperatorStatus) EnumDescriptor

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

func (OperatorStatus) String

func (x OperatorStatus) String() string

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)
	GetAllStores(ctx context.Context, in *GetAllStoresRequest, opts ...grpc.CallOption) (*GetAllStoresResponse, 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)
	GetPrevRegion(ctx context.Context, in *GetRegionRequest, opts ...grpc.CallOption) (*GetRegionResponse, error)
	GetRegionByID(ctx context.Context, in *GetRegionByIDRequest, opts ...grpc.CallOption) (*GetRegionResponse, error)
	ScanRegions(ctx context.Context, in *ScanRegionsRequest, opts ...grpc.CallOption) (*ScanRegionsResponse, error)
	AskSplit(ctx context.Context, in *AskSplitRequest, opts ...grpc.CallOption) (*AskSplitResponse, error)
	ReportSplit(ctx context.Context, in *ReportSplitRequest, opts ...grpc.CallOption) (*ReportSplitResponse, error)
	AskBatchSplit(ctx context.Context, in *AskBatchSplitRequest, opts ...grpc.CallOption) (*AskBatchSplitResponse, error)
	ReportBatchSplit(ctx context.Context, in *ReportBatchSplitRequest, opts ...grpc.CallOption) (*ReportBatchSplitResponse, error)
	GetClusterConfig(ctx context.Context, in *GetClusterConfigRequest, opts ...grpc.CallOption) (*GetClusterConfigResponse, error)
	PutClusterConfig(ctx context.Context, in *PutClusterConfigRequest, opts ...grpc.CallOption) (*PutClusterConfigResponse, error)
	ScatterRegion(ctx context.Context, in *ScatterRegionRequest, opts ...grpc.CallOption) (*ScatterRegionResponse, error)
	GetGCSafePoint(ctx context.Context, in *GetGCSafePointRequest, opts ...grpc.CallOption) (*GetGCSafePointResponse, error)
	UpdateGCSafePoint(ctx context.Context, in *UpdateGCSafePointRequest, opts ...grpc.CallOption) (*UpdateGCSafePointResponse, error)
	UpdateServiceGCSafePoint(ctx context.Context, in *UpdateServiceGCSafePointRequest, opts ...grpc.CallOption) (*UpdateServiceGCSafePointResponse, error)
	SyncRegions(ctx context.Context, opts ...grpc.CallOption) (PD_SyncRegionsClient, error)
	GetOperator(ctx context.Context, in *GetOperatorRequest, opts ...grpc.CallOption) (*GetOperatorResponse, error)
	SyncMaxTS(ctx context.Context, in *SyncMaxTSRequest, opts ...grpc.CallOption) (*SyncMaxTSResponse, error)
	SplitRegions(ctx context.Context, in *SplitRegionsRequest, opts ...grpc.CallOption) (*SplitRegionsResponse, error)
	GetDCLocations(ctx context.Context, in *GetDCLocationsRequest, opts ...grpc.CallOption) (*GetDCLocationsResponse, 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)
	GetAllStores(context.Context, *GetAllStoresRequest) (*GetAllStoresResponse, error)
	StoreHeartbeat(context.Context, *StoreHeartbeatRequest) (*StoreHeartbeatResponse, error)
	RegionHeartbeat(PD_RegionHeartbeatServer) error
	GetRegion(context.Context, *GetRegionRequest) (*GetRegionResponse, error)
	GetPrevRegion(context.Context, *GetRegionRequest) (*GetRegionResponse, error)
	GetRegionByID(context.Context, *GetRegionByIDRequest) (*GetRegionResponse, error)
	ScanRegions(context.Context, *ScanRegionsRequest) (*ScanRegionsResponse, error)
	AskSplit(context.Context, *AskSplitRequest) (*AskSplitResponse, error)
	ReportSplit(context.Context, *ReportSplitRequest) (*ReportSplitResponse, error)
	AskBatchSplit(context.Context, *AskBatchSplitRequest) (*AskBatchSplitResponse, error)
	ReportBatchSplit(context.Context, *ReportBatchSplitRequest) (*ReportBatchSplitResponse, error)
	GetClusterConfig(context.Context, *GetClusterConfigRequest) (*GetClusterConfigResponse, error)
	PutClusterConfig(context.Context, *PutClusterConfigRequest) (*PutClusterConfigResponse, error)
	ScatterRegion(context.Context, *ScatterRegionRequest) (*ScatterRegionResponse, error)
	GetGCSafePoint(context.Context, *GetGCSafePointRequest) (*GetGCSafePointResponse, error)
	UpdateGCSafePoint(context.Context, *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error)
	UpdateServiceGCSafePoint(context.Context, *UpdateServiceGCSafePointRequest) (*UpdateServiceGCSafePointResponse, error)
	SyncRegions(PD_SyncRegionsServer) error
	GetOperator(context.Context, *GetOperatorRequest) (*GetOperatorResponse, error)
	SyncMaxTS(context.Context, *SyncMaxTSRequest) (*SyncMaxTSResponse, error)
	SplitRegions(context.Context, *SplitRegionsRequest) (*SplitRegionsResponse, error)
	GetDCLocations(context.Context, *GetDCLocationsRequest) (*GetDCLocationsResponse, 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_SyncRegionsClient

type PD_SyncRegionsClient interface {
	Send(*SyncRegionRequest) error
	Recv() (*SyncRegionResponse, error)
	grpc.ClientStream
}

type PD_SyncRegionsServer

type PD_SyncRegionsServer interface {
	Send(*SyncRegionResponse) error
	Recv() (*SyncRegionRequest, 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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

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

func (*PeerStats) XXX_DiscardUnknown

func (m *PeerStats) XXX_DiscardUnknown()

func (*PeerStats) XXX_Marshal

func (m *PeerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerStats) XXX_Merge

func (dst *PeerStats) XXX_Merge(src proto.Message)

func (*PeerStats) XXX_Size

func (m *PeerStats) XXX_Size() int

func (*PeerStats) XXX_Unmarshal

func (m *PeerStats) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*PutClusterConfigRequest) XXX_DiscardUnknown

func (m *PutClusterConfigRequest) XXX_DiscardUnknown()

func (*PutClusterConfigRequest) XXX_Marshal

func (m *PutClusterConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutClusterConfigRequest) XXX_Merge

func (dst *PutClusterConfigRequest) XXX_Merge(src proto.Message)

func (*PutClusterConfigRequest) XXX_Size

func (m *PutClusterConfigRequest) XXX_Size() int

func (*PutClusterConfigRequest) XXX_Unmarshal

func (m *PutClusterConfigRequest) XXX_Unmarshal(b []byte) error

type PutClusterConfigResponse

type PutClusterConfigResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*PutClusterConfigResponse) XXX_DiscardUnknown

func (m *PutClusterConfigResponse) XXX_DiscardUnknown()

func (*PutClusterConfigResponse) XXX_Marshal

func (m *PutClusterConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutClusterConfigResponse) XXX_Merge

func (dst *PutClusterConfigResponse) XXX_Merge(src proto.Message)

func (*PutClusterConfigResponse) XXX_Size

func (m *PutClusterConfigResponse) XXX_Size() int

func (*PutClusterConfigResponse) XXX_Unmarshal

func (m *PutClusterConfigResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*PutStoreRequest) XXX_DiscardUnknown

func (m *PutStoreRequest) XXX_DiscardUnknown()

func (*PutStoreRequest) XXX_Marshal

func (m *PutStoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutStoreRequest) XXX_Merge

func (dst *PutStoreRequest) XXX_Merge(src proto.Message)

func (*PutStoreRequest) XXX_Size

func (m *PutStoreRequest) XXX_Size() int

func (*PutStoreRequest) XXX_Unmarshal

func (m *PutStoreRequest) XXX_Unmarshal(b []byte) error

type PutStoreResponse

type PutStoreResponse struct {
	Header               *ResponseHeader                       `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	ReplicationStatus    *replication_modepb.ReplicationStatus `protobuf:"bytes,2,opt,name=replication_status,json=replicationStatus" json:"replication_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

func (*PutStoreResponse) Descriptor

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

func (*PutStoreResponse) GetHeader

func (m *PutStoreResponse) GetHeader() *ResponseHeader

func (*PutStoreResponse) GetReplicationStatus

func (m *PutStoreResponse) GetReplicationStatus() *replication_modepb.ReplicationStatus

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

func (*PutStoreResponse) XXX_DiscardUnknown

func (m *PutStoreResponse) XXX_DiscardUnknown()

func (*PutStoreResponse) XXX_Marshal

func (m *PutStoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PutStoreResponse) XXX_Merge

func (dst *PutStoreResponse) XXX_Merge(src proto.Message)

func (*PutStoreResponse) XXX_Size

func (m *PutStoreResponse) XXX_Size() int

func (*PutStoreResponse) XXX_Unmarshal

func (m *PutStoreResponse) XXX_Unmarshal(b []byte) error

type RecordPair

type RecordPair struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                uint64   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecordPair) Descriptor

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

func (*RecordPair) GetKey

func (m *RecordPair) GetKey() string

func (*RecordPair) GetValue

func (m *RecordPair) GetValue() uint64

func (*RecordPair) Marshal

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

func (*RecordPair) MarshalTo

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

func (*RecordPair) ProtoMessage

func (*RecordPair) ProtoMessage()

func (*RecordPair) Reset

func (m *RecordPair) Reset()

func (*RecordPair) Size

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

func (*RecordPair) String

func (m *RecordPair) String() string

func (*RecordPair) Unmarshal

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

func (*RecordPair) XXX_DiscardUnknown

func (m *RecordPair) XXX_DiscardUnknown()

func (*RecordPair) XXX_Marshal

func (m *RecordPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordPair) XXX_Merge

func (dst *RecordPair) XXX_Merge(src proto.Message)

func (*RecordPair) XXX_Size

func (m *RecordPair) XXX_Size() int

func (*RecordPair) XXX_Unmarshal

func (m *RecordPair) XXX_Unmarshal(b []byte) error

type Region

type Region struct {
	Region *metapb.Region `protobuf:"bytes,1,opt,name=region" json:"region,omitempty"`
	Leader *metapb.Peer   `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
	// Leader considers that these peers are down.
	DownPeers []*PeerStats `protobuf:"bytes,3,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,4,rep,name=pending_peers,json=pendingPeers" json:"pending_peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Region) Descriptor

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

func (*Region) GetDownPeers

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

func (*Region) GetLeader

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

func (*Region) GetPendingPeers

func (m *Region) GetPendingPeers() []*metapb.Peer

func (*Region) GetRegion

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

func (*Region) Marshal

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

func (*Region) MarshalTo

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

func (*Region) ProtoMessage

func (*Region) ProtoMessage()

func (*Region) Reset

func (m *Region) Reset()

func (*Region) Size

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

func (*Region) String

func (m *Region) String() string

func (*Region) Unmarshal

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

func (*Region) XXX_DiscardUnknown

func (m *Region) XXX_DiscardUnknown()

func (*Region) XXX_Marshal

func (m *Region) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Region) XXX_Merge

func (dst *Region) XXX_Merge(src proto.Message)

func (*Region) XXX_Size

func (m *Region) XXX_Size() int

func (*Region) XXX_Unmarshal

func (m *Region) XXX_Unmarshal(b []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"`
	// Actually reported time interval
	Interval *TimeInterval `protobuf:"bytes,12,opt,name=interval" json:"interval,omitempty"`
	// Approximate number of keys.
	ApproximateKeys uint64 `protobuf:"varint,13,opt,name=approximate_keys,json=approximateKeys,proto3" json:"approximate_keys,omitempty"`
	// Term is the term of raft group.
	Term                 uint64                                      `protobuf:"varint,14,opt,name=term,proto3" json:"term,omitempty"`
	ReplicationStatus    *replication_modepb.RegionReplicationStatus `protobuf:"bytes,15,opt,name=replication_status,json=replicationStatus" json:"replication_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*RegionHeartbeatRequest) Descriptor

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

func (*RegionHeartbeatRequest) GetApproximateKeys

func (m *RegionHeartbeatRequest) GetApproximateKeys() uint64

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

func (m *RegionHeartbeatRequest) GetInterval() *TimeInterval

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

func (m *RegionHeartbeatRequest) GetReplicationStatus() *replication_modepb.RegionReplicationStatus

func (*RegionHeartbeatRequest) GetTerm

func (m *RegionHeartbeatRequest) GetTerm() uint64

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

func (*RegionHeartbeatRequest) XXX_DiscardUnknown

func (m *RegionHeartbeatRequest) XXX_DiscardUnknown()

func (*RegionHeartbeatRequest) XXX_Marshal

func (m *RegionHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionHeartbeatRequest) XXX_Merge

func (dst *RegionHeartbeatRequest) XXX_Merge(src proto.Message)

func (*RegionHeartbeatRequest) XXX_Size

func (m *RegionHeartbeatRequest) XXX_Size() int

func (*RegionHeartbeatRequest) XXX_Unmarshal

func (m *RegionHeartbeatRequest) XXX_Unmarshal(b []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"`
	Merge      *Merge       `protobuf:"bytes,7,opt,name=merge" json:"merge,omitempty"`
	// PD sends split_region to let TiKV split a region into two regions.
	SplitRegion *SplitRegion `protobuf:"bytes,8,opt,name=split_region,json=splitRegion" json:"split_region,omitempty"`
	// Multiple change peer operations atomically.
	// Note: PD can use both ChangePeer and ChangePeerV2 at the same time
	//       (not in the same RegionHeartbeatResponse).
	//       Now, PD use ChangePeerV2 only for replacing peers.
	ChangePeerV2         *ChangePeerV2 `protobuf:"bytes,9,opt,name=change_peer_v2,json=changePeerV2" json:"change_peer_v2,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RegionHeartbeatResponse) Descriptor

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

func (*RegionHeartbeatResponse) GetChangePeer

func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer

func (*RegionHeartbeatResponse) GetChangePeerV2

func (m *RegionHeartbeatResponse) GetChangePeerV2() *ChangePeerV2

func (*RegionHeartbeatResponse) GetHeader

func (m *RegionHeartbeatResponse) GetHeader() *ResponseHeader

func (*RegionHeartbeatResponse) GetMerge

func (m *RegionHeartbeatResponse) GetMerge() *Merge

func (*RegionHeartbeatResponse) GetRegionEpoch

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

func (*RegionHeartbeatResponse) GetRegionId

func (m *RegionHeartbeatResponse) GetRegionId() uint64

func (*RegionHeartbeatResponse) GetSplitRegion

func (m *RegionHeartbeatResponse) GetSplitRegion() *SplitRegion

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

func (*RegionHeartbeatResponse) XXX_DiscardUnknown

func (m *RegionHeartbeatResponse) XXX_DiscardUnknown()

func (*RegionHeartbeatResponse) XXX_Marshal

func (m *RegionHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionHeartbeatResponse) XXX_Merge

func (dst *RegionHeartbeatResponse) XXX_Merge(src proto.Message)

func (*RegionHeartbeatResponse) XXX_Size

func (m *RegionHeartbeatResponse) XXX_Size() int

func (*RegionHeartbeatResponse) XXX_Unmarshal

func (m *RegionHeartbeatResponse) XXX_Unmarshal(b []byte) error

type RegionStat

type RegionStat struct {
	// Bytes read/written during this period.
	BytesWritten uint64 `protobuf:"varint,1,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
	BytesRead    uint64 `protobuf:"varint,2,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
	// Keys read/written during this period.
	KeysWritten          uint64   `protobuf:"varint,3,opt,name=keys_written,json=keysWritten,proto3" json:"keys_written,omitempty"`
	KeysRead             uint64   `protobuf:"varint,4,opt,name=keys_read,json=keysRead,proto3" json:"keys_read,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegionStat) Descriptor

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

func (*RegionStat) GetBytesRead

func (m *RegionStat) GetBytesRead() uint64

func (*RegionStat) GetBytesWritten

func (m *RegionStat) GetBytesWritten() uint64

func (*RegionStat) GetKeysRead

func (m *RegionStat) GetKeysRead() uint64

func (*RegionStat) GetKeysWritten

func (m *RegionStat) GetKeysWritten() uint64

func (*RegionStat) Marshal

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

func (*RegionStat) MarshalTo

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

func (*RegionStat) ProtoMessage

func (*RegionStat) ProtoMessage()

func (*RegionStat) Reset

func (m *RegionStat) Reset()

func (*RegionStat) Size

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

func (*RegionStat) String

func (m *RegionStat) String() string

func (*RegionStat) Unmarshal

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

func (*RegionStat) XXX_DiscardUnknown

func (m *RegionStat) XXX_DiscardUnknown()

func (*RegionStat) XXX_Marshal

func (m *RegionStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegionStat) XXX_Merge

func (dst *RegionStat) XXX_Merge(src proto.Message)

func (*RegionStat) XXX_Size

func (m *RegionStat) XXX_Size() int

func (*RegionStat) XXX_Unmarshal

func (m *RegionStat) XXX_Unmarshal(b []byte) error

type ReportBatchSplitRequest

type ReportBatchSplitRequest struct {
	Header               *RequestHeader   `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	Regions              []*metapb.Region `protobuf:"bytes,2,rep,name=regions" json:"regions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ReportBatchSplitRequest) Descriptor

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

func (*ReportBatchSplitRequest) GetHeader

func (m *ReportBatchSplitRequest) GetHeader() *RequestHeader

func (*ReportBatchSplitRequest) GetRegions

func (m *ReportBatchSplitRequest) GetRegions() []*metapb.Region

func (*ReportBatchSplitRequest) Marshal

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

func (*ReportBatchSplitRequest) MarshalTo

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

func (*ReportBatchSplitRequest) ProtoMessage

func (*ReportBatchSplitRequest) ProtoMessage()

func (*ReportBatchSplitRequest) Reset

func (m *ReportBatchSplitRequest) Reset()

func (*ReportBatchSplitRequest) Size

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

func (*ReportBatchSplitRequest) String

func (m *ReportBatchSplitRequest) String() string

func (*ReportBatchSplitRequest) Unmarshal

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

func (*ReportBatchSplitRequest) XXX_DiscardUnknown

func (m *ReportBatchSplitRequest) XXX_DiscardUnknown()

func (*ReportBatchSplitRequest) XXX_Marshal

func (m *ReportBatchSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportBatchSplitRequest) XXX_Merge

func (dst *ReportBatchSplitRequest) XXX_Merge(src proto.Message)

func (*ReportBatchSplitRequest) XXX_Size

func (m *ReportBatchSplitRequest) XXX_Size() int

func (*ReportBatchSplitRequest) XXX_Unmarshal

func (m *ReportBatchSplitRequest) XXX_Unmarshal(b []byte) error

type ReportBatchSplitResponse

type ReportBatchSplitResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ReportBatchSplitResponse) Descriptor

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

func (*ReportBatchSplitResponse) GetHeader

func (m *ReportBatchSplitResponse) GetHeader() *ResponseHeader

func (*ReportBatchSplitResponse) Marshal

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

func (*ReportBatchSplitResponse) MarshalTo

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

func (*ReportBatchSplitResponse) ProtoMessage

func (*ReportBatchSplitResponse) ProtoMessage()

func (*ReportBatchSplitResponse) Reset

func (m *ReportBatchSplitResponse) Reset()

func (*ReportBatchSplitResponse) Size

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

func (*ReportBatchSplitResponse) String

func (m *ReportBatchSplitResponse) String() string

func (*ReportBatchSplitResponse) Unmarshal

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

func (*ReportBatchSplitResponse) XXX_DiscardUnknown

func (m *ReportBatchSplitResponse) XXX_DiscardUnknown()

func (*ReportBatchSplitResponse) XXX_Marshal

func (m *ReportBatchSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportBatchSplitResponse) XXX_Merge

func (dst *ReportBatchSplitResponse) XXX_Merge(src proto.Message)

func (*ReportBatchSplitResponse) XXX_Size

func (m *ReportBatchSplitResponse) XXX_Size() int

func (*ReportBatchSplitResponse) XXX_Unmarshal

func (m *ReportBatchSplitResponse) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

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

func (*ReportSplitRequest) XXX_DiscardUnknown

func (m *ReportSplitRequest) XXX_DiscardUnknown()

func (*ReportSplitRequest) XXX_Marshal

func (m *ReportSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportSplitRequest) XXX_Merge

func (dst *ReportSplitRequest) XXX_Merge(src proto.Message)

func (*ReportSplitRequest) XXX_Size

func (m *ReportSplitRequest) XXX_Size() int

func (*ReportSplitRequest) XXX_Unmarshal

func (m *ReportSplitRequest) XXX_Unmarshal(b []byte) error

type ReportSplitResponse

type ReportSplitResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

func (*ReportSplitResponse) XXX_DiscardUnknown

func (m *ReportSplitResponse) XXX_DiscardUnknown()

func (*ReportSplitResponse) XXX_Marshal

func (m *ReportSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportSplitResponse) XXX_Merge

func (dst *ReportSplitResponse) XXX_Merge(src proto.Message)

func (*ReportSplitResponse) XXX_Size

func (m *ReportSplitResponse) XXX_Size() int

func (*ReportSplitResponse) XXX_Unmarshal

func (m *ReportSplitResponse) XXX_Unmarshal(b []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"`
	// sender_id is the ID of the sender server, also member ID or etcd ID.
	SenderId             uint64   `protobuf:"varint,2,opt,name=sender_id,json=senderId,proto3" json:"sender_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestHeader) Descriptor

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

func (*RequestHeader) GetClusterId

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) GetSenderId

func (m *RequestHeader) GetSenderId() 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

func (*RequestHeader) XXX_DiscardUnknown

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal

func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestHeader) XXX_Merge

func (dst *RequestHeader) XXX_Merge(src proto.Message)

func (*RequestHeader) XXX_Size

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal

func (m *RequestHeader) XXX_Unmarshal(b []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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseHeader) Descriptor

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

func (*ResponseHeader) GetClusterId

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError

func (m *ResponseHeader) GetError() *Error

func (*ResponseHeader) 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

func (*ResponseHeader) XXX_DiscardUnknown

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal

func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseHeader) XXX_Merge

func (dst *ResponseHeader) XXX_Merge(src proto.Message)

func (*ResponseHeader) XXX_Size

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal

func (m *ResponseHeader) XXX_Unmarshal(b []byte) error

type ScanRegionsRequest

type ScanRegionsRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
	StartKey             []byte         `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	Limit                int32          `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	EndKey               []byte         `protobuf:"bytes,4,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ScanRegionsRequest) Descriptor

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

func (*ScanRegionsRequest) GetEndKey

func (m *ScanRegionsRequest) GetEndKey() []byte

func (*ScanRegionsRequest) GetHeader

func (m *ScanRegionsRequest) GetHeader() *RequestHeader

func (*ScanRegionsRequest) GetLimit

func (m *ScanRegionsRequest) GetLimit() int32

func (*ScanRegionsRequest) GetStartKey

func (m *ScanRegionsRequest) GetStartKey() []byte

func (*ScanRegionsRequest) Marshal

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

func (*ScanRegionsRequest) MarshalTo

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

func (*ScanRegionsRequest) ProtoMessage

func (*ScanRegionsRequest) ProtoMessage()

func (*ScanRegionsRequest) Reset

func (m *ScanRegionsRequest) Reset()

func (*ScanRegionsRequest) Size

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

func (*ScanRegionsRequest) String

func (m *ScanRegionsRequest) String() string

func (*ScanRegionsRequest) Unmarshal

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