kvproto: github.com/pingcap/kvproto/pkg/pdpb Index | Files

package pdpb

import "github.com/pingcap/kvproto/pkg/pdpb"

Index

Package Files

pdpb.pb.go

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,
}

func RegisterPDServer Uses

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

type AllocIDRequest Uses

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 Uses

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

func (*AllocIDRequest) GetHeader Uses

func (m *AllocIDRequest) GetHeader() *RequestHeader

func (*AllocIDRequest) Marshal Uses

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

func (*AllocIDRequest) MarshalTo Uses

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

func (*AllocIDRequest) ProtoMessage Uses

func (*AllocIDRequest) ProtoMessage()

func (*AllocIDRequest) Reset Uses

func (m *AllocIDRequest) Reset()

func (*AllocIDRequest) Size Uses

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

func (*AllocIDRequest) String Uses

func (m *AllocIDRequest) String() string

func (*AllocIDRequest) Unmarshal Uses

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

func (*AllocIDRequest) XXX_DiscardUnknown Uses

func (m *AllocIDRequest) XXX_DiscardUnknown()

func (*AllocIDRequest) XXX_Marshal Uses

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

func (*AllocIDRequest) XXX_Merge Uses

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

func (*AllocIDRequest) XXX_Size Uses

func (m *AllocIDRequest) XXX_Size() int

func (*AllocIDRequest) XXX_Unmarshal Uses

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

type AllocIDResponse Uses

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 Uses

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

func (*AllocIDResponse) GetHeader Uses

func (m *AllocIDResponse) GetHeader() *ResponseHeader

func (*AllocIDResponse) GetId Uses

func (m *AllocIDResponse) GetId() uint64

func (*AllocIDResponse) Marshal Uses

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

func (*AllocIDResponse) MarshalTo Uses

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

func (*AllocIDResponse) ProtoMessage Uses

func (*AllocIDResponse) ProtoMessage()

func (*AllocIDResponse) Reset Uses

func (m *AllocIDResponse) Reset()

func (*AllocIDResponse) Size Uses

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

func (*AllocIDResponse) String Uses

func (m *AllocIDResponse) String() string

func (*AllocIDResponse) Unmarshal Uses

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

func (*AllocIDResponse) XXX_DiscardUnknown Uses

func (m *AllocIDResponse) XXX_DiscardUnknown()

func (*AllocIDResponse) XXX_Marshal Uses

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

func (*AllocIDResponse) XXX_Merge Uses

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

func (*AllocIDResponse) XXX_Size Uses

func (m *AllocIDResponse) XXX_Size() int

func (*AllocIDResponse) XXX_Unmarshal Uses

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

type AskBatchSplitRequest Uses

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 Uses

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

func (*AskBatchSplitRequest) GetHeader Uses

func (m *AskBatchSplitRequest) GetHeader() *RequestHeader

func (*AskBatchSplitRequest) GetRegion Uses

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

func (*AskBatchSplitRequest) GetSplitCount Uses

func (m *AskBatchSplitRequest) GetSplitCount() uint32

func (*AskBatchSplitRequest) Marshal Uses

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

func (*AskBatchSplitRequest) MarshalTo Uses

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

func (*AskBatchSplitRequest) ProtoMessage Uses

func (*AskBatchSplitRequest) ProtoMessage()

func (*AskBatchSplitRequest) Reset Uses

func (m *AskBatchSplitRequest) Reset()

func (*AskBatchSplitRequest) Size Uses

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

func (*AskBatchSplitRequest) String Uses

func (m *AskBatchSplitRequest) String() string

func (*AskBatchSplitRequest) Unmarshal Uses

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

func (*AskBatchSplitRequest) XXX_DiscardUnknown Uses

func (m *AskBatchSplitRequest) XXX_DiscardUnknown()

func (*AskBatchSplitRequest) XXX_Marshal Uses

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

func (*AskBatchSplitRequest) XXX_Merge Uses

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

func (*AskBatchSplitRequest) XXX_Size Uses

func (m *AskBatchSplitRequest) XXX_Size() int

func (*AskBatchSplitRequest) XXX_Unmarshal Uses

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

type AskBatchSplitResponse Uses

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 Uses

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

func (*AskBatchSplitResponse) GetHeader Uses

func (m *AskBatchSplitResponse) GetHeader() *ResponseHeader

func (*AskBatchSplitResponse) GetIds Uses

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

func (*AskBatchSplitResponse) Marshal Uses

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

func (*AskBatchSplitResponse) MarshalTo Uses

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

func (*AskBatchSplitResponse) ProtoMessage Uses

func (*AskBatchSplitResponse) ProtoMessage()

func (*AskBatchSplitResponse) Reset Uses

func (m *AskBatchSplitResponse) Reset()

func (*AskBatchSplitResponse) Size Uses

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

func (*AskBatchSplitResponse) String Uses

func (m *AskBatchSplitResponse) String() string

func (*AskBatchSplitResponse) Unmarshal Uses

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

func (*AskBatchSplitResponse) XXX_DiscardUnknown Uses

func (m *AskBatchSplitResponse) XXX_DiscardUnknown()

func (*AskBatchSplitResponse) XXX_Marshal Uses

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

func (*AskBatchSplitResponse) XXX_Merge Uses

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

func (*AskBatchSplitResponse) XXX_Size Uses

func (m *AskBatchSplitResponse) XXX_Size() int

func (*AskBatchSplitResponse) XXX_Unmarshal Uses

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

type AskSplitRequest Uses

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 Uses

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

func (*AskSplitRequest) GetHeader Uses

func (m *AskSplitRequest) GetHeader() *RequestHeader

func (*AskSplitRequest) GetRegion Uses

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

func (*AskSplitRequest) Marshal Uses

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

func (*AskSplitRequest) MarshalTo Uses

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

func (*AskSplitRequest) ProtoMessage Uses

func (*AskSplitRequest) ProtoMessage()

func (*AskSplitRequest) Reset Uses

func (m *AskSplitRequest) Reset()

func (*AskSplitRequest) Size Uses

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

func (*AskSplitRequest) String Uses

func (m *AskSplitRequest) String() string

func (*AskSplitRequest) Unmarshal Uses

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

func (*AskSplitRequest) XXX_DiscardUnknown Uses

func (m *AskSplitRequest) XXX_DiscardUnknown()

func (*AskSplitRequest) XXX_Marshal Uses

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

func (*AskSplitRequest) XXX_Merge Uses

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

func (*AskSplitRequest) XXX_Size Uses

func (m *AskSplitRequest) XXX_Size() int

func (*AskSplitRequest) XXX_Unmarshal Uses

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

type AskSplitResponse Uses

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 Uses

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

func (*AskSplitResponse) GetHeader Uses

func (m *AskSplitResponse) GetHeader() *ResponseHeader

func (*AskSplitResponse) GetNewPeerIds Uses

func (m *AskSplitResponse) GetNewPeerIds() []uint64

func (*AskSplitResponse) GetNewRegionId Uses

func (m *AskSplitResponse) GetNewRegionId() uint64

func (*AskSplitResponse) Marshal Uses

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

func (*AskSplitResponse) MarshalTo Uses

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

func (*AskSplitResponse) ProtoMessage Uses

func (*AskSplitResponse) ProtoMessage()

func (*AskSplitResponse) Reset Uses

func (m *AskSplitResponse) Reset()

func (*AskSplitResponse) Size Uses

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

func (*AskSplitResponse) String Uses

func (m *AskSplitResponse) String() string

func (*AskSplitResponse) Unmarshal Uses

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

func (*AskSplitResponse) XXX_DiscardUnknown Uses

func (m *AskSplitResponse) XXX_DiscardUnknown()

func (*AskSplitResponse) XXX_Marshal Uses

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

func (*AskSplitResponse) XXX_Merge Uses

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

func (*AskSplitResponse) XXX_Size Uses

func (m *AskSplitResponse) XXX_Size() int

func (*AskSplitResponse) XXX_Unmarshal Uses

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

type BootstrapRequest Uses

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 Uses

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

func (*BootstrapRequest) GetHeader Uses

func (m *BootstrapRequest) GetHeader() *RequestHeader

func (*BootstrapRequest) GetRegion Uses

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

func (*BootstrapRequest) GetStore Uses

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

func (*BootstrapRequest) Marshal Uses

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

func (*BootstrapRequest) MarshalTo Uses

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

func (*BootstrapRequest) ProtoMessage Uses

func (*BootstrapRequest) ProtoMessage()

func (*BootstrapRequest) Reset Uses

func (m *BootstrapRequest) Reset()

func (*BootstrapRequest) Size Uses

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

func (*BootstrapRequest) String Uses

func (m *BootstrapRequest) String() string

func (*BootstrapRequest) Unmarshal Uses

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

func (*BootstrapRequest) XXX_DiscardUnknown Uses

func (m *BootstrapRequest) XXX_DiscardUnknown()

func (*BootstrapRequest) XXX_Marshal Uses

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

func (*BootstrapRequest) XXX_Merge Uses

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

func (*BootstrapRequest) XXX_Size Uses

func (m *BootstrapRequest) XXX_Size() int

func (*BootstrapRequest) XXX_Unmarshal Uses

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

type BootstrapResponse Uses

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 Uses

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

func (*BootstrapResponse) GetHeader Uses

func (m *BootstrapResponse) GetHeader() *ResponseHeader

func (*BootstrapResponse) GetReplicationStatus Uses

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

func (*BootstrapResponse) Marshal Uses

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

func (*BootstrapResponse) MarshalTo Uses

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

func (*BootstrapResponse) ProtoMessage Uses

func (*BootstrapResponse) ProtoMessage()

func (*BootstrapResponse) Reset Uses

func (m *BootstrapResponse) Reset()

func (*BootstrapResponse) Size Uses

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

func (*BootstrapResponse) String Uses

func (m *BootstrapResponse) String() string

func (*BootstrapResponse) Unmarshal Uses

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

func (*BootstrapResponse) XXX_DiscardUnknown Uses

func (m *BootstrapResponse) XXX_DiscardUnknown()

func (*BootstrapResponse) XXX_Marshal Uses

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

func (*BootstrapResponse) XXX_Merge Uses

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

func (*BootstrapResponse) XXX_Size Uses

func (m *BootstrapResponse) XXX_Size() int

func (*BootstrapResponse) XXX_Unmarshal Uses

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

type ChangePeer Uses

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 Uses

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

func (*ChangePeer) GetChangeType Uses

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

func (*ChangePeer) GetPeer Uses

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

func (*ChangePeer) Marshal Uses

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

func (*ChangePeer) MarshalTo Uses

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

func (*ChangePeer) ProtoMessage Uses

func (*ChangePeer) ProtoMessage()

func (*ChangePeer) Reset Uses

func (m *ChangePeer) Reset()

func (*ChangePeer) Size Uses

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

func (*ChangePeer) String Uses

func (m *ChangePeer) String() string

func (*ChangePeer) Unmarshal Uses

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

func (*ChangePeer) XXX_DiscardUnknown Uses

func (m *ChangePeer) XXX_DiscardUnknown()

func (*ChangePeer) XXX_Marshal Uses

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

func (*ChangePeer) XXX_Merge Uses

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

func (*ChangePeer) XXX_Size Uses

func (m *ChangePeer) XXX_Size() int

func (*ChangePeer) XXX_Unmarshal Uses

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

type ChangePeerV2 Uses

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 Uses

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

func (*ChangePeerV2) GetChanges Uses

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

func (*ChangePeerV2) Marshal Uses

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

func (*ChangePeerV2) MarshalTo Uses

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

func (*ChangePeerV2) ProtoMessage Uses

func (*ChangePeerV2) ProtoMessage()

func (*ChangePeerV2) Reset Uses

func (m *ChangePeerV2) Reset()

func (*ChangePeerV2) Size Uses

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

func (*ChangePeerV2) String Uses

func (m *ChangePeerV2) String() string

func (*ChangePeerV2) Unmarshal Uses

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

func (*ChangePeerV2) XXX_DiscardUnknown Uses

func (m *ChangePeerV2) XXX_DiscardUnknown()

func (*ChangePeerV2) XXX_Marshal Uses

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

func (*ChangePeerV2) XXX_Merge Uses

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

func (*ChangePeerV2) XXX_Size Uses

func (m *ChangePeerV2) XXX_Size() int

func (*ChangePeerV2) XXX_Unmarshal Uses

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

type CheckPolicy Uses

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

func (CheckPolicy) EnumDescriptor Uses

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

func (CheckPolicy) String Uses

func (x CheckPolicy) String() string

type Error Uses

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 Uses

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

func (*Error) GetMessage Uses

func (m *Error) GetMessage() string

func (*Error) GetType Uses

func (m *Error) GetType() ErrorType

func (*Error) Marshal Uses

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

func (*Error) MarshalTo Uses

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

func (*Error) ProtoMessage Uses

func (*Error) ProtoMessage()

func (*Error) Reset Uses

func (m *Error) Reset()

func (*Error) Size Uses

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

func (*Error) String Uses

func (m *Error) String() string

func (*Error) Unmarshal Uses

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

func (*Error) XXX_DiscardUnknown Uses

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal Uses

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

func (*Error) XXX_Merge Uses

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

func (*Error) XXX_Size Uses

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal Uses

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

type ErrorType Uses

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 Uses

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

func (ErrorType) String Uses

func (x ErrorType) String() string

type GetAllStoresRequest Uses

type GetAllStoresRequest struct {
    Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
    // Do NOT return tombstone stores if set to true.
    ExcludeTombstoneStores bool     `protobuf:"varint,2,opt,name=exclude_tombstone_stores,json=excludeTombstoneStores,proto3" json:"exclude_tombstone_stores,omitempty"`
    XXX_NoUnkeyedLiteral   struct{} `json:"-"`
    XXX_unrecognized       []byte   `json:"-"`
    XXX_sizecache          int32    `json:"-"`
}

func (*GetAllStoresRequest) Descriptor Uses

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

func (*GetAllStoresRequest) GetExcludeTombstoneStores Uses

func (m *GetAllStoresRequest) GetExcludeTombstoneStores() bool

func (*GetAllStoresRequest) GetHeader Uses

func (m *GetAllStoresRequest) GetHeader() *RequestHeader

func (*GetAllStoresRequest) Marshal Uses

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

func (*GetAllStoresRequest) MarshalTo Uses

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

func (*GetAllStoresRequest) ProtoMessage Uses

func (*GetAllStoresRequest) ProtoMessage()

func (*GetAllStoresRequest) Reset Uses

func (m *GetAllStoresRequest) Reset()

func (*GetAllStoresRequest) Size Uses

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

func (*GetAllStoresRequest) String Uses

func (m *GetAllStoresRequest) String() string

func (*GetAllStoresRequest) Unmarshal Uses

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

func (*GetAllStoresRequest) XXX_DiscardUnknown Uses

func (m *GetAllStoresRequest) XXX_DiscardUnknown()

func (*GetAllStoresRequest) XXX_Marshal Uses

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

func (*GetAllStoresRequest) XXX_Merge Uses

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

func (*GetAllStoresRequest) XXX_Size Uses

func (m *GetAllStoresRequest) XXX_Size() int

func (*GetAllStoresRequest) XXX_Unmarshal Uses

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

type GetAllStoresResponse Uses

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 Uses

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

func (*GetAllStoresResponse) GetHeader Uses

func (m *GetAllStoresResponse) GetHeader() *ResponseHeader

func (*GetAllStoresResponse) GetStores Uses

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

func (*GetAllStoresResponse) Marshal Uses

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

func (*GetAllStoresResponse) MarshalTo Uses

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

func (*GetAllStoresResponse) ProtoMessage Uses

func (*GetAllStoresResponse) ProtoMessage()

func (*GetAllStoresResponse) Reset Uses

func (m *GetAllStoresResponse) Reset()

func (*GetAllStoresResponse) Size Uses

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

func (*GetAllStoresResponse) String Uses

func (m *GetAllStoresResponse) String() string

func (*GetAllStoresResponse) Unmarshal Uses

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

func (*GetAllStoresResponse) XXX_DiscardUnknown Uses

func (m *GetAllStoresResponse) XXX_DiscardUnknown()

func (*GetAllStoresResponse) XXX_Marshal Uses

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

func (*GetAllStoresResponse) XXX_Merge Uses

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

func (*GetAllStoresResponse) XXX_Size Uses

func (m *GetAllStoresResponse) XXX_Size() int

func (*GetAllStoresResponse) XXX_Unmarshal Uses

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

type GetClusterConfigRequest Uses

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 Uses

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

func (*GetClusterConfigRequest) GetHeader Uses

func (m *GetClusterConfigRequest) GetHeader() *RequestHeader

func (*GetClusterConfigRequest) Marshal Uses

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

func (*GetClusterConfigRequest) MarshalTo Uses

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

func (*GetClusterConfigRequest) ProtoMessage Uses

func (*GetClusterConfigRequest) ProtoMessage()

func (*GetClusterConfigRequest) Reset Uses

func (m *GetClusterConfigRequest) Reset()

func (*GetClusterConfigRequest) Size Uses

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

func (*GetClusterConfigRequest) String Uses

func (m *GetClusterConfigRequest) String() string

func (*GetClusterConfigRequest) Unmarshal Uses

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

func (*GetClusterConfigRequest) XXX_DiscardUnknown Uses

func (m *GetClusterConfigRequest) XXX_DiscardUnknown()

func (*GetClusterConfigRequest) XXX_Marshal Uses

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

func (*GetClusterConfigRequest) XXX_Merge Uses

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

func (*GetClusterConfigRequest) XXX_Size Uses

func (m *GetClusterConfigRequest) XXX_Size() int

func (*GetClusterConfigRequest) XXX_Unmarshal Uses

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

type GetClusterConfigResponse Uses

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 Uses

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

func (*GetClusterConfigResponse) GetCluster Uses

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

func (*GetClusterConfigResponse) GetHeader Uses

func (m *GetClusterConfigResponse) GetHeader() *ResponseHeader

func (*GetClusterConfigResponse) Marshal Uses

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

func (*GetClusterConfigResponse) MarshalTo Uses

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

func (*GetClusterConfigResponse) ProtoMessage Uses

func (*GetClusterConfigResponse) ProtoMessage()

func (*GetClusterConfigResponse) Reset Uses

func (m *GetClusterConfigResponse) Reset()

func (*GetClusterConfigResponse) Size Uses

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

func (*GetClusterConfigResponse) String Uses

func (m *GetClusterConfigResponse) String() string

func (*GetClusterConfigResponse) Unmarshal Uses

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

func (*GetClusterConfigResponse) XXX_DiscardUnknown Uses

func (m *GetClusterConfigResponse) XXX_DiscardUnknown()

func (*GetClusterConfigResponse) XXX_Marshal Uses

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

func (*GetClusterConfigResponse) XXX_Merge Uses

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

func (*GetClusterConfigResponse) XXX_Size Uses

func (m *GetClusterConfigResponse) XXX_Size() int

func (*GetClusterConfigResponse) XXX_Unmarshal Uses

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

type GetGCSafePointRequest Uses

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 Uses

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

func (*GetGCSafePointRequest) GetHeader Uses

func (m *GetGCSafePointRequest) GetHeader() *RequestHeader

func (*GetGCSafePointRequest) Marshal Uses

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

func (*GetGCSafePointRequest) MarshalTo Uses

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

func (*GetGCSafePointRequest) ProtoMessage Uses

func (*GetGCSafePointRequest) ProtoMessage()

func (*GetGCSafePointRequest) Reset Uses

func (m *GetGCSafePointRequest) Reset()

func (*GetGCSafePointRequest) Size Uses

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

func (*GetGCSafePointRequest) String Uses

func (m *GetGCSafePointRequest) String() string

func (*GetGCSafePointRequest) Unmarshal Uses

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

func (*GetGCSafePointRequest) XXX_DiscardUnknown Uses

func (m *GetGCSafePointRequest) XXX_DiscardUnknown()

func (*GetGCSafePointRequest) XXX_Marshal Uses

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

func (*GetGCSafePointRequest) XXX_Merge Uses

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

func (*GetGCSafePointRequest) XXX_Size Uses

func (m *GetGCSafePointRequest) XXX_Size() int

func (*GetGCSafePointRequest) XXX_Unmarshal Uses

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

type GetGCSafePointResponse Uses

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 Uses

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

func (*GetGCSafePointResponse) GetHeader Uses

func (m *GetGCSafePointResponse) GetHeader() *ResponseHeader

func (*GetGCSafePointResponse) GetSafePoint Uses

func (m *GetGCSafePointResponse) GetSafePoint() uint64

func (*GetGCSafePointResponse) Marshal Uses

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

func (*GetGCSafePointResponse) MarshalTo Uses

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

func (*GetGCSafePointResponse) ProtoMessage Uses

func (*GetGCSafePointResponse) ProtoMessage()

func (*GetGCSafePointResponse) Reset Uses

func (m *GetGCSafePointResponse) Reset()

func (*GetGCSafePointResponse) Size Uses

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

func (*GetGCSafePointResponse) String Uses

func (m *GetGCSafePointResponse) String() string

func (*GetGCSafePointResponse) Unmarshal Uses

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

func (*GetGCSafePointResponse) XXX_DiscardUnknown Uses

func (m *GetGCSafePointResponse) XXX_DiscardUnknown()

func (*GetGCSafePointResponse) XXX_Marshal Uses

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

func (*GetGCSafePointResponse) XXX_Merge Uses

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

func (*GetGCSafePointResponse) XXX_Size Uses

func (m *GetGCSafePointResponse) XXX_Size() int

func (*GetGCSafePointResponse) XXX_Unmarshal Uses

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

type GetMembersRequest Uses

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 Uses

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

func (*GetMembersRequest) GetHeader Uses

func (m *GetMembersRequest) GetHeader() *RequestHeader

func (*GetMembersRequest) Marshal Uses

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

func (*GetMembersRequest) MarshalTo Uses

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

func (*GetMembersRequest) ProtoMessage Uses

func (*GetMembersRequest) ProtoMessage()

func (*GetMembersRequest) Reset Uses

func (m *GetMembersRequest) Reset()

func (*GetMembersRequest) Size Uses

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

func (*GetMembersRequest) String Uses

func (m *GetMembersRequest) String() string

func (*GetMembersRequest) Unmarshal Uses

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

func (*GetMembersRequest) XXX_DiscardUnknown Uses

func (m *GetMembersRequest) XXX_DiscardUnknown()

func (*GetMembersRequest) XXX_Marshal Uses

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

func (*GetMembersRequest) XXX_Merge Uses

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

func (*GetMembersRequest) XXX_Size Uses

func (m *GetMembersRequest) XXX_Size() int

func (*GetMembersRequest) XXX_Unmarshal Uses

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

type GetMembersResponse Uses

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

func (*GetMembersResponse) Descriptor Uses

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

func (*GetMembersResponse) GetEtcdLeader Uses

func (m *GetMembersResponse) GetEtcdLeader() *Member

func (*GetMembersResponse) GetHeader Uses

func (m *GetMembersResponse) GetHeader() *ResponseHeader

func (*GetMembersResponse) GetLeader Uses

func (m *GetMembersResponse) GetLeader() *Member

func (*GetMembersResponse) GetMembers Uses

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

func (*GetMembersResponse) Marshal Uses

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

func (*GetMembersResponse) MarshalTo Uses

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

func (*GetMembersResponse) ProtoMessage Uses

func (*GetMembersResponse) ProtoMessage()

func (*GetMembersResponse) Reset Uses

func (m *GetMembersResponse) Reset()

func (*GetMembersResponse) Size Uses

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

func (*GetMembersResponse) String Uses

func (m *GetMembersResponse) String() string

func (*GetMembersResponse) Unmarshal Uses

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

func (*GetMembersResponse) XXX_DiscardUnknown Uses

func (m *GetMembersResponse) XXX_DiscardUnknown()

func (*GetMembersResponse) XXX_Marshal Uses

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

func (*GetMembersResponse) XXX_Merge Uses

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

func (*GetMembersResponse) XXX_Size Uses

func (m *GetMembersResponse) XXX_Size() int

func (*GetMembersResponse) XXX_Unmarshal Uses

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

type GetOperatorRequest Uses

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 Uses

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

func (*GetOperatorRequest) GetHeader Uses

func (m *GetOperatorRequest) GetHeader() *RequestHeader

func (*GetOperatorRequest) GetRegionId Uses

func (m *GetOperatorRequest) GetRegionId() uint64

func (*GetOperatorRequest) Marshal Uses

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

func (*GetOperatorRequest) MarshalTo Uses

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

func (*GetOperatorRequest) ProtoMessage Uses

func (*GetOperatorRequest) ProtoMessage()

func (*GetOperatorRequest) Reset Uses

func (m *GetOperatorRequest) Reset()

func (*GetOperatorRequest) Size Uses

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

func (*GetOperatorRequest) String Uses

func (m *GetOperatorRequest) String() string

func (*GetOperatorRequest) Unmarshal Uses

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

func (*GetOperatorRequest) XXX_DiscardUnknown Uses

func (m *GetOperatorRequest) XXX_DiscardUnknown()

func (*GetOperatorRequest) XXX_Marshal Uses

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

func (*GetOperatorRequest) XXX_Merge Uses

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

func (*GetOperatorRequest) XXX_Size Uses

func (m *GetOperatorRequest) XXX_Size() int

func (*GetOperatorRequest) XXX_Unmarshal Uses

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

type GetOperatorResponse Uses

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 Uses

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

func (*GetOperatorResponse) GetDesc Uses

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

func (*GetOperatorResponse) GetHeader Uses

func (m *GetOperatorResponse) GetHeader() *ResponseHeader

func (*GetOperatorResponse) GetKind Uses

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

func (*GetOperatorResponse) GetRegionId Uses

func (m *GetOperatorResponse) GetRegionId() uint64

func (*GetOperatorResponse) GetStatus Uses

func (m *GetOperatorResponse) GetStatus() OperatorStatus

func (*GetOperatorResponse) Marshal Uses

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

func (*GetOperatorResponse) MarshalTo Uses

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

func (*GetOperatorResponse) ProtoMessage Uses

func (*GetOperatorResponse) ProtoMessage()

func (*GetOperatorResponse) Reset Uses

func (m *GetOperatorResponse) Reset()

func (*GetOperatorResponse) Size Uses

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

func (*GetOperatorResponse) String Uses

func (m *GetOperatorResponse) String() string

func (*GetOperatorResponse) Unmarshal Uses

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

func (*GetOperatorResponse) XXX_DiscardUnknown Uses

func (m *GetOperatorResponse) XXX_DiscardUnknown()

func (*GetOperatorResponse) XXX_Marshal Uses

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

func (*GetOperatorResponse) XXX_Merge Uses

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

func (*GetOperatorResponse) XXX_Size Uses

func (m *GetOperatorResponse) XXX_Size() int

func (*GetOperatorResponse) XXX_Unmarshal Uses

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

type GetRegionByIDRequest Uses

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 Uses

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

func (*GetRegionByIDRequest) GetHeader Uses

func (m *GetRegionByIDRequest) GetHeader() *RequestHeader

func (*GetRegionByIDRequest) GetRegionId Uses

func (m *GetRegionByIDRequest) GetRegionId() uint64

func (*GetRegionByIDRequest) Marshal Uses

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

func (*GetRegionByIDRequest) MarshalTo Uses

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

func (*GetRegionByIDRequest) ProtoMessage Uses

func (*GetRegionByIDRequest) ProtoMessage()

func (*GetRegionByIDRequest) Reset Uses

func (m *GetRegionByIDRequest) Reset()

func (*GetRegionByIDRequest) Size Uses

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

func (*GetRegionByIDRequest) String Uses

func (m *GetRegionByIDRequest) String() string

func (*GetRegionByIDRequest) Unmarshal Uses

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

func (*GetRegionByIDRequest) XXX_DiscardUnknown Uses

func (m *GetRegionByIDRequest) XXX_DiscardUnknown()

func (*GetRegionByIDRequest) XXX_Marshal Uses

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

func (*GetRegionByIDRequest) XXX_Merge Uses

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

func (*GetRegionByIDRequest) XXX_Size Uses

func (m *GetRegionByIDRequest) XXX_Size() int

func (*GetRegionByIDRequest) XXX_Unmarshal Uses

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

type GetRegionRequest Uses

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 Uses

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

func (*GetRegionRequest) GetHeader Uses

func (m *GetRegionRequest) GetHeader() *RequestHeader

func (*GetRegionRequest) GetRegionKey Uses

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

func (*GetRegionRequest) Marshal Uses

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

func (*GetRegionRequest) MarshalTo Uses

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

func (*GetRegionRequest) ProtoMessage Uses

func (*GetRegionRequest) ProtoMessage()

func (*GetRegionRequest) Reset Uses

func (m *GetRegionRequest) Reset()

func (*GetRegionRequest) Size Uses

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

func (*GetRegionRequest) String Uses

func (m *GetRegionRequest) String() string

func (*GetRegionRequest) Unmarshal Uses

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

func (*GetRegionRequest) XXX_DiscardUnknown Uses

func (m *GetRegionRequest) XXX_DiscardUnknown()

func (*GetRegionRequest) XXX_Marshal Uses

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

func (*GetRegionRequest) XXX_Merge Uses

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

func (*GetRegionRequest) XXX_Size Uses

func (m *GetRegionRequest) XXX_Size() int

func (*GetRegionRequest) XXX_Unmarshal Uses

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

type GetRegionResponse Uses

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 Uses

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

func (*GetRegionResponse) GetDownPeers Uses

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

func (*GetRegionResponse) GetHeader Uses

func (m *GetRegionResponse) GetHeader() *ResponseHeader

func (*GetRegionResponse) GetLeader Uses

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

func (*GetRegionResponse) GetPendingPeers Uses

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

func (*GetRegionResponse) GetRegion Uses

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

func (*GetRegionResponse) Marshal Uses

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

func (*GetRegionResponse) MarshalTo Uses

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

func (*GetRegionResponse) ProtoMessage Uses

func (*GetRegionResponse) ProtoMessage()

func (*GetRegionResponse) Reset Uses

func (m *GetRegionResponse) Reset()

func (*GetRegionResponse) Size Uses

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

func (*GetRegionResponse) String Uses

func (m *GetRegionResponse) String() string

func (*GetRegionResponse) Unmarshal Uses

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

func (*GetRegionResponse) XXX_DiscardUnknown Uses

func (m *GetRegionResponse) XXX_DiscardUnknown()

func (*GetRegionResponse) XXX_Marshal Uses

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

func (*GetRegionResponse) XXX_Merge Uses

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

func (*GetRegionResponse) XXX_Size Uses

func (m *GetRegionResponse) XXX_Size() int

func (*GetRegionResponse) XXX_Unmarshal Uses

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

type GetStoreRequest Uses

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 Uses

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

func (*GetStoreRequest) GetHeader Uses

func (m *GetStoreRequest) GetHeader() *RequestHeader

func (*GetStoreRequest) GetStoreId Uses

func (m *GetStoreRequest) GetStoreId() uint64

func (*GetStoreRequest) Marshal Uses

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

func (*GetStoreRequest) MarshalTo Uses

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

func (*GetStoreRequest) ProtoMessage Uses

func (*GetStoreRequest) ProtoMessage()

func (*GetStoreRequest) Reset Uses

func (m *GetStoreRequest) Reset()

func (*GetStoreRequest) Size Uses

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

func (*GetStoreRequest) String Uses

func (m *GetStoreRequest) String() string

func (*GetStoreRequest) Unmarshal Uses

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

func (*GetStoreRequest) XXX_DiscardUnknown Uses

func (m *GetStoreRequest) XXX_DiscardUnknown()

func (*GetStoreRequest) XXX_Marshal Uses

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

func (*GetStoreRequest) XXX_Merge Uses

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

func (*GetStoreRequest) XXX_Size Uses

func (m *GetStoreRequest) XXX_Size() int

func (*GetStoreRequest) XXX_Unmarshal Uses

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

type GetStoreResponse Uses

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 Uses

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

func (*GetStoreResponse) GetHeader Uses

func (m *GetStoreResponse) GetHeader() *ResponseHeader

func (*GetStoreResponse) GetStats Uses

func (m *GetStoreResponse) GetStats() *StoreStats

func (*GetStoreResponse) GetStore Uses

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

func (*GetStoreResponse) Marshal Uses

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

func (*GetStoreResponse) MarshalTo Uses

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

func (*GetStoreResponse) ProtoMessage Uses

func (*GetStoreResponse) ProtoMessage()

func (*GetStoreResponse) Reset Uses

func (m *GetStoreResponse) Reset()

func (*GetStoreResponse) Size Uses

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

func (*GetStoreResponse) String Uses

func (m *GetStoreResponse) String() string

func (*GetStoreResponse) Unmarshal Uses

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

func (*GetStoreResponse) XXX_DiscardUnknown Uses

func (m *GetStoreResponse) XXX_DiscardUnknown()

func (*GetStoreResponse) XXX_Marshal Uses

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

func (*GetStoreResponse) XXX_Merge Uses

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

func (*GetStoreResponse) XXX_Size Uses

func (m *GetStoreResponse) XXX_Size() int

func (*GetStoreResponse) XXX_Unmarshal Uses

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

type IsBootstrappedRequest Uses

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 Uses

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

func (*IsBootstrappedRequest) GetHeader Uses

func (m *IsBootstrappedRequest) GetHeader() *RequestHeader

func (*IsBootstrappedRequest) Marshal Uses

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

func (*IsBootstrappedRequest) MarshalTo Uses

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

func (*IsBootstrappedRequest) ProtoMessage Uses

func (*IsBootstrappedRequest) ProtoMessage()

func (*IsBootstrappedRequest) Reset Uses

func (m *IsBootstrappedRequest) Reset()

func (*IsBootstrappedRequest) Size Uses

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

func (*IsBootstrappedRequest) String Uses

func (m *IsBootstrappedRequest) String() string

func (*IsBootstrappedRequest) Unmarshal Uses

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

func (*IsBootstrappedRequest) XXX_DiscardUnknown Uses

func (m *IsBootstrappedRequest) XXX_DiscardUnknown()

func (*IsBootstrappedRequest) XXX_Marshal Uses

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

func (*IsBootstrappedRequest) XXX_Merge Uses

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

func (*IsBootstrappedRequest) XXX_Size Uses

func (m *IsBootstrappedRequest) XXX_Size() int

func (*IsBootstrappedRequest) XXX_Unmarshal Uses

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

type IsBootstrappedResponse Uses

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 Uses

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

func (*IsBootstrappedResponse) GetBootstrapped Uses

func (m *IsBootstrappedResponse) GetBootstrapped() bool

func (*IsBootstrappedResponse) GetHeader Uses

func (m *IsBootstrappedResponse) GetHeader() *ResponseHeader

func (*IsBootstrappedResponse) Marshal Uses

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

func (*IsBootstrappedResponse) MarshalTo Uses

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

func (*IsBootstrappedResponse) ProtoMessage Uses

func (*IsBootstrappedResponse) ProtoMessage()

func (*IsBootstrappedResponse) Reset Uses

func (m *IsBootstrappedResponse) Reset()

func (*IsBootstrappedResponse) Size Uses

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

func (*IsBootstrappedResponse) String Uses

func (m *IsBootstrappedResponse) String() string

func (*IsBootstrappedResponse) Unmarshal Uses

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

func (*IsBootstrappedResponse) XXX_DiscardUnknown Uses

func (m *IsBootstrappedResponse) XXX_DiscardUnknown()

func (*IsBootstrappedResponse) XXX_Marshal Uses

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

func (*IsBootstrappedResponse) XXX_Merge Uses

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

func (*IsBootstrappedResponse) XXX_Size Uses

func (m *IsBootstrappedResponse) XXX_Size() int

func (*IsBootstrappedResponse) XXX_Unmarshal Uses

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

type Member Uses

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 Uses

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

func (*Member) GetBinaryVersion Uses

func (m *Member) GetBinaryVersion() string

func (*Member) GetClientUrls Uses

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

func (*Member) GetDeployPath Uses

func (m *Member) GetDeployPath() string

func (*Member) GetGitHash Uses

func (m *Member) GetGitHash() string

func (*Member) GetLeaderPriority Uses

func (m *Member) GetLeaderPriority() int32

func (*Member) GetMemberId Uses

func (m *Member) GetMemberId() uint64

func (*Member) GetName Uses

func (m *Member) GetName() string

func (*Member) GetPeerUrls Uses

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

func (*Member) Marshal Uses

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

func (*Member) MarshalTo Uses

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

func (*Member) ProtoMessage Uses

func (*Member) ProtoMessage()

func (*Member) Reset Uses

func (m *Member) Reset()

func (*Member) Size Uses

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

func (*Member) String Uses

func (m *Member) String() string

func (*Member) Unmarshal Uses

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

func (*Member) XXX_DiscardUnknown Uses

func (m *Member) XXX_DiscardUnknown()

func (*Member) XXX_Marshal Uses

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

func (*Member) XXX_Merge Uses

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

func (*Member) XXX_Size Uses

func (m *Member) XXX_Size() int

func (*Member) XXX_Unmarshal Uses

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

type Merge Uses

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 Uses

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

func (*Merge) GetTarget Uses

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

func (*Merge) Marshal Uses

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

func (*Merge) MarshalTo Uses

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

func (*Merge) ProtoMessage Uses

func (*Merge) ProtoMessage()

func (*Merge) Reset Uses

func (m *Merge) Reset()

func (*Merge) Size Uses

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

func (*Merge) String Uses

func (m *Merge) String() string

func (*Merge) Unmarshal Uses

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

func (*Merge) XXX_DiscardUnknown Uses

func (m *Merge) XXX_DiscardUnknown()

func (*Merge) XXX_Marshal Uses

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

func (*Merge) XXX_Merge Uses

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

func (*Merge) XXX_Size Uses

func (m *Merge) XXX_Size() int

func (*Merge) XXX_Unmarshal Uses

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

type OperatorStatus Uses

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 Uses

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

func (OperatorStatus) String Uses

func (x OperatorStatus) String() string

type PDClient Uses

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

func NewPDClient Uses

func NewPDClient(cc *grpc.ClientConn) PDClient

type PDServer Uses

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

type PD_RegionHeartbeatClient Uses

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

type PD_RegionHeartbeatServer Uses

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

type PD_SyncRegionsClient Uses

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

type PD_SyncRegionsServer Uses

type PD_SyncRegionsServer interface {
    Send(*SyncRegionResponse) error
    Recv() (*SyncRegionRequest, error)
    grpc.ServerStream
}

type PD_TsoClient Uses

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

type PD_TsoServer Uses

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

type PeerStats Uses

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 Uses

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

func (*PeerStats) GetDownSeconds Uses

func (m *PeerStats) GetDownSeconds() uint64

func (*PeerStats) GetPeer Uses

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

func (*PeerStats) Marshal Uses

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

func (*PeerStats) MarshalTo Uses

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

func (*PeerStats) ProtoMessage Uses

func (*PeerStats) ProtoMessage()

func (*PeerStats) Reset Uses

func (m *PeerStats) Reset()

func (*PeerStats) Size Uses

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

func (*PeerStats) String Uses

func (m *PeerStats) String() string

func (*PeerStats) Unmarshal Uses

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

func (*PeerStats) XXX_DiscardUnknown Uses

func (m *PeerStats) XXX_DiscardUnknown()

func (*PeerStats) XXX_Marshal Uses

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

func (*PeerStats) XXX_Merge Uses

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

func (*PeerStats) XXX_Size Uses

func (m *PeerStats) XXX_Size() int

func (*PeerStats) XXX_Unmarshal Uses

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

type PutClusterConfigRequest Uses

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 Uses

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

func (*PutClusterConfigRequest) GetCluster Uses

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

func (*PutClusterConfigRequest) GetHeader Uses

func (m *PutClusterConfigRequest) GetHeader() *RequestHeader

func (*PutClusterConfigRequest) Marshal Uses

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

func (*PutClusterConfigRequest) MarshalTo Uses

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

func (*PutClusterConfigRequest) ProtoMessage Uses

func (*PutClusterConfigRequest) ProtoMessage()

func (*PutClusterConfigRequest) Reset Uses

func (m *PutClusterConfigRequest) Reset()

func (*PutClusterConfigRequest) Size Uses

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

func (*PutClusterConfigRequest) String Uses

func (m *PutClusterConfigRequest) String() string

func (*PutClusterConfigRequest) Unmarshal Uses

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

func (*PutClusterConfigRequest) XXX_DiscardUnknown Uses

func (m *PutClusterConfigRequest) XXX_DiscardUnknown()

func (*PutClusterConfigRequest) XXX_Marshal Uses

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

func (*PutClusterConfigRequest) XXX_Merge Uses

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

func (*PutClusterConfigRequest) XXX_Size Uses

func (m *PutClusterConfigRequest) XXX_Size() int

func (*PutClusterConfigRequest) XXX_Unmarshal Uses

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

type PutClusterConfigResponse Uses

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 Uses

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

func (*PutClusterConfigResponse) GetHeader Uses

func (m *PutClusterConfigResponse) GetHeader() *ResponseHeader

func (*PutClusterConfigResponse) Marshal Uses

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

func (*PutClusterConfigResponse) MarshalTo Uses

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

func (*PutClusterConfigResponse) ProtoMessage Uses

func (*PutClusterConfigResponse) ProtoMessage()

func (*PutClusterConfigResponse) Reset Uses

func (m *PutClusterConfigResponse) Reset()

func (*PutClusterConfigResponse) Size Uses

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

func (*PutClusterConfigResponse) String Uses

func (m *PutClusterConfigResponse) String() string

func (*PutClusterConfigResponse) Unmarshal Uses

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

func (*PutClusterConfigResponse) XXX_DiscardUnknown Uses

func (m *PutClusterConfigResponse) XXX_DiscardUnknown()

func (*PutClusterConfigResponse) XXX_Marshal Uses

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

func (*PutClusterConfigResponse) XXX_Merge Uses

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

func (*PutClusterConfigResponse) XXX_Size Uses

func (m *PutClusterConfigResponse) XXX_Size() int

func (*PutClusterConfigResponse) XXX_Unmarshal Uses

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

type PutStoreRequest Uses

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 Uses

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

func (*PutStoreRequest) GetHeader Uses

func (m *PutStoreRequest) GetHeader() *RequestHeader

func (*PutStoreRequest) GetStore Uses

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

func (*PutStoreRequest) Marshal Uses

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

func (*PutStoreRequest) MarshalTo Uses

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

func (*PutStoreRequest) ProtoMessage Uses

func (*PutStoreRequest) ProtoMessage()

func (*PutStoreRequest) Reset Uses

func (m *PutStoreRequest) Reset()

func (*PutStoreRequest) Size Uses

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

func (*PutStoreRequest) String Uses

func (m *PutStoreRequest) String() string

func (*PutStoreRequest) Unmarshal Uses

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

func (*PutStoreRequest) XXX_DiscardUnknown Uses

func (m *PutStoreRequest) XXX_DiscardUnknown()

func (*PutStoreRequest) XXX_Marshal Uses

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

func (*PutStoreRequest) XXX_Merge Uses

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

func (*PutStoreRequest) XXX_Size Uses

func (m *PutStoreRequest) XXX_Size() int

func (*PutStoreRequest) XXX_Unmarshal Uses

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

type PutStoreResponse Uses

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 Uses

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

func (*PutStoreResponse) GetHeader Uses

func (m *PutStoreResponse) GetHeader() *ResponseHeader

func (*PutStoreResponse) GetReplicationStatus Uses

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

func (*PutStoreResponse) Marshal Uses

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

func (*PutStoreResponse) MarshalTo Uses

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

func (*PutStoreResponse) ProtoMessage Uses

func (*PutStoreResponse) ProtoMessage()

func (*PutStoreResponse) Reset Uses

func (m *PutStoreResponse) Reset()

func (*PutStoreResponse) Size Uses

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

func (*PutStoreResponse) String Uses

func (m *PutStoreResponse) String() string

func (*PutStoreResponse) Unmarshal Uses

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

func (*PutStoreResponse) XXX_DiscardUnknown Uses

func (m *PutStoreResponse) XXX_DiscardUnknown()

func (*PutStoreResponse) XXX_Marshal Uses

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

func (*PutStoreResponse) XXX_Merge Uses

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

func (*PutStoreResponse) XXX_Size Uses

func (m *PutStoreResponse) XXX_Size() int

func (*PutStoreResponse) XXX_Unmarshal Uses

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

type RecordPair Uses

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 Uses

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

func (*RecordPair) GetKey Uses

func (m *RecordPair) GetKey() string

func (*RecordPair) GetValue Uses

func (m *RecordPair) GetValue() uint64

func (*RecordPair) Marshal Uses

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

func (*RecordPair) MarshalTo Uses

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

func (*RecordPair) ProtoMessage Uses

func (*RecordPair) ProtoMessage()

func (*RecordPair) Reset Uses

func (m *RecordPair) Reset()

func (*RecordPair) Size Uses

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

func (*RecordPair) String Uses

func (m *RecordPair) String() string

func (*RecordPair) Unmarshal Uses

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

func (*RecordPair) XXX_DiscardUnknown Uses

func (m *RecordPair) XXX_DiscardUnknown()

func (*RecordPair) XXX_Marshal Uses

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

func (*RecordPair) XXX_Merge Uses

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

func (*RecordPair) XXX_Size Uses

func (m *RecordPair) XXX_Size() int

func (*RecordPair) XXX_Unmarshal Uses

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

type Region Uses

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 Uses

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

func (*Region) GetDownPeers Uses

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

func (*Region) GetLeader Uses

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

func (*Region) GetPendingPeers Uses

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

func (*Region) GetRegion Uses

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

func (*Region) Marshal Uses

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

func (*Region) MarshalTo Uses

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

func (*Region) ProtoMessage Uses

func (*Region) ProtoMessage()

func (*Region) Reset Uses

func (m *Region) Reset()

func (*Region) Size Uses

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

func (*Region) String Uses

func (m *Region) String() string

func (*Region) Unmarshal Uses

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

func (*Region) XXX_DiscardUnknown Uses

func (m *Region) XXX_DiscardUnknown()

func (*Region) XXX_Marshal Uses

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

func (*Region) XXX_Merge Uses

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

func (*Region) XXX_Size Uses

func (m *Region) XXX_Size() int

func (*Region) XXX_Unmarshal Uses

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

type RegionHeartbeatRequest Uses

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 Uses

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

func (*RegionHeartbeatRequest) GetApproximateKeys Uses

func (m *RegionHeartbeatRequest) GetApproximateKeys() uint64

func (*RegionHeartbeatRequest) GetApproximateSize Uses

func (m *RegionHeartbeatRequest) GetApproximateSize() uint64

func (*RegionHeartbeatRequest) GetBytesRead Uses

func (m *RegionHeartbeatRequest) GetBytesRead() uint64

func (*RegionHeartbeatRequest) GetBytesWritten Uses

func (m *RegionHeartbeatRequest) GetBytesWritten() uint64

func (*RegionHeartbeatRequest) GetDownPeers Uses

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

func (*RegionHeartbeatRequest) GetHeader Uses

func (m *RegionHeartbeatRequest) GetHeader() *RequestHeader

func (*RegionHeartbeatRequest) GetInterval Uses

func (m *RegionHeartbeatRequest) GetInterval() *TimeInterval

func (*RegionHeartbeatRequest) GetKeysRead Uses

func (m *RegionHeartbeatRequest) GetKeysRead() uint64

func (*RegionHeartbeatRequest) GetKeysWritten Uses

func (m *RegionHeartbeatRequest) GetKeysWritten() uint64

func (*RegionHeartbeatRequest) GetLeader Uses

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

func (*RegionHeartbeatRequest) GetPendingPeers Uses

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

func (*RegionHeartbeatRequest) GetRegion Uses

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

func (*RegionHeartbeatRequest) GetReplicationStatus Uses

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

func (*RegionHeartbeatRequest) GetTerm Uses

func (m *RegionHeartbeatRequest) GetTerm() uint64

func (*RegionHeartbeatRequest) Marshal Uses

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

func (*RegionHeartbeatRequest) MarshalTo Uses

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

func (*RegionHeartbeatRequest) ProtoMessage Uses

func (*RegionHeartbeatRequest) ProtoMessage()

func (*RegionHeartbeatRequest) Reset Uses

func (m *RegionHeartbeatRequest) Reset()

func (*RegionHeartbeatRequest) Size Uses

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

func (*RegionHeartbeatRequest) String Uses

func (m *RegionHeartbeatRequest) String() string

func (*RegionHeartbeatRequest) Unmarshal Uses

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

func (*RegionHeartbeatRequest) XXX_DiscardUnknown Uses

func (m *RegionHeartbeatRequest) XXX_DiscardUnknown()

func (*RegionHeartbeatRequest) XXX_Marshal Uses

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

func (*RegionHeartbeatRequest) XXX_Merge Uses

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

func (*RegionHeartbeatRequest) XXX_Size Uses

func (m *RegionHeartbeatRequest) XXX_Size() int

func (*RegionHeartbeatRequest) XXX_Unmarshal Uses

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

type RegionHeartbeatResponse Uses

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 Uses

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

func (*RegionHeartbeatResponse) GetChangePeer Uses

func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer

func (*RegionHeartbeatResponse) GetChangePeerV2 Uses

func (m *RegionHeartbeatResponse) GetChangePeerV2() *ChangePeerV2

func (*RegionHeartbeatResponse) GetHeader Uses

func (m *RegionHeartbeatResponse) GetHeader() *ResponseHeader

func (*RegionHeartbeatResponse) GetMerge Uses

func (m *RegionHeartbeatResponse) GetMerge() *Merge

func (*RegionHeartbeatResponse) GetRegionEpoch Uses

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

func (*RegionHeartbeatResponse) GetRegionId Uses

func (m *RegionHeartbeatResponse) GetRegionId() uint64

func (*RegionHeartbeatResponse) GetSplitRegion Uses

func (m *RegionHeartbeatResponse) GetSplitRegion() *SplitRegion

func (*RegionHeartbeatResponse) GetTargetPeer Uses

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

func (*RegionHeartbeatResponse) GetTransferLeader Uses

func (m *RegionHeartbeatResponse) GetTransferLeader() *TransferLeader

func (*RegionHeartbeatResponse) Marshal Uses

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

func (*RegionHeartbeatResponse) MarshalTo Uses

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

func (*RegionHeartbeatResponse) ProtoMessage Uses

func (*RegionHeartbeatResponse) ProtoMessage()

func (*RegionHeartbeatResponse) Reset Uses

func (m *RegionHeartbeatResponse) Reset()

func (*RegionHeartbeatResponse) Size Uses

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

func (*RegionHeartbeatResponse) String Uses

func (m *RegionHeartbeatResponse) String() string

func (*RegionHeartbeatResponse) Unmarshal Uses

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

func (*RegionHeartbeatResponse) XXX_DiscardUnknown Uses

func (m *RegionHeartbeatResponse) XXX_DiscardUnknown()

func (*RegionHeartbeatResponse) XXX_Marshal Uses

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

func (*RegionHeartbeatResponse) XXX_Merge Uses

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

func (*RegionHeartbeatResponse) XXX_Size Uses

func (m *RegionHeartbeatResponse) XXX_Size() int

func (*RegionHeartbeatResponse) XXX_Unmarshal Uses

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

type RegionStat Uses

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 Uses

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

func (*RegionStat) GetBytesRead Uses

func (m *RegionStat) GetBytesRead() uint64

func (*RegionStat) GetBytesWritten Uses

func (m *RegionStat) GetBytesWritten() uint64

func (*RegionStat) GetKeysRead Uses

func (m *RegionStat) GetKeysRead() uint64

func (*RegionStat) GetKeysWritten Uses

func (m *RegionStat) GetKeysWritten() uint64

func (*RegionStat) Marshal Uses

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

func (*RegionStat) MarshalTo Uses

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

func (*RegionStat) ProtoMessage Uses

func (*RegionStat) ProtoMessage()

func (*RegionStat) Reset Uses

func (m *RegionStat) Reset()

func (*RegionStat) Size Uses

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

func (*RegionStat) String Uses

func (m *RegionStat) String() string

func (*RegionStat) Unmarshal Uses

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

func (*RegionStat) XXX_DiscardUnknown Uses

func (m *RegionStat) XXX_DiscardUnknown()

func (*RegionStat) XXX_Marshal Uses

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

func (*RegionStat) XXX_Merge Uses

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

func (*RegionStat) XXX_Size Uses

func (m *RegionStat) XXX_Size() int

func (*RegionStat) XXX_Unmarshal Uses

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

type ReportBatchSplitRequest Uses

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 Uses

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

func (*ReportBatchSplitRequest) GetHeader Uses

func (m *ReportBatchSplitRequest) GetHeader() *RequestHeader

func (*ReportBatchSplitRequest) GetRegions Uses

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

func (*ReportBatchSplitRequest) Marshal Uses

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

func (*ReportBatchSplitRequest) MarshalTo Uses

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

func (*ReportBatchSplitRequest) ProtoMessage Uses

func (*ReportBatchSplitRequest) ProtoMessage()

func (*ReportBatchSplitRequest) Reset Uses

func (m *ReportBatchSplitRequest) Reset()

func (*ReportBatchSplitRequest) Size Uses

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

func (*ReportBatchSplitRequest) String Uses

func (m *ReportBatchSplitRequest) String() string

func (*ReportBatchSplitRequest) Unmarshal Uses

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

func (*ReportBatchSplitRequest) XXX_DiscardUnknown Uses

func (m *ReportBatchSplitRequest) XXX_DiscardUnknown()

func (*ReportBatchSplitRequest) XXX_Marshal Uses

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

func (*ReportBatchSplitRequest) XXX_Merge Uses

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

func (*ReportBatchSplitRequest) XXX_Size Uses

func (m *ReportBatchSplitRequest) XXX_Size() int

func (*ReportBatchSplitRequest) XXX_Unmarshal Uses

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

type ReportBatchSplitResponse Uses

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 Uses

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

func (*ReportBatchSplitResponse) GetHeader Uses

func (m *ReportBatchSplitResponse) GetHeader() *ResponseHeader

func (*ReportBatchSplitResponse) Marshal Uses

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

func (*ReportBatchSplitResponse) MarshalTo Uses

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

func (*ReportBatchSplitResponse) ProtoMessage Uses

func (*ReportBatchSplitResponse) ProtoMessage()

func (*ReportBatchSplitResponse) Reset Uses

func (m *ReportBatchSplitResponse) Reset()

func (*ReportBatchSplitResponse) Size Uses

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

func (*ReportBatchSplitResponse) String Uses

func (m *ReportBatchSplitResponse) String() string

func (*ReportBatchSplitResponse) Unmarshal Uses

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

func (*ReportBatchSplitResponse) XXX_DiscardUnknown Uses

func (m *ReportBatchSplitResponse) XXX_DiscardUnknown()

func (*ReportBatchSplitResponse) XXX_Marshal Uses

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

func (*ReportBatchSplitResponse) XXX_Merge Uses

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

func (*ReportBatchSplitResponse) XXX_Size Uses

func (m *ReportBatchSplitResponse) XXX_Size() int

func (*ReportBatchSplitResponse) XXX_Unmarshal Uses

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

type ReportSplitRequest Uses

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 Uses

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

func (*ReportSplitRequest) GetHeader Uses

func (m *ReportSplitRequest) GetHeader() *RequestHeader

func (*ReportSplitRequest) GetLeft Uses

func (m *ReportSplitRequest) GetLeft() *metapb.Region

func (*ReportSplitRequest) GetRight Uses

func (m *ReportSplitRequest) GetRight() *metapb.Region

func (*ReportSplitRequest) Marshal Uses

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

func (*ReportSplitRequest) MarshalTo Uses

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

func (*ReportSplitRequest) ProtoMessage Uses

func (*ReportSplitRequest) ProtoMessage()

func (*ReportSplitRequest) Reset Uses

func (m *ReportSplitRequest) Reset()

func (*ReportSplitRequest) Size Uses

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

func (*ReportSplitRequest) String Uses

func (m *ReportSplitRequest) String() string

func (*ReportSplitRequest) Unmarshal Uses

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

func (*ReportSplitRequest) XXX_DiscardUnknown Uses

func (m *ReportSplitRequest) XXX_DiscardUnknown()

func (*ReportSplitRequest) XXX_Marshal Uses

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

func (*ReportSplitRequest) XXX_Merge Uses

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

func (*ReportSplitRequest) XXX_Size Uses

func (m *ReportSplitRequest) XXX_Size() int

func (*ReportSplitRequest) XXX_Unmarshal Uses

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

type ReportSplitResponse Uses

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 Uses

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

func (*ReportSplitResponse) GetHeader Uses

func (m *ReportSplitResponse) GetHeader() *ResponseHeader

func (*ReportSplitResponse) Marshal Uses

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

func (*ReportSplitResponse) MarshalTo Uses

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

func (*ReportSplitResponse) ProtoMessage Uses

func (*ReportSplitResponse) ProtoMessage()

func (*ReportSplitResponse) Reset Uses

func (m *ReportSplitResponse) Reset()

func (*ReportSplitResponse) Size Uses

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

func (*ReportSplitResponse) String Uses

func (m *ReportSplitResponse) String() string

func (*ReportSplitResponse) Unmarshal Uses

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

func (*ReportSplitResponse) XXX_DiscardUnknown Uses

func (m *ReportSplitResponse) XXX_DiscardUnknown()

func (*ReportSplitResponse) XXX_Marshal Uses

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

func (*ReportSplitResponse) XXX_Merge Uses

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

func (*ReportSplitResponse) XXX_Size Uses

func (m *ReportSplitResponse) XXX_Size() int

func (*ReportSplitResponse) XXX_Unmarshal Uses

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

type RequestHeader Uses

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

func (*RequestHeader) Descriptor Uses

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

func (*RequestHeader) GetClusterId Uses

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) Marshal Uses

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

func (*RequestHeader) MarshalTo Uses

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

func (*RequestHeader) ProtoMessage Uses

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset Uses

func (m *RequestHeader) Reset()

func (*RequestHeader) Size Uses

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

func (*RequestHeader) String Uses

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal Uses

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

func (*RequestHeader) XXX_DiscardUnknown Uses

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal Uses

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

func (*RequestHeader) XXX_Merge Uses

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

func (*RequestHeader) XXX_Size Uses

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal Uses

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

type ResponseHeader Uses

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 Uses

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

func (*ResponseHeader) GetClusterId Uses

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError Uses

func (m *ResponseHeader) GetError() *Error

func (*ResponseHeader) Marshal Uses

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

func (*ResponseHeader) MarshalTo Uses

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

func (*ResponseHeader) ProtoMessage Uses

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset Uses

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size Uses

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

func (*ResponseHeader) String Uses

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal Uses

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

func (*ResponseHeader) XXX_DiscardUnknown Uses

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal Uses

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

func (*ResponseHeader) XXX_Merge Uses

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

func (*ResponseHeader) XXX_Size Uses

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal Uses

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

type ScanRegionsRequest Uses

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 Uses

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

func (*ScanRegionsRequest) GetEndKey Uses

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

func (*ScanRegionsRequest) GetHeader Uses

func (m *ScanRegionsRequest) GetHeader() *RequestHeader

func (*ScanRegionsRequest) GetLimit Uses

func (m *ScanRegionsRequest) GetLimit() int32

func (*ScanRegionsRequest) GetStartKey Uses

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

func (*ScanRegionsRequest) Marshal Uses

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

func (*ScanRegionsRequest) MarshalTo Uses

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

func (*ScanRegionsRequest) ProtoMessage Uses

func (*ScanRegionsRequest) ProtoMessage()

func (*ScanRegionsRequest) Reset Uses

func (m *ScanRegionsRequest) Reset()

func (*ScanRegionsRequest) Size Uses

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

func (*ScanRegionsRequest) String Uses

func (m *ScanRegionsRequest) String() string

func (*ScanRegionsRequest) Unmarshal Uses

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

func (*ScanRegionsRequest) XXX_DiscardUnknown Uses

func (m *ScanRegionsRequest) XXX_DiscardUnknown()

func (*ScanRegionsRequest) XXX_Marshal Uses

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

func (*ScanRegionsRequest) XXX_Merge Uses

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

func (*ScanRegionsRequest) XXX_Size Uses

func (m *ScanRegionsRequest) XXX_Size() int

func (*ScanRegionsRequest) XXX_Unmarshal Uses

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

type ScanRegionsResponse Uses

type ScanRegionsResponse struct {
    Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
    // Keep for backword compatibability.
    RegionMetas []*metapb.Region `protobuf:"bytes,2,rep,name=region_metas,json=regionMetas" json:"region_metas,omitempty"`
    Leaders     []*metapb.Peer   `protobuf:"bytes,3,rep,name=leaders" json:"leaders,omitempty"`
    // Extended region info with down/pending peers.
    Regions              []*Region `protobuf:"bytes,4,rep,name=regions" json:"regions,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*ScanRegionsResponse) Descriptor Uses

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

func (*ScanRegionsResponse) GetHeader Uses

func (m *ScanRegionsResponse) GetHeader() *ResponseHeader

func (*ScanRegionsResponse) GetLeaders Uses

func (m *ScanRegionsResponse) GetLeaders() []*metapb.Peer

func (*ScanRegionsResponse) GetRegionMetas Uses

func (m *ScanRegionsResponse) GetRegionMetas() []*metapb.Region

func (*ScanRegionsResponse) GetRegions Uses

func (m *ScanRegionsResponse) GetRegions() []*Region

func (*ScanRegionsResponse) Marshal Uses

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

func (*ScanRegionsResponse) MarshalTo Uses

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

func (*ScanRegionsResponse) ProtoMessage Uses

func (*ScanRegionsResponse) ProtoMessage()

func (*ScanRegionsResponse) Reset Uses

func (m *ScanRegionsResponse) Reset()

func (*ScanRegionsResponse) Size Uses

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

func (*ScanRegionsResponse) String Uses

func (m *ScanRegionsResponse) String() string

func (*ScanRegionsResponse) Unmarshal Uses

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

func (*ScanRegionsResponse) XXX_DiscardUnknown Uses

func (m *ScanRegionsResponse) XXX_DiscardUnknown()

func (*ScanRegionsResponse) XXX_Marshal Uses

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

func (*ScanRegionsResponse) XXX_Merge Uses

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

func (*ScanRegionsResponse) XXX_Size Uses

func (m *ScanRegionsResponse) XXX_Size() int

func (*ScanRegionsResponse) XXX_Unmarshal Uses

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

type ScatterRegionRequest Uses

type ScatterRegionRequest 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"`
    // PD will use these region information if it can't find the region.
    // For example, the region is just split and hasn't report to PD yet.
    Region *metapb.Region `protobuf:"bytes,3,opt,name=region" json:"region,omitempty"`
    Leader *metapb.Peer   `protobuf:"bytes,4,opt,name=leader" json:"leader,omitempty"`
    // If group is defined, the regions with the same group would be scattered as a whole group.
    // If not defined, the regions would be scattered in a cluster level.
    Group                string   `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*ScatterRegionRequest) Descriptor Uses

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

func (*ScatterRegionRequest) GetGroup Uses

func (m *ScatterRegionRequest) GetGroup() string

func (*ScatterRegionRequest) GetHeader Uses

func (m *ScatterRegionRequest) GetHeader() *RequestHeader

func (*ScatterRegionRequest) GetLeader Uses

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

func (*ScatterRegionRequest) GetRegion Uses

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

func (*ScatterRegionRequest) GetRegionId Uses

func (m *ScatterRegionRequest) GetRegionId() uint64

func (*ScatterRegionRequest) Marshal Uses

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

func (*ScatterRegionRequest) MarshalTo Uses

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

func (*ScatterRegionRequest) ProtoMessage Uses

func (*ScatterRegionRequest) ProtoMessage()

func (*ScatterRegionRequest) Reset Uses

func (m *ScatterRegionRequest) Reset()

func (*ScatterRegionRequest) Size Uses

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

func (*ScatterRegionRequest) String Uses

func (m *ScatterRegionRequest) String() string

func (*ScatterRegionRequest) Unmarshal Uses

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

func (*ScatterRegionRequest) XXX_DiscardUnknown Uses

func (m *ScatterRegionRequest) XXX_DiscardUnknown()

func (*ScatterRegionRequest) XXX_Marshal Uses

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

func (*ScatterRegionRequest) XXX_Merge Uses

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

func (*ScatterRegionRequest) XXX_Size Uses

func (m *ScatterRegionRequest) XXX_Size() int

func (*ScatterRegionRequest) XXX_Unmarshal Uses

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

type ScatterRegionResponse Uses

type ScatterRegionResponse 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 (*ScatterRegionResponse) Descriptor Uses

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

func (*ScatterRegionResponse) GetHeader Uses

func (m *ScatterRegionResponse) GetHeader() *ResponseHeader

func (*ScatterRegionResponse) Marshal Uses

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

func (*ScatterRegionResponse) MarshalTo Uses

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

func (*ScatterRegionResponse) ProtoMessage Uses

func (*ScatterRegionResponse) ProtoMessage()

func (*ScatterRegionResponse) Reset Uses

func (m *ScatterRegionResponse) Reset()

func (*ScatterRegionResponse) Size Uses

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

func (*ScatterRegionResponse) String Uses

func (m *ScatterRegionResponse) String() string

func (*ScatterRegionResponse) Unmarshal Uses

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

func (*ScatterRegionResponse) XXX_DiscardUnknown Uses

func (m *ScatterRegionResponse) XXX_DiscardUnknown()

func (*ScatterRegionResponse) XXX_Marshal Uses

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

func (*ScatterRegionResponse) XXX_Merge Uses

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

func (*ScatterRegionResponse) XXX_Size Uses

func (m *ScatterRegionResponse) XXX_Size() int

func (*ScatterRegionResponse) XXX_Unmarshal Uses

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

type SplitID Uses

type SplitID struct {
    NewRegionId          uint64   `protobuf:"varint,1,opt,name=new_region_id,json=newRegionId,proto3" json:"new_region_id,omitempty"`
    NewPeerIds           []uint64 `protobuf:"varint,2,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 (*SplitID) Descriptor Uses

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

func (*SplitID) GetNewPeerIds Uses

func (m *SplitID) GetNewPeerIds() []uint64

func (*SplitID) GetNewRegionId Uses

func (m *SplitID) GetNewRegionId() uint64

func (*SplitID) Marshal Uses

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

func (*SplitID) MarshalTo Uses

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

func (*SplitID) ProtoMessage Uses

func (*SplitID) ProtoMessage()

func (*SplitID) Reset Uses

func (m *SplitID) Reset()

func (*SplitID) Size Uses

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

func (*SplitID) String Uses

func (m *SplitID) String() string

func (*SplitID) Unmarshal Uses

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

func (*SplitID) XXX_DiscardUnknown Uses

func (m *SplitID) XXX_DiscardUnknown()

func (*SplitID) XXX_Marshal Uses

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

func (*SplitID) XXX_Merge Uses

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

func (*SplitID) XXX_Size Uses

func (m *SplitID) XXX_Size() int

func (*SplitID) XXX_Unmarshal Uses

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

type SplitRegion Uses

type SplitRegion struct {
    Policy               CheckPolicy `protobuf:"varint,1,opt,name=policy,proto3,enum=pdpb.CheckPolicy" json:"policy,omitempty"`
    Keys                 [][]byte    `protobuf:"bytes,2,rep,name=keys" json:"keys,omitempty"`
    XXX_NoUnkeyedLiteral struct{}    `json:"-"`
    XXX_unrecognized     []byte      `json:"-"`
    XXX_sizecache        int32       `json:"-"`
}

func (*SplitRegion) Descriptor Uses

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

func (*SplitRegion) GetKeys Uses

func (m *SplitRegion) GetKeys() [][]byte

func (*SplitRegion) GetPolicy Uses

func (m *SplitRegion) GetPolicy() CheckPolicy

func (*SplitRegion) Marshal Uses

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

func (*SplitRegion) MarshalTo Uses

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

func (*SplitRegion) ProtoMessage Uses

func (*SplitRegion) ProtoMessage()

func (*SplitRegion) Reset Uses

func (m *SplitRegion) Reset()

func (*SplitRegion) Size Uses

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

func (*SplitRegion) String Uses

func (m *SplitRegion) String() string

func (*SplitRegion) Unmarshal Uses

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

func (*SplitRegion) XXX_DiscardUnknown Uses

func (m *SplitRegion) XXX_DiscardUnknown()

func (*SplitRegion) XXX_Marshal Uses

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

func (*SplitRegion) XXX_Merge Uses

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

func (*SplitRegion) XXX_Size Uses

func (m *SplitRegion) XXX_Size() int

func (*SplitRegion) XXX_Unmarshal Uses

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

type StoreHeartbeatRequest Uses

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

func (*StoreHeartbeatRequest) Descriptor Uses

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

func (*StoreHeartbeatRequest) GetHeader Uses

func (m *StoreHeartbeatRequest) GetHeader() *RequestHeader

func (*StoreHeartbeatRequest) GetStats Uses

func (m *StoreHeartbeatRequest) GetStats() *StoreStats

func (*StoreHeartbeatRequest) Marshal Uses

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

func (*StoreHeartbeatRequest) MarshalTo Uses

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

func (*StoreHeartbeatRequest) ProtoMessage Uses

func (*StoreHeartbeatRequest) ProtoMessage()

func (*StoreHeartbeatRequest) Reset Uses

func (m *StoreHeartbeatRequest) Reset()

func (*StoreHeartbeatRequest) Size Uses

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

func (*StoreHeartbeatRequest) String Uses

func (m *StoreHeartbeatRequest) String() string

func (*StoreHeartbeatRequest) Unmarshal Uses

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

func (*StoreHeartbeatRequest) XXX_DiscardUnknown Uses

func (m *StoreHeartbeatRequest) XXX_DiscardUnknown()

func (*StoreHeartbeatRequest) XXX_Marshal Uses

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

func (*StoreHeartbeatRequest) XXX_Merge Uses

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

func (*StoreHeartbeatRequest) XXX_Size Uses

func (m *StoreHeartbeatRequest) XXX_Size() int

func (*StoreHeartbeatRequest) XXX_Unmarshal Uses

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

type StoreHeartbeatResponse Uses

type StoreHeartbeatResponse 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"`
    ClusterVersion       string                                `protobuf:"bytes,3,opt,name=cluster_version,json=clusterVersion,proto3" json:"cluster_version,omitempty"`
    XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
    XXX_unrecognized     []byte                                `json:"-"`
    XXX_sizecache        int32                                 `json:"-"`
}

func (*StoreHeartbeatResponse) Descriptor Uses

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

func (*StoreHeartbeatResponse) GetClusterVersion Uses

func (m *StoreHeartbeatResponse) GetClusterVersion() string

func (*StoreHeartbeatResponse) GetHeader Uses

func (m *StoreHeartbeatResponse) GetHeader() *ResponseHeader

func (*StoreHeartbeatResponse) GetReplicationStatus Uses

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

func (*StoreHeartbeatResponse) Marshal Uses

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

func (*StoreHeartbeatResponse) MarshalTo Uses

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

func (*StoreHeartbeatResponse) ProtoMessage Uses

func (*StoreHeartbeatResponse) ProtoMessage()

func (*StoreHeartbeatResponse) Reset Uses

func (m *StoreHeartbeatResponse) Reset()

func (*StoreHeartbeatResponse) Size Uses

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

func (*StoreHeartbeatResponse) String Uses

func (m *StoreHeartbeatResponse) String() string

func (*StoreHeartbeatResponse) Unmarshal Uses

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

func (*StoreHeartbeatResponse) XXX_DiscardUnknown Uses

func (m *StoreHeartbeatResponse) XXX_DiscardUnknown()

func (*StoreHeartbeatResponse) XXX_Marshal Uses

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

func (*StoreHeartbeatResponse) XXX_Merge Uses

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

func (*StoreHeartbeatResponse) XXX_Size Uses

func (m *StoreHeartbeatResponse) XXX_Size() int

func (*StoreHeartbeatResponse) XXX_Unmarshal Uses

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

type StoreStats Uses

type StoreStats struct {
    StoreId uint64 `protobuf:"varint,1,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
    // Capacity for the store.
    Capacity uint64 `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
    // Available size for the store.
    Available uint64 `protobuf:"varint,3,opt,name=available,proto3" json:"available,omitempty"`
    // Total region count in this store.
    RegionCount uint32 `protobuf:"varint,4,opt,name=region_count,json=regionCount,proto3" json:"region_count,omitempty"`
    // Current sending snapshot count.
    SendingSnapCount uint32 `protobuf:"varint,5,opt,name=sending_snap_count,json=sendingSnapCount,proto3" json:"sending_snap_count,omitempty"`
    // Current receiving snapshot count.
    ReceivingSnapCount uint32 `protobuf:"varint,6,opt,name=receiving_snap_count,json=receivingSnapCount,proto3" json:"receiving_snap_count,omitempty"`
    // When the store is started (unix timestamp in seconds).
    StartTime uint32 `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
    // How many region is applying snapshot.
    ApplyingSnapCount uint32 `protobuf:"varint,8,opt,name=applying_snap_count,json=applyingSnapCount,proto3" json:"applying_snap_count,omitempty"`
    // If the store is busy
    IsBusy bool `protobuf:"varint,9,opt,name=is_busy,json=isBusy,proto3" json:"is_busy,omitempty"`
    // Actually used space by db
    UsedSize uint64 `protobuf:"varint,10,opt,name=used_size,json=usedSize,proto3" json:"used_size,omitempty"`
    // Bytes written for the store during this period.
    BytesWritten uint64 `protobuf:"varint,11,opt,name=bytes_written,json=bytesWritten,proto3" json:"bytes_written,omitempty"`
    // Keys written for the store during this period.
    KeysWritten uint64 `protobuf:"varint,12,opt,name=keys_written,json=keysWritten,proto3" json:"keys_written,omitempty"`
    // Bytes read for the store during this period.
    BytesRead uint64 `protobuf:"varint,13,opt,name=bytes_read,json=bytesRead,proto3" json:"bytes_read,omitempty"`
    // Keys read for the store during this period.
    KeysRead uint64 `protobuf:"varint,14,opt,name=keys_read,json=keysRead,proto3" json:"keys_read,omitempty"`
    // Actually reported time interval
    Interval *TimeInterval `protobuf:"bytes,15,opt,name=interval" json:"interval,omitempty"`
    // Threads' CPU usages in the store
    CpuUsages []*RecordPair `protobuf:"bytes,16,rep,name=cpu_usages,json=cpuUsages" json:"cpu_usages,omitempty"`
    // Threads' read disk I/O rates in the store
    ReadIoRates []*RecordPair `protobuf:"bytes,17,rep,name=read_io_rates,json=readIoRates" json:"read_io_rates,omitempty"`
    // Threads' write disk I/O rates in the store
    WriteIoRates []*RecordPair `protobuf:"bytes,18,rep,name=write_io_rates,json=writeIoRates" json:"write_io_rates,omitempty"`
    // Operations' latencies in the store
    OpLatencies          []*RecordPair `protobuf:"bytes,19,rep,name=op_latencies,json=opLatencies" json:"op_latencies,omitempty"`
    XXX_NoUnkeyedLiteral struct{}      `json:"-"`
    XXX_unrecognized     []byte        `json:"-"`
    XXX_sizecache        int32         `json:"-"`
}

func (*StoreStats) Descriptor Uses

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

func (*StoreStats) GetApplyingSnapCount Uses

func (m *StoreStats) GetApplyingSnapCount() uint32

func (*StoreStats) GetAvailable Uses

func (m *StoreStats) GetAvailable() uint64

func (*StoreStats) GetBytesRead Uses

func (m *StoreStats) GetBytesRead() uint64

func (*StoreStats) GetBytesWritten Uses

func (m *StoreStats) GetBytesWritten() uint64

func (*StoreStats) GetCapacity Uses

func (m *StoreStats) GetCapacity() uint64

func (*StoreStats) GetCpuUsages Uses

func (m *StoreStats) GetCpuUsages() []*RecordPair

func (*StoreStats) GetInterval Uses

func (m *StoreStats) GetInterval() *TimeInterval

func (*StoreStats) GetIsBusy Uses

func (m *StoreStats) GetIsBusy() bool

func (*StoreStats) GetKeysRead Uses

func (m *StoreStats) GetKeysRead() uint64

func (*StoreStats) GetKeysWritten Uses

func (m *StoreStats) GetKeysWritten() uint64

func (*StoreStats) GetOpLatencies Uses

func (m *StoreStats) GetOpLatencies() []*RecordPair

func (*StoreStats) GetReadIoRates Uses

func (m *StoreStats) GetReadIoRates() []*RecordPair

func (*StoreStats) GetReceivingSnapCount Uses

func (m *StoreStats) GetReceivingSnapCount() uint32

func (*StoreStats) GetRegionCount Uses

func (m *StoreStats) GetRegionCount() uint32

func (*StoreStats) GetSendingSnapCount Uses

func (m *StoreStats) GetSendingSnapCount() uint32

func (*StoreStats) GetStartTime Uses

func (m *StoreStats) GetStartTime() uint32

func (*StoreStats) GetStoreId Uses

func (m *StoreStats) GetStoreId() uint64

func (*StoreStats) GetUsedSize Uses

func (m *StoreStats) GetUsedSize() uint64

func (*StoreStats) GetWriteIoRates Uses

func (m *StoreStats) GetWriteIoRates() []*RecordPair

func (*StoreStats) Marshal Uses

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

func (*StoreStats) MarshalTo Uses

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

func (*StoreStats) ProtoMessage Uses

func (*StoreStats) ProtoMessage()

func (*StoreStats) Reset Uses

func (m *StoreStats) Reset()

func (*StoreStats) Size Uses

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

func (*StoreStats) String Uses

func (m *StoreStats) String() string

func (*StoreStats) Unmarshal Uses

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

func (*StoreStats) XXX_DiscardUnknown Uses

func (m *StoreStats) XXX_DiscardUnknown()

func (*StoreStats) XXX_Marshal Uses

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

func (*StoreStats) XXX_Merge Uses

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

func (*StoreStats) XXX_Size Uses

func (m *StoreStats) XXX_Size() int

func (*StoreStats) XXX_Unmarshal Uses

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

type SyncRegionRequest Uses

type SyncRegionRequest struct {
    Header *RequestHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
    Member *Member        `protobuf:"bytes,2,opt,name=member" json:"member,omitempty"`
    // the follower PD will use the start index to locate historical changes
    // that require synchronization.
    StartIndex           uint64   `protobuf:"varint,3,opt,name=start_index,json=startIndex,proto3" json:"start_index,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*SyncRegionRequest) Descriptor Uses

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

func (*SyncRegionRequest) GetHeader Uses

func (m *SyncRegionRequest) GetHeader() *RequestHeader

func (*SyncRegionRequest) GetMember Uses

func (m *SyncRegionRequest) GetMember() *Member

func (*SyncRegionRequest) GetStartIndex Uses

func (m *SyncRegionRequest) GetStartIndex() uint64

func (*SyncRegionRequest) Marshal Uses

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

func (*SyncRegionRequest) MarshalTo Uses

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

func (*SyncRegionRequest) ProtoMessage Uses

func (*SyncRegionRequest) ProtoMessage()

func (*SyncRegionRequest) Reset Uses

func (m *SyncRegionRequest) Reset()

func (*SyncRegionRequest) Size Uses

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

func (*SyncRegionRequest) String Uses

func (m *SyncRegionRequest) String() string

func (*SyncRegionRequest) Unmarshal Uses

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

func (*SyncRegionRequest) XXX_DiscardUnknown Uses

func (m *SyncRegionRequest) XXX_DiscardUnknown()

func (*SyncRegionRequest) XXX_Marshal Uses

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

func (*SyncRegionRequest) XXX_Merge Uses

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

func (*SyncRegionRequest) XXX_Size Uses

func (m *SyncRegionRequest) XXX_Size() int

func (*SyncRegionRequest) XXX_Unmarshal Uses

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

type SyncRegionResponse Uses

type SyncRegionResponse struct {
    Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
    // the leader PD will send the repsonds include
    // changed regions records and the index of the first record.
    Regions              []*metapb.Region `protobuf:"bytes,2,rep,name=regions" json:"regions,omitempty"`
    StartIndex           uint64           `protobuf:"varint,3,opt,name=start_index,json=startIndex,proto3" json:"start_index,omitempty"`
    RegionStats          []*RegionStat    `protobuf:"bytes,4,rep,name=region_stats,json=regionStats" json:"region_stats,omitempty"`
    RegionLeaders        []*metapb.Peer   `protobuf:"bytes,5,rep,name=region_leaders,json=regionLeaders" json:"region_leaders,omitempty"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

func (*SyncRegionResponse) Descriptor Uses

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

func (*SyncRegionResponse) GetHeader Uses

func (m *SyncRegionResponse) GetHeader() *ResponseHeader

func (*SyncRegionResponse) GetRegionLeaders Uses

func (m *SyncRegionResponse) GetRegionLeaders() []*metapb.Peer

func (*SyncRegionResponse) GetRegionStats Uses

func (m *SyncRegionResponse) GetRegionStats() []*RegionStat

func (*SyncRegionResponse) GetRegions Uses

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

func (*SyncRegionResponse) GetStartIndex Uses

func (m *SyncRegionResponse) GetStartIndex() uint64

func (*SyncRegionResponse) Marshal Uses

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

func (*SyncRegionResponse) MarshalTo Uses

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

func (*SyncRegionResponse) ProtoMessage Uses

func (*SyncRegionResponse) ProtoMessage()

func (*SyncRegionResponse) Reset Uses

func (m *SyncRegionResponse) Reset()

func (*SyncRegionResponse) Size Uses

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

func (*SyncRegionResponse) String Uses

func (m *SyncRegionResponse) String() string

func (*SyncRegionResponse) Unmarshal Uses

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

func (*SyncRegionResponse) XXX_DiscardUnknown Uses

func (m *SyncRegionResponse) XXX_DiscardUnknown()

func (*SyncRegionResponse) XXX_Marshal Uses

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

func (*SyncRegionResponse) XXX_Merge Uses

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

func (*SyncRegionResponse) XXX_Size Uses

func (m *SyncRegionResponse) XXX_Size() int

func (*SyncRegionResponse) XXX_Unmarshal Uses

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

type TimeInterval Uses

type TimeInterval struct {
    // The unix timestamp in seconds of the start of this period.
    StartTimestamp uint64 `protobuf:"varint,1,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
    // The unix timestamp in seconds of the end of this period.
    EndTimestamp         uint64   `protobuf:"varint,2,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*TimeInterval) Descriptor Uses

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

func (*TimeInterval) GetEndTimestamp Uses

func (m *TimeInterval) GetEndTimestamp() uint64

func (*TimeInterval) GetStartTimestamp Uses

func (m *TimeInterval) GetStartTimestamp() uint64

func (*TimeInterval) Marshal Uses

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

func (*TimeInterval) MarshalTo Uses

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

func (*TimeInterval) ProtoMessage Uses

func (*TimeInterval) ProtoMessage()

func (*TimeInterval) Reset Uses

func (m *TimeInterval) Reset()

func (*TimeInterval) Size Uses

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

func (*TimeInterval) String Uses

func (m *TimeInterval) String() string

func (*TimeInterval) Unmarshal Uses

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

func (*TimeInterval) XXX_DiscardUnknown Uses

func (m *TimeInterval) XXX_DiscardUnknown()

func (*TimeInterval) XXX_Marshal Uses

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

func (*TimeInterval) XXX_Merge Uses

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

func (*TimeInterval) XXX_Size Uses

func (m *TimeInterval) XXX_Size() int

func (*TimeInterval) XXX_Unmarshal Uses

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

type Timestamp Uses