Documentation
¶
Index ¶
- Variables
- func RegisterPDServer(s *grpc.Server, srv PDServer)
- type AllocIDRequest
- func (*AllocIDRequest) Descriptor() ([]byte, []int)
- func (m *AllocIDRequest) GetHeader() *RequestHeader
- func (m *AllocIDRequest) Marshal() (dAtA []byte, err error)
- func (m *AllocIDRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AllocIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AllocIDRequest) ProtoMessage()
- func (m *AllocIDRequest) Reset()
- func (m *AllocIDRequest) Size() (n int)
- func (m *AllocIDRequest) String() string
- func (m *AllocIDRequest) Unmarshal(dAtA []byte) error
- func (m *AllocIDRequest) XXX_DiscardUnknown()
- func (m *AllocIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AllocIDRequest) XXX_Merge(src proto.Message)
- func (m *AllocIDRequest) XXX_Size() int
- func (m *AllocIDRequest) XXX_Unmarshal(b []byte) error
- type AllocIDResponse
- func (*AllocIDResponse) Descriptor() ([]byte, []int)
- func (m *AllocIDResponse) GetHeader() *ResponseHeader
- func (m *AllocIDResponse) GetId() uint64
- func (m *AllocIDResponse) Marshal() (dAtA []byte, err error)
- func (m *AllocIDResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AllocIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AllocIDResponse) ProtoMessage()
- func (m *AllocIDResponse) Reset()
- func (m *AllocIDResponse) Size() (n int)
- func (m *AllocIDResponse) String() string
- func (m *AllocIDResponse) Unmarshal(dAtA []byte) error
- func (m *AllocIDResponse) XXX_DiscardUnknown()
- func (m *AllocIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AllocIDResponse) XXX_Merge(src proto.Message)
- func (m *AllocIDResponse) XXX_Size() int
- func (m *AllocIDResponse) XXX_Unmarshal(b []byte) error
- type AskBatchSplitRequest
- func (*AskBatchSplitRequest) Descriptor() ([]byte, []int)
- func (m *AskBatchSplitRequest) GetHeader() *RequestHeader
- func (m *AskBatchSplitRequest) GetRegion() *metapb.Region
- func (m *AskBatchSplitRequest) GetSplitCount() uint32
- func (m *AskBatchSplitRequest) Marshal() (dAtA []byte, err error)
- func (m *AskBatchSplitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AskBatchSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AskBatchSplitRequest) ProtoMessage()
- func (m *AskBatchSplitRequest) Reset()
- func (m *AskBatchSplitRequest) Size() (n int)
- func (m *AskBatchSplitRequest) String() string
- func (m *AskBatchSplitRequest) Unmarshal(dAtA []byte) error
- func (m *AskBatchSplitRequest) XXX_DiscardUnknown()
- func (m *AskBatchSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AskBatchSplitRequest) XXX_Merge(src proto.Message)
- func (m *AskBatchSplitRequest) XXX_Size() int
- func (m *AskBatchSplitRequest) XXX_Unmarshal(b []byte) error
- type AskBatchSplitResponse
- func (*AskBatchSplitResponse) Descriptor() ([]byte, []int)
- func (m *AskBatchSplitResponse) GetHeader() *ResponseHeader
- func (m *AskBatchSplitResponse) GetIds() []*SplitID
- func (m *AskBatchSplitResponse) Marshal() (dAtA []byte, err error)
- func (m *AskBatchSplitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AskBatchSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AskBatchSplitResponse) ProtoMessage()
- func (m *AskBatchSplitResponse) Reset()
- func (m *AskBatchSplitResponse) Size() (n int)
- func (m *AskBatchSplitResponse) String() string
- func (m *AskBatchSplitResponse) Unmarshal(dAtA []byte) error
- func (m *AskBatchSplitResponse) XXX_DiscardUnknown()
- func (m *AskBatchSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AskBatchSplitResponse) XXX_Merge(src proto.Message)
- func (m *AskBatchSplitResponse) XXX_Size() int
- func (m *AskBatchSplitResponse) XXX_Unmarshal(b []byte) error
- type AskSplitRequest
- func (*AskSplitRequest) Descriptor() ([]byte, []int)
- func (m *AskSplitRequest) GetHeader() *RequestHeader
- func (m *AskSplitRequest) GetRegion() *metapb.Region
- func (m *AskSplitRequest) Marshal() (dAtA []byte, err error)
- func (m *AskSplitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AskSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AskSplitRequest) ProtoMessage()
- func (m *AskSplitRequest) Reset()
- func (m *AskSplitRequest) Size() (n int)
- func (m *AskSplitRequest) String() string
- func (m *AskSplitRequest) Unmarshal(dAtA []byte) error
- func (m *AskSplitRequest) XXX_DiscardUnknown()
- func (m *AskSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AskSplitRequest) XXX_Merge(src proto.Message)
- func (m *AskSplitRequest) XXX_Size() int
- func (m *AskSplitRequest) XXX_Unmarshal(b []byte) error
- type AskSplitResponse
- func (*AskSplitResponse) Descriptor() ([]byte, []int)
- func (m *AskSplitResponse) GetHeader() *ResponseHeader
- func (m *AskSplitResponse) GetNewPeerIds() []uint64
- func (m *AskSplitResponse) GetNewRegionId() uint64
- func (m *AskSplitResponse) Marshal() (dAtA []byte, err error)
- func (m *AskSplitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AskSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AskSplitResponse) ProtoMessage()
- func (m *AskSplitResponse) Reset()
- func (m *AskSplitResponse) Size() (n int)
- func (m *AskSplitResponse) String() string
- func (m *AskSplitResponse) Unmarshal(dAtA []byte) error
- func (m *AskSplitResponse) XXX_DiscardUnknown()
- func (m *AskSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AskSplitResponse) XXX_Merge(src proto.Message)
- func (m *AskSplitResponse) XXX_Size() int
- func (m *AskSplitResponse) XXX_Unmarshal(b []byte) error
- type AwakenRegions
- func (*AwakenRegions) Descriptor() ([]byte, []int)
- func (m *AwakenRegions) GetAbnormalStores() []uint64
- func (m *AwakenRegions) Marshal() (dAtA []byte, err error)
- func (m *AwakenRegions) MarshalTo(dAtA []byte) (int, error)
- func (m *AwakenRegions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AwakenRegions) ProtoMessage()
- func (m *AwakenRegions) Reset()
- func (m *AwakenRegions) Size() (n int)
- func (m *AwakenRegions) String() string
- func (m *AwakenRegions) Unmarshal(dAtA []byte) error
- func (m *AwakenRegions) XXX_DiscardUnknown()
- func (m *AwakenRegions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AwakenRegions) XXX_Merge(src proto.Message)
- func (m *AwakenRegions) XXX_Size() int
- func (m *AwakenRegions) XXX_Unmarshal(b []byte) error
- type BatchSwitchWitness
- func (*BatchSwitchWitness) Descriptor() ([]byte, []int)
- func (m *BatchSwitchWitness) GetSwitchWitnesses() []*SwitchWitness
- func (m *BatchSwitchWitness) Marshal() (dAtA []byte, err error)
- func (m *BatchSwitchWitness) MarshalTo(dAtA []byte) (int, error)
- func (m *BatchSwitchWitness) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BatchSwitchWitness) ProtoMessage()
- func (m *BatchSwitchWitness) Reset()
- func (m *BatchSwitchWitness) Size() (n int)
- func (m *BatchSwitchWitness) String() string
- func (m *BatchSwitchWitness) Unmarshal(dAtA []byte) error
- func (m *BatchSwitchWitness) XXX_DiscardUnknown()
- func (m *BatchSwitchWitness) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BatchSwitchWitness) XXX_Merge(src proto.Message)
- func (m *BatchSwitchWitness) XXX_Size() int
- func (m *BatchSwitchWitness) XXX_Unmarshal(b []byte) error
- type BootstrapRequest
- func (*BootstrapRequest) Descriptor() ([]byte, []int)
- func (m *BootstrapRequest) GetHeader() *RequestHeader
- func (m *BootstrapRequest) GetRegion() *metapb.Region
- func (m *BootstrapRequest) GetStore() *metapb.Store
- func (m *BootstrapRequest) Marshal() (dAtA []byte, err error)
- func (m *BootstrapRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *BootstrapRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BootstrapRequest) ProtoMessage()
- func (m *BootstrapRequest) Reset()
- func (m *BootstrapRequest) Size() (n int)
- func (m *BootstrapRequest) String() string
- func (m *BootstrapRequest) Unmarshal(dAtA []byte) error
- func (m *BootstrapRequest) XXX_DiscardUnknown()
- func (m *BootstrapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BootstrapRequest) XXX_Merge(src proto.Message)
- func (m *BootstrapRequest) XXX_Size() int
- func (m *BootstrapRequest) XXX_Unmarshal(b []byte) error
- type BootstrapResponse
- func (*BootstrapResponse) Descriptor() ([]byte, []int)
- func (m *BootstrapResponse) GetHeader() *ResponseHeader
- func (m *BootstrapResponse) GetReplicationStatus() *replication_modepb.ReplicationStatus
- func (m *BootstrapResponse) Marshal() (dAtA []byte, err error)
- func (m *BootstrapResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *BootstrapResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BootstrapResponse) ProtoMessage()
- func (m *BootstrapResponse) Reset()
- func (m *BootstrapResponse) Size() (n int)
- func (m *BootstrapResponse) String() string
- func (m *BootstrapResponse) Unmarshal(dAtA []byte) error
- func (m *BootstrapResponse) XXX_DiscardUnknown()
- func (m *BootstrapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BootstrapResponse) XXX_Merge(src proto.Message)
- func (m *BootstrapResponse) XXX_Size() int
- func (m *BootstrapResponse) XXX_Unmarshal(b []byte) error
- type ChangePeer
- func (*ChangePeer) Descriptor() ([]byte, []int)
- func (m *ChangePeer) GetChangeType() eraftpb.ConfChangeType
- func (m *ChangePeer) GetPeer() *metapb.Peer
- func (m *ChangePeer) Marshal() (dAtA []byte, err error)
- func (m *ChangePeer) MarshalTo(dAtA []byte) (int, error)
- func (m *ChangePeer) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChangePeer) ProtoMessage()
- func (m *ChangePeer) Reset()
- func (m *ChangePeer) Size() (n int)
- func (m *ChangePeer) String() string
- func (m *ChangePeer) Unmarshal(dAtA []byte) error
- func (m *ChangePeer) XXX_DiscardUnknown()
- func (m *ChangePeer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChangePeer) XXX_Merge(src proto.Message)
- func (m *ChangePeer) XXX_Size() int
- func (m *ChangePeer) XXX_Unmarshal(b []byte) error
- type ChangePeerV2
- func (*ChangePeerV2) Descriptor() ([]byte, []int)
- func (m *ChangePeerV2) GetChanges() []*ChangePeer
- func (m *ChangePeerV2) Marshal() (dAtA []byte, err error)
- func (m *ChangePeerV2) MarshalTo(dAtA []byte) (int, error)
- func (m *ChangePeerV2) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChangePeerV2) ProtoMessage()
- func (m *ChangePeerV2) Reset()
- func (m *ChangePeerV2) Size() (n int)
- func (m *ChangePeerV2) String() string
- func (m *ChangePeerV2) Unmarshal(dAtA []byte) error
- func (m *ChangePeerV2) XXX_DiscardUnknown()
- func (m *ChangePeerV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChangePeerV2) XXX_Merge(src proto.Message)
- func (m *ChangePeerV2) XXX_Size() int
- func (m *ChangePeerV2) XXX_Unmarshal(b []byte) error
- type CheckPolicy
- type DemoteFailedVoters
- func (*DemoteFailedVoters) Descriptor() ([]byte, []int)
- func (m *DemoteFailedVoters) GetFailedVoters() []*metapb.Peer
- func (m *DemoteFailedVoters) GetRegionId() uint64
- func (m *DemoteFailedVoters) Marshal() (dAtA []byte, err error)
- func (m *DemoteFailedVoters) MarshalTo(dAtA []byte) (int, error)
- func (m *DemoteFailedVoters) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DemoteFailedVoters) ProtoMessage()
- func (m *DemoteFailedVoters) Reset()
- func (m *DemoteFailedVoters) Size() (n int)
- func (m *DemoteFailedVoters) String() string
- func (m *DemoteFailedVoters) Unmarshal(dAtA []byte) error
- func (m *DemoteFailedVoters) XXX_DiscardUnknown()
- func (m *DemoteFailedVoters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DemoteFailedVoters) XXX_Merge(src proto.Message)
- func (m *DemoteFailedVoters) XXX_Size() int
- func (m *DemoteFailedVoters) XXX_Unmarshal(b []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetMessage() string
- func (m *Error) GetType() ErrorType
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Error) XXX_Merge(src proto.Message)
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type ErrorType
- type EventType
- type ForceLeader
- func (*ForceLeader) Descriptor() ([]byte, []int)
- func (m *ForceLeader) GetEnterForceLeaders() []uint64
- func (m *ForceLeader) GetFailedStores() []uint64
- func (m *ForceLeader) Marshal() (dAtA []byte, err error)
- func (m *ForceLeader) MarshalTo(dAtA []byte) (int, error)
- func (m *ForceLeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ForceLeader) ProtoMessage()
- func (m *ForceLeader) Reset()
- func (m *ForceLeader) Size() (n int)
- func (m *ForceLeader) String() string
- func (m *ForceLeader) Unmarshal(dAtA []byte) error
- func (m *ForceLeader) XXX_DiscardUnknown()
- func (m *ForceLeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ForceLeader) XXX_Merge(src proto.Message)
- func (m *ForceLeader) XXX_Size() int
- func (m *ForceLeader) XXX_Unmarshal(b []byte) error
- type GetAllStoresRequest
- func (*GetAllStoresRequest) Descriptor() ([]byte, []int)
- func (m *GetAllStoresRequest) GetExcludeTombstoneStores() bool
- func (m *GetAllStoresRequest) GetHeader() *RequestHeader
- func (m *GetAllStoresRequest) Marshal() (dAtA []byte, err error)
- func (m *GetAllStoresRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetAllStoresRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetAllStoresRequest) ProtoMessage()
- func (m *GetAllStoresRequest) Reset()
- func (m *GetAllStoresRequest) Size() (n int)
- func (m *GetAllStoresRequest) String() string
- func (m *GetAllStoresRequest) Unmarshal(dAtA []byte) error
- func (m *GetAllStoresRequest) XXX_DiscardUnknown()
- func (m *GetAllStoresRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAllStoresRequest) XXX_Merge(src proto.Message)
- func (m *GetAllStoresRequest) XXX_Size() int
- func (m *GetAllStoresRequest) XXX_Unmarshal(b []byte) error
- type GetAllStoresResponse
- func (*GetAllStoresResponse) Descriptor() ([]byte, []int)
- func (m *GetAllStoresResponse) GetHeader() *ResponseHeader
- func (m *GetAllStoresResponse) GetStores() []*metapb.Store
- func (m *GetAllStoresResponse) Marshal() (dAtA []byte, err error)
- func (m *GetAllStoresResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetAllStoresResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetAllStoresResponse) ProtoMessage()
- func (m *GetAllStoresResponse) Reset()
- func (m *GetAllStoresResponse) Size() (n int)
- func (m *GetAllStoresResponse) String() string
- func (m *GetAllStoresResponse) Unmarshal(dAtA []byte) error
- func (m *GetAllStoresResponse) XXX_DiscardUnknown()
- func (m *GetAllStoresResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAllStoresResponse) XXX_Merge(src proto.Message)
- func (m *GetAllStoresResponse) XXX_Size() int
- func (m *GetAllStoresResponse) XXX_Unmarshal(b []byte) error
- type GetClusterConfigRequest
- func (*GetClusterConfigRequest) Descriptor() ([]byte, []int)
- func (m *GetClusterConfigRequest) GetHeader() *RequestHeader
- func (m *GetClusterConfigRequest) Marshal() (dAtA []byte, err error)
- func (m *GetClusterConfigRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetClusterConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetClusterConfigRequest) ProtoMessage()
- func (m *GetClusterConfigRequest) Reset()
- func (m *GetClusterConfigRequest) Size() (n int)
- func (m *GetClusterConfigRequest) String() string
- func (m *GetClusterConfigRequest) Unmarshal(dAtA []byte) error
- func (m *GetClusterConfigRequest) XXX_DiscardUnknown()
- func (m *GetClusterConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetClusterConfigRequest) XXX_Merge(src proto.Message)
- func (m *GetClusterConfigRequest) XXX_Size() int
- func (m *GetClusterConfigRequest) XXX_Unmarshal(b []byte) error
- type GetClusterConfigResponse
- func (*GetClusterConfigResponse) Descriptor() ([]byte, []int)
- func (m *GetClusterConfigResponse) GetCluster() *metapb.Cluster
- func (m *GetClusterConfigResponse) GetHeader() *ResponseHeader
- func (m *GetClusterConfigResponse) Marshal() (dAtA []byte, err error)
- func (m *GetClusterConfigResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetClusterConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetClusterConfigResponse) ProtoMessage()
- func (m *GetClusterConfigResponse) Reset()
- func (m *GetClusterConfigResponse) Size() (n int)
- func (m *GetClusterConfigResponse) String() string
- func (m *GetClusterConfigResponse) Unmarshal(dAtA []byte) error
- func (m *GetClusterConfigResponse) XXX_DiscardUnknown()
- func (m *GetClusterConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetClusterConfigResponse) XXX_Merge(src proto.Message)
- func (m *GetClusterConfigResponse) XXX_Size() int
- func (m *GetClusterConfigResponse) XXX_Unmarshal(b []byte) error
- type GetClusterInfoRequest
- func (*GetClusterInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetClusterInfoRequest) GetHeader() *ResponseHeader
- func (m *GetClusterInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetClusterInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetClusterInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetClusterInfoRequest) ProtoMessage()
- func (m *GetClusterInfoRequest) Reset()
- func (m *GetClusterInfoRequest) Size() (n int)
- func (m *GetClusterInfoRequest) String() string
- func (m *GetClusterInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetClusterInfoRequest) XXX_DiscardUnknown()
- func (m *GetClusterInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetClusterInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetClusterInfoRequest) XXX_Size() int
- func (m *GetClusterInfoRequest) XXX_Unmarshal(b []byte) error
- type GetClusterInfoResponse
- func (*GetClusterInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetClusterInfoResponse) GetHeader() *ResponseHeader
- func (m *GetClusterInfoResponse) GetServiceModes() []ServiceMode
- func (m *GetClusterInfoResponse) GetTsoUrls() []string
- func (m *GetClusterInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *GetClusterInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetClusterInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetClusterInfoResponse) ProtoMessage()
- func (m *GetClusterInfoResponse) Reset()
- func (m *GetClusterInfoResponse) Size() (n int)
- func (m *GetClusterInfoResponse) String() string
- func (m *GetClusterInfoResponse) Unmarshal(dAtA []byte) error
- func (m *GetClusterInfoResponse) XXX_DiscardUnknown()
- func (m *GetClusterInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetClusterInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetClusterInfoResponse) XXX_Size() int
- func (m *GetClusterInfoResponse) XXX_Unmarshal(b []byte) error
- type GetDCLocationInfoRequest
- func (*GetDCLocationInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetDCLocationInfoRequest) GetDcLocation() string
- func (m *GetDCLocationInfoRequest) GetHeader() *RequestHeader
- func (m *GetDCLocationInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetDCLocationInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDCLocationInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDCLocationInfoRequest) ProtoMessage()
- func (m *GetDCLocationInfoRequest) Reset()
- func (m *GetDCLocationInfoRequest) Size() (n int)
- func (m *GetDCLocationInfoRequest) String() string
- func (m *GetDCLocationInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetDCLocationInfoRequest) XXX_DiscardUnknown()
- func (m *GetDCLocationInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDCLocationInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetDCLocationInfoRequest) XXX_Size() int
- func (m *GetDCLocationInfoRequest) XXX_Unmarshal(b []byte) error
- type GetDCLocationInfoResponse
- func (*GetDCLocationInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetDCLocationInfoResponse) GetHeader() *ResponseHeader
- func (m *GetDCLocationInfoResponse) GetMaxTs() *Timestamp
- func (m *GetDCLocationInfoResponse) GetSuffix() int32
- func (m *GetDCLocationInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *GetDCLocationInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDCLocationInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDCLocationInfoResponse) ProtoMessage()
- func (m *GetDCLocationInfoResponse) Reset()
- func (m *GetDCLocationInfoResponse) Size() (n int)
- func (m *GetDCLocationInfoResponse) String() string
- func (m *GetDCLocationInfoResponse) Unmarshal(dAtA []byte) error
- func (m *GetDCLocationInfoResponse) XXX_DiscardUnknown()
- func (m *GetDCLocationInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDCLocationInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetDCLocationInfoResponse) XXX_Size() int
- func (m *GetDCLocationInfoResponse) XXX_Unmarshal(b []byte) error
- type GetExternalTimestampRequest
- func (*GetExternalTimestampRequest) Descriptor() ([]byte, []int)
- func (m *GetExternalTimestampRequest) GetHeader() *RequestHeader
- func (m *GetExternalTimestampRequest) Marshal() (dAtA []byte, err error)
- func (m *GetExternalTimestampRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetExternalTimestampRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetExternalTimestampRequest) ProtoMessage()
- func (m *GetExternalTimestampRequest) Reset()
- func (m *GetExternalTimestampRequest) Size() (n int)
- func (m *GetExternalTimestampRequest) String() string
- func (m *GetExternalTimestampRequest) Unmarshal(dAtA []byte) error
- func (m *GetExternalTimestampRequest) XXX_DiscardUnknown()
- func (m *GetExternalTimestampRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetExternalTimestampRequest) XXX_Merge(src proto.Message)
- func (m *GetExternalTimestampRequest) XXX_Size() int
- func (m *GetExternalTimestampRequest) XXX_Unmarshal(b []byte) error
- type GetExternalTimestampResponse
- func (*GetExternalTimestampResponse) Descriptor() ([]byte, []int)
- func (m *GetExternalTimestampResponse) GetHeader() *ResponseHeader
- func (m *GetExternalTimestampResponse) GetTimestamp() uint64
- func (m *GetExternalTimestampResponse) Marshal() (dAtA []byte, err error)
- func (m *GetExternalTimestampResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetExternalTimestampResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetExternalTimestampResponse) ProtoMessage()
- func (m *GetExternalTimestampResponse) Reset()
- func (m *GetExternalTimestampResponse) Size() (n int)
- func (m *GetExternalTimestampResponse) String() string
- func (m *GetExternalTimestampResponse) Unmarshal(dAtA []byte) error
- func (m *GetExternalTimestampResponse) XXX_DiscardUnknown()
- func (m *GetExternalTimestampResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetExternalTimestampResponse) XXX_Merge(src proto.Message)
- func (m *GetExternalTimestampResponse) XXX_Size() int
- func (m *GetExternalTimestampResponse) XXX_Unmarshal(b []byte) error
- type GetGCSafePointRequest
- func (*GetGCSafePointRequest) Descriptor() ([]byte, []int)
- func (m *GetGCSafePointRequest) GetHeader() *RequestHeader
- func (m *GetGCSafePointRequest) Marshal() (dAtA []byte, err error)
- func (m *GetGCSafePointRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetGCSafePointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetGCSafePointRequest) ProtoMessage()
- func (m *GetGCSafePointRequest) Reset()
- func (m *GetGCSafePointRequest) Size() (n int)
- func (m *GetGCSafePointRequest) String() string
- func (m *GetGCSafePointRequest) Unmarshal(dAtA []byte) error
- func (m *GetGCSafePointRequest) XXX_DiscardUnknown()
- func (m *GetGCSafePointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetGCSafePointRequest) XXX_Merge(src proto.Message)
- func (m *GetGCSafePointRequest) XXX_Size() int
- func (m *GetGCSafePointRequest) XXX_Unmarshal(b []byte) error
- type GetGCSafePointResponse
- func (*GetGCSafePointResponse) Descriptor() ([]byte, []int)
- func (m *GetGCSafePointResponse) GetHeader() *ResponseHeader
- func (m *GetGCSafePointResponse) GetSafePoint() uint64
- func (m *GetGCSafePointResponse) Marshal() (dAtA []byte, err error)
- func (m *GetGCSafePointResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetGCSafePointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetGCSafePointResponse) ProtoMessage()
- func (m *GetGCSafePointResponse) Reset()
- func (m *GetGCSafePointResponse) Size() (n int)
- func (m *GetGCSafePointResponse) String() string
- func (m *GetGCSafePointResponse) Unmarshal(dAtA []byte) error
- func (m *GetGCSafePointResponse) XXX_DiscardUnknown()
- func (m *GetGCSafePointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetGCSafePointResponse) XXX_Merge(src proto.Message)
- func (m *GetGCSafePointResponse) XXX_Size() int
- func (m *GetGCSafePointResponse) XXX_Unmarshal(b []byte) error
- type GetGCSafePointV2Request
- func (*GetGCSafePointV2Request) Descriptor() ([]byte, []int)
- func (m *GetGCSafePointV2Request) GetHeader() *RequestHeader
- func (m *GetGCSafePointV2Request) GetKeyspaceId() uint32
- func (m *GetGCSafePointV2Request) Marshal() (dAtA []byte, err error)
- func (m *GetGCSafePointV2Request) MarshalTo(dAtA []byte) (int, error)
- func (m *GetGCSafePointV2Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetGCSafePointV2Request) ProtoMessage()
- func (m *GetGCSafePointV2Request) Reset()
- func (m *GetGCSafePointV2Request) Size() (n int)
- func (m *GetGCSafePointV2Request) String() string
- func (m *GetGCSafePointV2Request) Unmarshal(dAtA []byte) error
- func (m *GetGCSafePointV2Request) XXX_DiscardUnknown()
- func (m *GetGCSafePointV2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetGCSafePointV2Request) XXX_Merge(src proto.Message)
- func (m *GetGCSafePointV2Request) XXX_Size() int
- func (m *GetGCSafePointV2Request) XXX_Unmarshal(b []byte) error
- type GetGCSafePointV2Response
- func (*GetGCSafePointV2Response) Descriptor() ([]byte, []int)
- func (m *GetGCSafePointV2Response) GetHeader() *ResponseHeader
- func (m *GetGCSafePointV2Response) GetSafePoint() uint64
- func (m *GetGCSafePointV2Response) Marshal() (dAtA []byte, err error)
- func (m *GetGCSafePointV2Response) MarshalTo(dAtA []byte) (int, error)
- func (m *GetGCSafePointV2Response) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetGCSafePointV2Response) ProtoMessage()
- func (m *GetGCSafePointV2Response) Reset()
- func (m *GetGCSafePointV2Response) Size() (n int)
- func (m *GetGCSafePointV2Response) String() string
- func (m *GetGCSafePointV2Response) Unmarshal(dAtA []byte) error
- func (m *GetGCSafePointV2Response) XXX_DiscardUnknown()
- func (m *GetGCSafePointV2Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetGCSafePointV2Response) XXX_Merge(src proto.Message)
- func (m *GetGCSafePointV2Response) XXX_Size() int
- func (m *GetGCSafePointV2Response) XXX_Unmarshal(b []byte) error
- type GetMembersRequest
- func (*GetMembersRequest) Descriptor() ([]byte, []int)
- func (m *GetMembersRequest) GetHeader() *RequestHeader
- func (m *GetMembersRequest) Marshal() (dAtA []byte, err error)
- func (m *GetMembersRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetMembersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetMembersRequest) ProtoMessage()
- func (m *GetMembersRequest) Reset()
- func (m *GetMembersRequest) Size() (n int)
- func (m *GetMembersRequest) String() string
- func (m *GetMembersRequest) Unmarshal(dAtA []byte) error
- func (m *GetMembersRequest) XXX_DiscardUnknown()
- func (m *GetMembersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMembersRequest) XXX_Merge(src proto.Message)
- func (m *GetMembersRequest) XXX_Size() int
- func (m *GetMembersRequest) XXX_Unmarshal(b []byte) error
- type GetMembersResponse
- func (*GetMembersResponse) Descriptor() ([]byte, []int)
- func (m *GetMembersResponse) GetEtcdLeader() *Member
- func (m *GetMembersResponse) GetHeader() *ResponseHeader
- func (m *GetMembersResponse) GetLeader() *Member
- func (m *GetMembersResponse) GetMembers() []*Member
- func (m *GetMembersResponse) GetTsoAllocatorLeaders() map[string]*Member
- func (m *GetMembersResponse) Marshal() (dAtA []byte, err error)
- func (m *GetMembersResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetMembersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetMembersResponse) ProtoMessage()
- func (m *GetMembersResponse) Reset()
- func (m *GetMembersResponse) Size() (n int)
- func (m *GetMembersResponse) String() string
- func (m *GetMembersResponse) Unmarshal(dAtA []byte) error
- func (m *GetMembersResponse) XXX_DiscardUnknown()
- func (m *GetMembersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMembersResponse) XXX_Merge(src proto.Message)
- func (m *GetMembersResponse) XXX_Size() int
- func (m *GetMembersResponse) XXX_Unmarshal(b []byte) error
- type GetMinTSRequest
- func (*GetMinTSRequest) Descriptor() ([]byte, []int)
- func (m *GetMinTSRequest) GetHeader() *RequestHeader
- func (m *GetMinTSRequest) Marshal() (dAtA []byte, err error)
- func (m *GetMinTSRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetMinTSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetMinTSRequest) ProtoMessage()
- func (m *GetMinTSRequest) Reset()
- func (m *GetMinTSRequest) Size() (n int)
- func (m *GetMinTSRequest) String() string
- func (m *GetMinTSRequest) Unmarshal(dAtA []byte) error
- func (m *GetMinTSRequest) XXX_DiscardUnknown()
- func (m *GetMinTSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMinTSRequest) XXX_Merge(src proto.Message)
- func (m *GetMinTSRequest) XXX_Size() int
- func (m *GetMinTSRequest) XXX_Unmarshal(b []byte) error
- type GetMinTSResponse
- func (*GetMinTSResponse) Descriptor() ([]byte, []int)
- func (m *GetMinTSResponse) GetHeader() *ResponseHeader
- func (m *GetMinTSResponse) GetTimestamp() *Timestamp
- func (m *GetMinTSResponse) Marshal() (dAtA []byte, err error)
- func (m *GetMinTSResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetMinTSResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetMinTSResponse) ProtoMessage()
- func (m *GetMinTSResponse) Reset()
- func (m *GetMinTSResponse) Size() (n int)
- func (m *GetMinTSResponse) String() string
- func (m *GetMinTSResponse) Unmarshal(dAtA []byte) error
- func (m *GetMinTSResponse) XXX_DiscardUnknown()
- func (m *GetMinTSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetMinTSResponse) XXX_Merge(src proto.Message)
- func (m *GetMinTSResponse) XXX_Size() int
- func (m *GetMinTSResponse) XXX_Unmarshal(b []byte) error
- type GetOperatorRequest
- func (*GetOperatorRequest) Descriptor() ([]byte, []int)
- func (m *GetOperatorRequest) GetHeader() *RequestHeader
- func (m *GetOperatorRequest) GetRegionId() uint64
- func (m *GetOperatorRequest) Marshal() (dAtA []byte, err error)
- func (m *GetOperatorRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetOperatorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetOperatorRequest) ProtoMessage()
- func (m *GetOperatorRequest) Reset()
- func (m *GetOperatorRequest) Size() (n int)
- func (m *GetOperatorRequest) String() string
- func (m *GetOperatorRequest) Unmarshal(dAtA []byte) error
- func (m *GetOperatorRequest) XXX_DiscardUnknown()
- func (m *GetOperatorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetOperatorRequest) XXX_Merge(src proto.Message)
- func (m *GetOperatorRequest) XXX_Size() int
- func (m *GetOperatorRequest) XXX_Unmarshal(b []byte) error
- type GetOperatorResponse
- func (*GetOperatorResponse) Descriptor() ([]byte, []int)
- func (m *GetOperatorResponse) GetDesc() []byte
- func (m *GetOperatorResponse) GetHeader() *ResponseHeader
- func (m *GetOperatorResponse) GetKind() []byte
- func (m *GetOperatorResponse) GetRegionId() uint64
- func (m *GetOperatorResponse) GetStatus() OperatorStatus
- func (m *GetOperatorResponse) Marshal() (dAtA []byte, err error)
- func (m *GetOperatorResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetOperatorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetOperatorResponse) ProtoMessage()
- func (m *GetOperatorResponse) Reset()
- func (m *GetOperatorResponse) Size() (n int)
- func (m *GetOperatorResponse) String() string
- func (m *GetOperatorResponse) Unmarshal(dAtA []byte) error
- func (m *GetOperatorResponse) XXX_DiscardUnknown()
- func (m *GetOperatorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetOperatorResponse) XXX_Merge(src proto.Message)
- func (m *GetOperatorResponse) XXX_Size() int
- func (m *GetOperatorResponse) XXX_Unmarshal(b []byte) error
- type GetRegionByIDRequest
- func (*GetRegionByIDRequest) Descriptor() ([]byte, []int)
- func (m *GetRegionByIDRequest) GetHeader() *RequestHeader
- func (m *GetRegionByIDRequest) GetNeedBuckets() bool
- func (m *GetRegionByIDRequest) GetRegionId() uint64
- func (m *GetRegionByIDRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRegionByIDRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRegionByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRegionByIDRequest) ProtoMessage()
- func (m *GetRegionByIDRequest) Reset()
- func (m *GetRegionByIDRequest) Size() (n int)
- func (m *GetRegionByIDRequest) String() string
- func (m *GetRegionByIDRequest) Unmarshal(dAtA []byte) error
- func (m *GetRegionByIDRequest) XXX_DiscardUnknown()
- func (m *GetRegionByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRegionByIDRequest) XXX_Merge(src proto.Message)
- func (m *GetRegionByIDRequest) XXX_Size() int
- func (m *GetRegionByIDRequest) XXX_Unmarshal(b []byte) error
- type GetRegionRequest
- func (*GetRegionRequest) Descriptor() ([]byte, []int)
- func (m *GetRegionRequest) GetHeader() *RequestHeader
- func (m *GetRegionRequest) GetNeedBuckets() bool
- func (m *GetRegionRequest) GetRegionKey() []byte
- func (m *GetRegionRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRegionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRegionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRegionRequest) ProtoMessage()
- func (m *GetRegionRequest) Reset()
- func (m *GetRegionRequest) Size() (n int)
- func (m *GetRegionRequest) String() string
- func (m *GetRegionRequest) Unmarshal(dAtA []byte) error
- func (m *GetRegionRequest) XXX_DiscardUnknown()
- func (m *GetRegionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRegionRequest) XXX_Merge(src proto.Message)
- func (m *GetRegionRequest) XXX_Size() int
- func (m *GetRegionRequest) XXX_Unmarshal(b []byte) error
- type GetRegionResponse
- func (*GetRegionResponse) Descriptor() ([]byte, []int)
- func (m *GetRegionResponse) GetBuckets() *metapb.Buckets
- func (m *GetRegionResponse) GetDownPeers() []*PeerStats
- func (m *GetRegionResponse) GetHeader() *ResponseHeader
- func (m *GetRegionResponse) GetLeader() *metapb.Peer
- func (m *GetRegionResponse) GetPendingPeers() []*metapb.Peer
- func (m *GetRegionResponse) GetRegion() *metapb.Region
- func (m *GetRegionResponse) Marshal() (dAtA []byte, err error)
- func (m *GetRegionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRegionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRegionResponse) ProtoMessage()
- func (m *GetRegionResponse) Reset()
- func (m *GetRegionResponse) Size() (n int)
- func (m *GetRegionResponse) String() string
- func (m *GetRegionResponse) Unmarshal(dAtA []byte) error
- func (m *GetRegionResponse) XXX_DiscardUnknown()
- func (m *GetRegionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRegionResponse) XXX_Merge(src proto.Message)
- func (m *GetRegionResponse) XXX_Size() int
- func (m *GetRegionResponse) XXX_Unmarshal(b []byte) error
- type GetStoreRequest
- func (*GetStoreRequest) Descriptor() ([]byte, []int)
- func (m *GetStoreRequest) GetHeader() *RequestHeader
- func (m *GetStoreRequest) GetStoreId() uint64
- func (m *GetStoreRequest) Marshal() (dAtA []byte, err error)
- func (m *GetStoreRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetStoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetStoreRequest) ProtoMessage()
- func (m *GetStoreRequest) Reset()
- func (m *GetStoreRequest) Size() (n int)
- func (m *GetStoreRequest) String() string
- func (m *GetStoreRequest) Unmarshal(dAtA []byte) error
- func (m *GetStoreRequest) XXX_DiscardUnknown()
- func (m *GetStoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetStoreRequest) XXX_Merge(src proto.Message)
- func (m *GetStoreRequest) XXX_Size() int
- func (m *GetStoreRequest) XXX_Unmarshal(b []byte) error
- type GetStoreResponse
- func (*GetStoreResponse) Descriptor() ([]byte, []int)
- func (m *GetStoreResponse) GetHeader() *ResponseHeader
- func (m *GetStoreResponse) GetStats() *StoreStats
- func (m *GetStoreResponse) GetStore() *metapb.Store
- func (m *GetStoreResponse) Marshal() (dAtA []byte, err error)
- func (m *GetStoreResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetStoreResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetStoreResponse) ProtoMessage()
- func (m *GetStoreResponse) Reset()
- func (m *GetStoreResponse) Size() (n int)
- func (m *GetStoreResponse) String() string
- func (m *GetStoreResponse) Unmarshal(dAtA []byte) error
- func (m *GetStoreResponse) XXX_DiscardUnknown()
- func (m *GetStoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetStoreResponse) XXX_Merge(src proto.Message)
- func (m *GetStoreResponse) XXX_Size() int
- func (m *GetStoreResponse) XXX_Unmarshal(b []byte) error
- type GlobalConfigItem
- func (*GlobalConfigItem) Descriptor() ([]byte, []int)
- func (m *GlobalConfigItem) GetError() *Error
- func (m *GlobalConfigItem) GetKind() EventType
- func (m *GlobalConfigItem) GetName() string
- func (m *GlobalConfigItem) GetPayload() []byte
- func (m *GlobalConfigItem) GetValue() string
- func (m *GlobalConfigItem) Marshal() (dAtA []byte, err error)
- func (m *GlobalConfigItem) MarshalTo(dAtA []byte) (int, error)
- func (m *GlobalConfigItem) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GlobalConfigItem) ProtoMessage()
- func (m *GlobalConfigItem) Reset()
- func (m *GlobalConfigItem) Size() (n int)
- func (m *GlobalConfigItem) String() string
- func (m *GlobalConfigItem) Unmarshal(dAtA []byte) error
- func (m *GlobalConfigItem) XXX_DiscardUnknown()
- func (m *GlobalConfigItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GlobalConfigItem) XXX_Merge(src proto.Message)
- func (m *GlobalConfigItem) XXX_Size() int
- func (m *GlobalConfigItem) XXX_Unmarshal(b []byte) error
- type IsBootstrappedRequest
- func (*IsBootstrappedRequest) Descriptor() ([]byte, []int)
- func (m *IsBootstrappedRequest) GetHeader() *RequestHeader
- func (m *IsBootstrappedRequest) Marshal() (dAtA []byte, err error)
- func (m *IsBootstrappedRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *IsBootstrappedRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IsBootstrappedRequest) ProtoMessage()
- func (m *IsBootstrappedRequest) Reset()
- func (m *IsBootstrappedRequest) Size() (n int)
- func (m *IsBootstrappedRequest) String() string
- func (m *IsBootstrappedRequest) Unmarshal(dAtA []byte) error
- func (m *IsBootstrappedRequest) XXX_DiscardUnknown()
- func (m *IsBootstrappedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsBootstrappedRequest) XXX_Merge(src proto.Message)
- func (m *IsBootstrappedRequest) XXX_Size() int
- func (m *IsBootstrappedRequest) XXX_Unmarshal(b []byte) error
- type IsBootstrappedResponse
- func (*IsBootstrappedResponse) Descriptor() ([]byte, []int)
- func (m *IsBootstrappedResponse) GetBootstrapped() bool
- func (m *IsBootstrappedResponse) GetHeader() *ResponseHeader
- func (m *IsBootstrappedResponse) Marshal() (dAtA []byte, err error)
- func (m *IsBootstrappedResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *IsBootstrappedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IsBootstrappedResponse) ProtoMessage()
- func (m *IsBootstrappedResponse) Reset()
- func (m *IsBootstrappedResponse) Size() (n int)
- func (m *IsBootstrappedResponse) String() string
- func (m *IsBootstrappedResponse) Unmarshal(dAtA []byte) error
- func (m *IsBootstrappedResponse) XXX_DiscardUnknown()
- func (m *IsBootstrappedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsBootstrappedResponse) XXX_Merge(src proto.Message)
- func (m *IsBootstrappedResponse) XXX_Size() int
- func (m *IsBootstrappedResponse) XXX_Unmarshal(b []byte) error
- type IsSnapshotRecoveringRequest
- func (*IsSnapshotRecoveringRequest) Descriptor() ([]byte, []int)
- func (m *IsSnapshotRecoveringRequest) GetHeader() *RequestHeader
- func (m *IsSnapshotRecoveringRequest) Marshal() (dAtA []byte, err error)
- func (m *IsSnapshotRecoveringRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *IsSnapshotRecoveringRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IsSnapshotRecoveringRequest) ProtoMessage()
- func (m *IsSnapshotRecoveringRequest) Reset()
- func (m *IsSnapshotRecoveringRequest) Size() (n int)
- func (m *IsSnapshotRecoveringRequest) String() string
- func (m *IsSnapshotRecoveringRequest) Unmarshal(dAtA []byte) error
- func (m *IsSnapshotRecoveringRequest) XXX_DiscardUnknown()
- func (m *IsSnapshotRecoveringRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsSnapshotRecoveringRequest) XXX_Merge(src proto.Message)
- func (m *IsSnapshotRecoveringRequest) XXX_Size() int
- func (m *IsSnapshotRecoveringRequest) XXX_Unmarshal(b []byte) error
- type IsSnapshotRecoveringResponse
- func (*IsSnapshotRecoveringResponse) Descriptor() ([]byte, []int)
- func (m *IsSnapshotRecoveringResponse) GetHeader() *ResponseHeader
- func (m *IsSnapshotRecoveringResponse) GetMarked() bool
- func (m *IsSnapshotRecoveringResponse) Marshal() (dAtA []byte, err error)
- func (m *IsSnapshotRecoveringResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *IsSnapshotRecoveringResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IsSnapshotRecoveringResponse) ProtoMessage()
- func (m *IsSnapshotRecoveringResponse) Reset()
- func (m *IsSnapshotRecoveringResponse) Size() (n int)
- func (m *IsSnapshotRecoveringResponse) String() string
- func (m *IsSnapshotRecoveringResponse) Unmarshal(dAtA []byte) error
- func (m *IsSnapshotRecoveringResponse) XXX_DiscardUnknown()
- func (m *IsSnapshotRecoveringResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IsSnapshotRecoveringResponse) XXX_Merge(src proto.Message)
- func (m *IsSnapshotRecoveringResponse) XXX_Size() int
- func (m *IsSnapshotRecoveringResponse) XXX_Unmarshal(b []byte) error
- type LoadGlobalConfigRequest
- func (*LoadGlobalConfigRequest) Descriptor() ([]byte, []int)
- func (m *LoadGlobalConfigRequest) GetConfigPath() string
- func (m *LoadGlobalConfigRequest) GetNames() []string
- func (m *LoadGlobalConfigRequest) Marshal() (dAtA []byte, err error)
- func (m *LoadGlobalConfigRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *LoadGlobalConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LoadGlobalConfigRequest) ProtoMessage()
- func (m *LoadGlobalConfigRequest) Reset()
- func (m *LoadGlobalConfigRequest) Size() (n int)
- func (m *LoadGlobalConfigRequest) String() string
- func (m *LoadGlobalConfigRequest) Unmarshal(dAtA []byte) error
- func (m *LoadGlobalConfigRequest) XXX_DiscardUnknown()
- func (m *LoadGlobalConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadGlobalConfigRequest) XXX_Merge(src proto.Message)
- func (m *LoadGlobalConfigRequest) XXX_Size() int
- func (m *LoadGlobalConfigRequest) XXX_Unmarshal(b []byte) error
- type LoadGlobalConfigResponse
- func (*LoadGlobalConfigResponse) Descriptor() ([]byte, []int)
- func (m *LoadGlobalConfigResponse) GetItems() []*GlobalConfigItem
- func (m *LoadGlobalConfigResponse) GetRevision() int64
- func (m *LoadGlobalConfigResponse) Marshal() (dAtA []byte, err error)
- func (m *LoadGlobalConfigResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *LoadGlobalConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LoadGlobalConfigResponse) ProtoMessage()
- func (m *LoadGlobalConfigResponse) Reset()
- func (m *LoadGlobalConfigResponse) Size() (n int)
- func (m *LoadGlobalConfigResponse) String() string
- func (m *LoadGlobalConfigResponse) Unmarshal(dAtA []byte) error
- func (m *LoadGlobalConfigResponse) XXX_DiscardUnknown()
- func (m *LoadGlobalConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LoadGlobalConfigResponse) XXX_Merge(src proto.Message)
- func (m *LoadGlobalConfigResponse) XXX_Size() int
- func (m *LoadGlobalConfigResponse) XXX_Unmarshal(b []byte) error
- type Member
- func (*Member) Descriptor() ([]byte, []int)
- func (m *Member) GetBinaryVersion() string
- func (m *Member) GetClientUrls() []string
- func (m *Member) GetDcLocation() string
- func (m *Member) GetDeployPath() string
- func (m *Member) GetGitHash() string
- func (m *Member) GetLeaderPriority() int32
- func (m *Member) GetMemberId() uint64
- func (m *Member) GetName() string
- func (m *Member) GetPeerUrls() []string
- func (m *Member) Marshal() (dAtA []byte, err error)
- func (m *Member) MarshalTo(dAtA []byte) (int, error)
- func (m *Member) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Member) ProtoMessage()
- func (m *Member) Reset()
- func (m *Member) Size() (n int)
- func (m *Member) String() string
- func (m *Member) Unmarshal(dAtA []byte) error
- func (m *Member) XXX_DiscardUnknown()
- func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Member) XXX_Merge(src proto.Message)
- func (m *Member) XXX_Size() int
- func (m *Member) XXX_Unmarshal(b []byte) error
- type Merge
- func (*Merge) Descriptor() ([]byte, []int)
- func (m *Merge) GetTarget() *metapb.Region
- func (m *Merge) Marshal() (dAtA []byte, err error)
- func (m *Merge) MarshalTo(dAtA []byte) (int, error)
- func (m *Merge) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Merge) ProtoMessage()
- func (m *Merge) Reset()
- func (m *Merge) Size() (n int)
- func (m *Merge) String() string
- func (m *Merge) Unmarshal(dAtA []byte) error
- func (m *Merge) XXX_DiscardUnknown()
- func (m *Merge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Merge) XXX_Merge(src proto.Message)
- func (m *Merge) XXX_Size() int
- func (m *Merge) XXX_Unmarshal(b []byte) error
- type OperatorStatus
- type PDClient
- type PDServer
- type PD_RegionHeartbeatClient
- type PD_RegionHeartbeatServer
- type PD_ReportBucketsClient
- type PD_ReportBucketsServer
- type PD_SyncRegionsClient
- type PD_SyncRegionsServer
- type PD_TsoClient
- type PD_TsoServer
- type PD_WatchGCSafePointV2Client
- type PD_WatchGCSafePointV2Server
- type PD_WatchGlobalConfigClient
- type PD_WatchGlobalConfigServer
- type PeerReport
- func (*PeerReport) Descriptor() ([]byte, []int)
- func (m *PeerReport) GetHasCommitMerge() bool
- func (m *PeerReport) GetIsForceLeader() bool
- func (m *PeerReport) GetRaftState() *raft_serverpb.RaftLocalState
- func (m *PeerReport) GetRegionState() *raft_serverpb.RegionLocalState
- func (m *PeerReport) Marshal() (dAtA []byte, err error)
- func (m *PeerReport) MarshalTo(dAtA []byte) (int, error)
- func (m *PeerReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PeerReport) ProtoMessage()
- func (m *PeerReport) Reset()
- func (m *PeerReport) Size() (n int)
- func (m *PeerReport) String() string
- func (m *PeerReport) Unmarshal(dAtA []byte) error
- func (m *PeerReport) XXX_DiscardUnknown()
- func (m *PeerReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerReport) XXX_Merge(src proto.Message)
- func (m *PeerReport) XXX_Size() int
- func (m *PeerReport) XXX_Unmarshal(b []byte) error
- type PeerStat
- func (*PeerStat) Descriptor() ([]byte, []int)
- func (m *PeerStat) GetQueryStats() *QueryStats
- func (m *PeerStat) GetReadBytes() uint64
- func (m *PeerStat) GetReadKeys() uint64
- func (m *PeerStat) GetRegionId() uint64
- func (m *PeerStat) GetWrittenBytes() uint64
- func (m *PeerStat) GetWrittenKeys() uint64
- func (m *PeerStat) Marshal() (dAtA []byte, err error)
- func (m *PeerStat) MarshalTo(dAtA []byte) (int, error)
- func (m *PeerStat) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PeerStat) ProtoMessage()
- func (m *PeerStat) Reset()
- func (m *PeerStat) Size() (n int)
- func (m *PeerStat) String() string
- func (m *PeerStat) Unmarshal(dAtA []byte) error
- func (m *PeerStat) XXX_DiscardUnknown()
- func (m *PeerStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerStat) XXX_Merge(src proto.Message)
- func (m *PeerStat) XXX_Size() int
- func (m *PeerStat) XXX_Unmarshal(b []byte) error
- type PeerStats
- func (*PeerStats) Descriptor() ([]byte, []int)
- func (m *PeerStats) GetDownSeconds() uint64
- func (m *PeerStats) GetPeer() *metapb.Peer
- func (m *PeerStats) Marshal() (dAtA []byte, err error)
- func (m *PeerStats) MarshalTo(dAtA []byte) (int, error)
- func (m *PeerStats) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PeerStats) ProtoMessage()
- func (m *PeerStats) Reset()
- func (m *PeerStats) Size() (n int)
- func (m *PeerStats) String() string
- func (m *PeerStats) Unmarshal(dAtA []byte) error
- func (m *PeerStats) XXX_DiscardUnknown()
- func (m *PeerStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerStats) XXX_Merge(src proto.Message)
- func (m *PeerStats) XXX_Size() int
- func (m *PeerStats) XXX_Unmarshal(b []byte) error
- type Peers
- func (*Peers) Descriptor() ([]byte, []int)
- func (m *Peers) GetPeers() []*metapb.Peer
- func (m *Peers) Marshal() (dAtA []byte, err error)
- func (m *Peers) MarshalTo(dAtA []byte) (int, error)
- func (m *Peers) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Peers) ProtoMessage()
- func (m *Peers) Reset()
- func (m *Peers) Size() (n int)
- func (m *Peers) String() string
- func (m *Peers) Unmarshal(dAtA []byte) error
- func (m *Peers) XXX_DiscardUnknown()
- func (m *Peers) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Peers) XXX_Merge(src proto.Message)
- func (m *Peers) XXX_Size() int
- func (m *Peers) XXX_Unmarshal(b []byte) error
- type PeersStats
- func (*PeersStats) Descriptor() ([]byte, []int)
- func (m *PeersStats) GetPeers() []*PeerStats
- func (m *PeersStats) Marshal() (dAtA []byte, err error)
- func (m *PeersStats) MarshalTo(dAtA []byte) (int, error)
- func (m *PeersStats) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PeersStats) ProtoMessage()
- func (m *PeersStats) Reset()
- func (m *PeersStats) Size() (n int)
- func (m *PeersStats) String() string
- func (m *PeersStats) Unmarshal(dAtA []byte) error
- func (m *PeersStats) XXX_DiscardUnknown()
- func (m *PeersStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeersStats) XXX_Merge(src proto.Message)
- func (m *PeersStats) XXX_Size() int
- func (m *PeersStats) XXX_Unmarshal(b []byte) error
- type PutClusterConfigRequest
- func (*PutClusterConfigRequest) Descriptor() ([]byte, []int)
- func (m *PutClusterConfigRequest) GetCluster() *metapb.Cluster
- func (m *PutClusterConfigRequest) GetHeader() *RequestHeader
- func (m *PutClusterConfigRequest) Marshal() (dAtA []byte, err error)
- func (m *PutClusterConfigRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PutClusterConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PutClusterConfigRequest) ProtoMessage()
- func (m *PutClusterConfigRequest) Reset()
- func (m *PutClusterConfigRequest) Size() (n int)
- func (m *PutClusterConfigRequest) String() string
- func (m *PutClusterConfigRequest) Unmarshal(dAtA []byte) error
- func (m *PutClusterConfigRequest) XXX_DiscardUnknown()
- func (m *PutClusterConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutClusterConfigRequest) XXX_Merge(src proto.Message)
- func (m *PutClusterConfigRequest) XXX_Size() int
- func (m *PutClusterConfigRequest) XXX_Unmarshal(b []byte) error
- type PutClusterConfigResponse
- func (*PutClusterConfigResponse) Descriptor() ([]byte, []int)
- func (m *PutClusterConfigResponse) GetHeader() *ResponseHeader
- func (m *PutClusterConfigResponse) Marshal() (dAtA []byte, err error)
- func (m *PutClusterConfigResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PutClusterConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PutClusterConfigResponse) ProtoMessage()
- func (m *PutClusterConfigResponse) Reset()
- func (m *PutClusterConfigResponse) Size() (n int)
- func (m *PutClusterConfigResponse) String() string
- func (m *PutClusterConfigResponse) Unmarshal(dAtA []byte) error
- func (m *PutClusterConfigResponse) XXX_DiscardUnknown()
- func (m *PutClusterConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutClusterConfigResponse) XXX_Merge(src proto.Message)
- func (m *PutClusterConfigResponse) XXX_Size() int
- func (m *PutClusterConfigResponse) XXX_Unmarshal(b []byte) error
- type PutStoreRequest
- func (*PutStoreRequest) Descriptor() ([]byte, []int)
- func (m *PutStoreRequest) GetHeader() *RequestHeader
- func (m *PutStoreRequest) GetStore() *metapb.Store
- func (m *PutStoreRequest) Marshal() (dAtA []byte, err error)
- func (m *PutStoreRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PutStoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PutStoreRequest) ProtoMessage()
- func (m *PutStoreRequest) Reset()
- func (m *PutStoreRequest) Size() (n int)
- func (m *PutStoreRequest) String() string
- func (m *PutStoreRequest) Unmarshal(dAtA []byte) error
- func (m *PutStoreRequest) XXX_DiscardUnknown()
- func (m *PutStoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutStoreRequest) XXX_Merge(src proto.Message)
- func (m *PutStoreRequest) XXX_Size() int
- func (m *PutStoreRequest) XXX_Unmarshal(b []byte) error
- type PutStoreResponse
- func (*PutStoreResponse) Descriptor() ([]byte, []int)
- func (m *PutStoreResponse) GetHeader() *ResponseHeader
- func (m *PutStoreResponse) GetReplicationStatus() *replication_modepb.ReplicationStatus
- func (m *PutStoreResponse) Marshal() (dAtA []byte, err error)
- func (m *PutStoreResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PutStoreResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PutStoreResponse) ProtoMessage()
- func (m *PutStoreResponse) Reset()
- func (m *PutStoreResponse) Size() (n int)
- func (m *PutStoreResponse) String() string
- func (m *PutStoreResponse) Unmarshal(dAtA []byte) error
- func (m *PutStoreResponse) XXX_DiscardUnknown()
- func (m *PutStoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PutStoreResponse) XXX_Merge(src proto.Message)
- func (m *PutStoreResponse) XXX_Size() int
- func (m *PutStoreResponse) XXX_Unmarshal(b []byte) error
- type QueryKind
- type QueryStats
- func (*QueryStats) Descriptor() ([]byte, []int)
- func (m *QueryStats) GetAcquirePessimisticLock() uint64
- func (m *QueryStats) GetCommit() uint64
- func (m *QueryStats) GetCoprocessor() uint64
- func (m *QueryStats) GetDelete() uint64
- func (m *QueryStats) GetDeleteRange() uint64
- func (m *QueryStats) GetGC() uint64
- func (m *QueryStats) GetGet() uint64
- func (m *QueryStats) GetPrewrite() uint64
- func (m *QueryStats) GetPut() uint64
- func (m *QueryStats) GetRollback() uint64
- func (m *QueryStats) GetScan() uint64
- func (m *QueryStats) Marshal() (dAtA []byte, err error)
- func (m *QueryStats) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStats) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStats) ProtoMessage()
- func (m *QueryStats) Reset()
- func (m *QueryStats) Size() (n int)
- func (m *QueryStats) String() string
- func (m *QueryStats) Unmarshal(dAtA []byte) error
- func (m *QueryStats) XXX_DiscardUnknown()
- func (m *QueryStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStats) XXX_Merge(src proto.Message)
- func (m *QueryStats) XXX_Size() int
- func (m *QueryStats) XXX_Unmarshal(b []byte) error
- type RecordPair
- func (*RecordPair) Descriptor() ([]byte, []int)
- func (m *RecordPair) GetKey() string
- func (m *RecordPair) GetValue() uint64
- func (m *RecordPair) Marshal() (dAtA []byte, err error)
- func (m *RecordPair) MarshalTo(dAtA []byte) (int, error)
- func (m *RecordPair) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RecordPair) ProtoMessage()
- func (m *RecordPair) Reset()
- func (m *RecordPair) Size() (n int)
- func (m *RecordPair) String() string
- func (m *RecordPair) Unmarshal(dAtA []byte) error
- func (m *RecordPair) XXX_DiscardUnknown()
- func (m *RecordPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordPair) XXX_Merge(src proto.Message)
- func (m *RecordPair) XXX_Size() int
- func (m *RecordPair) XXX_Unmarshal(b []byte) error
- type RecoveryPlan
- func (*RecoveryPlan) Descriptor() ([]byte, []int)
- func (m *RecoveryPlan) GetCreates() []*metapb.Region
- func (m *RecoveryPlan) GetDemotes() []*DemoteFailedVoters
- func (m *RecoveryPlan) GetForceLeader() *ForceLeader
- func (m *RecoveryPlan) GetStep() uint64
- func (m *RecoveryPlan) GetTombstones() []uint64
- func (m *RecoveryPlan) GetUpdates() []*metapb.Regiondeprecated
- func (m *RecoveryPlan) Marshal() (dAtA []byte, err error)
- func (m *RecoveryPlan) MarshalTo(dAtA []byte) (int, error)
- func (m *RecoveryPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RecoveryPlan) ProtoMessage()
- func (m *RecoveryPlan) Reset()
- func (m *RecoveryPlan) Size() (n int)
- func (m *RecoveryPlan) String() string
- func (m *RecoveryPlan) Unmarshal(dAtA []byte) error
- func (m *RecoveryPlan) XXX_DiscardUnknown()
- func (m *RecoveryPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecoveryPlan) XXX_Merge(src proto.Message)
- func (m *RecoveryPlan) XXX_Size() int
- func (m *RecoveryPlan) XXX_Unmarshal(b []byte) error
- type Region
- func (*Region) Descriptor() ([]byte, []int)
- func (m *Region) GetDownPeers() []*PeerStats
- func (m *Region) GetLeader() *metapb.Peer
- func (m *Region) GetPendingPeers() []*metapb.Peer
- func (m *Region) GetRegion() *metapb.Region
- func (m *Region) Marshal() (dAtA []byte, err error)
- func (m *Region) MarshalTo(dAtA []byte) (int, error)
- func (m *Region) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Region) ProtoMessage()
- func (m *Region) Reset()
- func (m *Region) Size() (n int)
- func (m *Region) String() string
- func (m *Region) Unmarshal(dAtA []byte) error
- func (m *Region) XXX_DiscardUnknown()
- func (m *Region) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Region) XXX_Merge(src proto.Message)
- func (m *Region) XXX_Size() int
- func (m *Region) XXX_Unmarshal(b []byte) error
- type RegionHeartbeatRequest
- func (*RegionHeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *RegionHeartbeatRequest) GetApproximateKeys() uint64
- func (m *RegionHeartbeatRequest) GetApproximateKvSize() uint64
- func (m *RegionHeartbeatRequest) GetApproximateSize() uint64
- func (m *RegionHeartbeatRequest) GetBytesRead() uint64
- func (m *RegionHeartbeatRequest) GetBytesWritten() uint64
- func (m *RegionHeartbeatRequest) GetCpuUsage() uint64
- func (m *RegionHeartbeatRequest) GetDownPeers() []*PeerStats
- func (m *RegionHeartbeatRequest) GetHeader() *RequestHeader
- func (m *RegionHeartbeatRequest) GetInterval() *TimeInterval
- func (m *RegionHeartbeatRequest) GetKeysRead() uint64
- func (m *RegionHeartbeatRequest) GetKeysWritten() uint64
- func (m *RegionHeartbeatRequest) GetLeader() *metapb.Peer
- func (m *RegionHeartbeatRequest) GetPendingPeers() []*metapb.Peer
- func (m *RegionHeartbeatRequest) GetQueryStats() *QueryStats
- func (m *RegionHeartbeatRequest) GetRegion() *metapb.Region
- func (m *RegionHeartbeatRequest) GetReplicationStatus() *replication_modepb.RegionReplicationStatus
- func (m *RegionHeartbeatRequest) GetTerm() uint64
- func (m *RegionHeartbeatRequest) Marshal() (dAtA []byte, err error)
- func (m *RegionHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RegionHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegionHeartbeatRequest) ProtoMessage()
- func (m *RegionHeartbeatRequest) Reset()
- func (m *RegionHeartbeatRequest) Size() (n int)
- func (m *RegionHeartbeatRequest) String() string
- func (m *RegionHeartbeatRequest) Unmarshal(dAtA []byte) error
- func (m *RegionHeartbeatRequest) XXX_DiscardUnknown()
- func (m *RegionHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegionHeartbeatRequest) XXX_Merge(src proto.Message)
- func (m *RegionHeartbeatRequest) XXX_Size() int
- func (m *RegionHeartbeatRequest) XXX_Unmarshal(b []byte) error
- type RegionHeartbeatResponse
- func (*RegionHeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *RegionHeartbeatResponse) GetChangePeer() *ChangePeer
- func (m *RegionHeartbeatResponse) GetChangePeerV2() *ChangePeerV2
- func (m *RegionHeartbeatResponse) GetHeader() *ResponseHeader
- func (m *RegionHeartbeatResponse) GetMerge() *Merge
- func (m *RegionHeartbeatResponse) GetRegionEpoch() *metapb.RegionEpoch
- func (m *RegionHeartbeatResponse) GetRegionId() uint64
- func (m *RegionHeartbeatResponse) GetSplitRegion() *SplitRegion
- func (m *RegionHeartbeatResponse) GetSwitchWitnesses() *BatchSwitchWitness
- func (m *RegionHeartbeatResponse) GetTargetPeer() *metapb.Peer
- func (m *RegionHeartbeatResponse) GetTransferLeader() *TransferLeader
- func (m *RegionHeartbeatResponse) Marshal() (dAtA []byte, err error)
- func (m *RegionHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RegionHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegionHeartbeatResponse) ProtoMessage()
- func (m *RegionHeartbeatResponse) Reset()
- func (m *RegionHeartbeatResponse) Size() (n int)
- func (m *RegionHeartbeatResponse) String() string
- func (m *RegionHeartbeatResponse) Unmarshal(dAtA []byte) error
- func (m *RegionHeartbeatResponse) XXX_DiscardUnknown()
- func (m *RegionHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegionHeartbeatResponse) XXX_Merge(src proto.Message)
- func (m *RegionHeartbeatResponse) XXX_Size() int
- func (m *RegionHeartbeatResponse) XXX_Unmarshal(b []byte) error
- type RegionStat
- func (*RegionStat) Descriptor() ([]byte, []int)
- func (m *RegionStat) GetBytesRead() uint64
- func (m *RegionStat) GetBytesWritten() uint64
- func (m *RegionStat) GetKeysRead() uint64
- func (m *RegionStat) GetKeysWritten() uint64
- func (m *RegionStat) Marshal() (dAtA []byte, err error)
- func (m *RegionStat) MarshalTo(dAtA []byte) (int, error)
- func (m *RegionStat) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegionStat) ProtoMessage()
- func (m *RegionStat) Reset()
- func (m *RegionStat) Size() (n int)
- func (m *RegionStat) String() string
- func (m *RegionStat) Unmarshal(dAtA []byte) error
- func (m *RegionStat) XXX_DiscardUnknown()
- func (m *RegionStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegionStat) XXX_Merge(src proto.Message)
- func (m *RegionStat) XXX_Size() int
- func (m *RegionStat) XXX_Unmarshal(b []byte) error
- type ReportBatchSplitRequest
- func (*ReportBatchSplitRequest) Descriptor() ([]byte, []int)
- func (m *ReportBatchSplitRequest) GetHeader() *RequestHeader
- func (m *ReportBatchSplitRequest) GetRegions() []*metapb.Region
- func (m *ReportBatchSplitRequest) Marshal() (dAtA []byte, err error)
- func (m *ReportBatchSplitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportBatchSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportBatchSplitRequest) ProtoMessage()
- func (m *ReportBatchSplitRequest) Reset()
- func (m *ReportBatchSplitRequest) Size() (n int)
- func (m *ReportBatchSplitRequest) String() string
- func (m *ReportBatchSplitRequest) Unmarshal(dAtA []byte) error
- func (m *ReportBatchSplitRequest) XXX_DiscardUnknown()
- func (m *ReportBatchSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportBatchSplitRequest) XXX_Merge(src proto.Message)
- func (m *ReportBatchSplitRequest) XXX_Size() int
- func (m *ReportBatchSplitRequest) XXX_Unmarshal(b []byte) error
- type ReportBatchSplitResponse
- func (*ReportBatchSplitResponse) Descriptor() ([]byte, []int)
- func (m *ReportBatchSplitResponse) GetHeader() *ResponseHeader
- func (m *ReportBatchSplitResponse) Marshal() (dAtA []byte, err error)
- func (m *ReportBatchSplitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportBatchSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportBatchSplitResponse) ProtoMessage()
- func (m *ReportBatchSplitResponse) Reset()
- func (m *ReportBatchSplitResponse) Size() (n int)
- func (m *ReportBatchSplitResponse) String() string
- func (m *ReportBatchSplitResponse) Unmarshal(dAtA []byte) error
- func (m *ReportBatchSplitResponse) XXX_DiscardUnknown()
- func (m *ReportBatchSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportBatchSplitResponse) XXX_Merge(src proto.Message)
- func (m *ReportBatchSplitResponse) XXX_Size() int
- func (m *ReportBatchSplitResponse) XXX_Unmarshal(b []byte) error
- type ReportBucketsRequest
- func (*ReportBucketsRequest) Descriptor() ([]byte, []int)
- func (m *ReportBucketsRequest) GetBuckets() *metapb.Buckets
- func (m *ReportBucketsRequest) GetHeader() *RequestHeader
- func (m *ReportBucketsRequest) GetRegionEpoch() *metapb.RegionEpoch
- func (m *ReportBucketsRequest) Marshal() (dAtA []byte, err error)
- func (m *ReportBucketsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportBucketsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportBucketsRequest) ProtoMessage()
- func (m *ReportBucketsRequest) Reset()
- func (m *ReportBucketsRequest) Size() (n int)
- func (m *ReportBucketsRequest) String() string
- func (m *ReportBucketsRequest) Unmarshal(dAtA []byte) error
- func (m *ReportBucketsRequest) XXX_DiscardUnknown()
- func (m *ReportBucketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportBucketsRequest) XXX_Merge(src proto.Message)
- func (m *ReportBucketsRequest) XXX_Size() int
- func (m *ReportBucketsRequest) XXX_Unmarshal(b []byte) error
- type ReportBucketsResponse
- func (*ReportBucketsResponse) Descriptor() ([]byte, []int)
- func (m *ReportBucketsResponse) GetHeader() *ResponseHeader
- func (m *ReportBucketsResponse) Marshal() (dAtA []byte, err error)
- func (m *ReportBucketsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportBucketsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportBucketsResponse) ProtoMessage()
- func (m *ReportBucketsResponse) Reset()
- func (m *ReportBucketsResponse) Size() (n int)
- func (m *ReportBucketsResponse) String() string
- func (m *ReportBucketsResponse) Unmarshal(dAtA []byte) error
- func (m *ReportBucketsResponse) XXX_DiscardUnknown()
- func (m *ReportBucketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportBucketsResponse) XXX_Merge(src proto.Message)
- func (m *ReportBucketsResponse) XXX_Size() int
- func (m *ReportBucketsResponse) XXX_Unmarshal(b []byte) error
- type ReportMinResolvedTsRequest
- func (*ReportMinResolvedTsRequest) Descriptor() ([]byte, []int)
- func (m *ReportMinResolvedTsRequest) GetHeader() *RequestHeader
- func (m *ReportMinResolvedTsRequest) GetMinResolvedTs() uint64
- func (m *ReportMinResolvedTsRequest) GetStoreId() uint64
- func (m *ReportMinResolvedTsRequest) Marshal() (dAtA []byte, err error)
- func (m *ReportMinResolvedTsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportMinResolvedTsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportMinResolvedTsRequest) ProtoMessage()
- func (m *ReportMinResolvedTsRequest) Reset()
- func (m *ReportMinResolvedTsRequest) Size() (n int)
- func (m *ReportMinResolvedTsRequest) String() string
- func (m *ReportMinResolvedTsRequest) Unmarshal(dAtA []byte) error
- func (m *ReportMinResolvedTsRequest) XXX_DiscardUnknown()
- func (m *ReportMinResolvedTsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportMinResolvedTsRequest) XXX_Merge(src proto.Message)
- func (m *ReportMinResolvedTsRequest) XXX_Size() int
- func (m *ReportMinResolvedTsRequest) XXX_Unmarshal(b []byte) error
- type ReportMinResolvedTsResponse
- func (*ReportMinResolvedTsResponse) Descriptor() ([]byte, []int)
- func (m *ReportMinResolvedTsResponse) GetHeader() *ResponseHeader
- func (m *ReportMinResolvedTsResponse) Marshal() (dAtA []byte, err error)
- func (m *ReportMinResolvedTsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportMinResolvedTsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportMinResolvedTsResponse) ProtoMessage()
- func (m *ReportMinResolvedTsResponse) Reset()
- func (m *ReportMinResolvedTsResponse) Size() (n int)
- func (m *ReportMinResolvedTsResponse) String() string
- func (m *ReportMinResolvedTsResponse) Unmarshal(dAtA []byte) error
- func (m *ReportMinResolvedTsResponse) XXX_DiscardUnknown()
- func (m *ReportMinResolvedTsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportMinResolvedTsResponse) XXX_Merge(src proto.Message)
- func (m *ReportMinResolvedTsResponse) XXX_Size() int
- func (m *ReportMinResolvedTsResponse) XXX_Unmarshal(b []byte) error
- type ReportSplitRequest
- func (*ReportSplitRequest) Descriptor() ([]byte, []int)
- func (m *ReportSplitRequest) GetHeader() *RequestHeader
- func (m *ReportSplitRequest) GetLeft() *metapb.Region
- func (m *ReportSplitRequest) GetRight() *metapb.Region
- func (m *ReportSplitRequest) Marshal() (dAtA []byte, err error)
- func (m *ReportSplitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportSplitRequest) ProtoMessage()
- func (m *ReportSplitRequest) Reset()
- func (m *ReportSplitRequest) Size() (n int)
- func (m *ReportSplitRequest) String() string
- func (m *ReportSplitRequest) Unmarshal(dAtA []byte) error
- func (m *ReportSplitRequest) XXX_DiscardUnknown()
- func (m *ReportSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportSplitRequest) XXX_Merge(src proto.Message)
- func (m *ReportSplitRequest) XXX_Size() int
- func (m *ReportSplitRequest) XXX_Unmarshal(b []byte) error
- type ReportSplitResponse
- func (*ReportSplitResponse) Descriptor() ([]byte, []int)
- func (m *ReportSplitResponse) GetHeader() *ResponseHeader
- func (m *ReportSplitResponse) Marshal() (dAtA []byte, err error)
- func (m *ReportSplitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReportSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReportSplitResponse) ProtoMessage()
- func (m *ReportSplitResponse) Reset()
- func (m *ReportSplitResponse) Size() (n int)
- func (m *ReportSplitResponse) String() string
- func (m *ReportSplitResponse) Unmarshal(dAtA []byte) error
- func (m *ReportSplitResponse) XXX_DiscardUnknown()
- func (m *ReportSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReportSplitResponse) XXX_Merge(src proto.Message)
- func (m *ReportSplitResponse) XXX_Size() int
- func (m *ReportSplitResponse) XXX_Unmarshal(b []byte) error
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)
- func (m *RequestHeader) GetClusterId() uint64
- func (m *RequestHeader) GetSenderId() uint64
- func (m *RequestHeader) Marshal() (dAtA []byte, err error)
- func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequestHeader) ProtoMessage()
- func (m *RequestHeader) Reset()
- func (m *RequestHeader) Size() (n int)
- func (m *RequestHeader) String() string
- func (m *RequestHeader) Unmarshal(dAtA []byte) error
- func (m *RequestHeader) XXX_DiscardUnknown()
- func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestHeader) XXX_Merge(src proto.Message)
- func (m *RequestHeader) XXX_Size() int
- func (m *RequestHeader) XXX_Unmarshal(b []byte) error
- type ResponseHeader
- func (*ResponseHeader) Descriptor() ([]byte, []int)
- func (m *ResponseHeader) GetClusterId() uint64
- func (m *ResponseHeader) GetError() *Error
- func (m *ResponseHeader) Marshal() (dAtA []byte, err error)
- func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResponseHeader) ProtoMessage()
- func (m *ResponseHeader) Reset()
- func (m *ResponseHeader) Size() (n int)
- func (m *ResponseHeader) String() string
- func (m *ResponseHeader) Unmarshal(dAtA []byte) error
- func (m *ResponseHeader) XXX_DiscardUnknown()
- func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseHeader) XXX_Merge(src proto.Message)
- func (m *ResponseHeader) XXX_Size() int
- func (m *ResponseHeader) XXX_Unmarshal(b []byte) error
- type SafePointEvent
- func (*SafePointEvent) Descriptor() ([]byte, []int)
- func (m *SafePointEvent) GetKeyspaceId() uint32
- func (m *SafePointEvent) GetSafePoint() uint64
- func (m *SafePointEvent) GetType() EventType
- func (m *SafePointEvent) Marshal() (dAtA []byte, err error)
- func (m *SafePointEvent) MarshalTo(dAtA []byte) (int, error)
- func (m *SafePointEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SafePointEvent) ProtoMessage()
- func (m *SafePointEvent) Reset()
- func (m *SafePointEvent) Size() (n int)
- func (m *SafePointEvent) String() string
- func (m *SafePointEvent) Unmarshal(dAtA []byte) error
- func (m *SafePointEvent) XXX_DiscardUnknown()
- func (m *SafePointEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SafePointEvent) XXX_Merge(src proto.Message)
- func (m *SafePointEvent) XXX_Size() int
- func (m *SafePointEvent) XXX_Unmarshal(b []byte) error
- type ScanRegionsRequest
- func (*ScanRegionsRequest) Descriptor() ([]byte, []int)
- func (m *ScanRegionsRequest) GetEndKey() []byte
- func (m *ScanRegionsRequest) GetHeader() *RequestHeader
- func (m *ScanRegionsRequest) GetLimit() int32
- func (m *ScanRegionsRequest) GetStartKey() []byte
- func (m *ScanRegionsRequest) Marshal() (dAtA []byte, err error)
- func (m *ScanRegionsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ScanRegionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ScanRegionsRequest) ProtoMessage()
- func (m *ScanRegionsRequest) Reset()
- func (m *ScanRegionsRequest) Size() (n int)
- func (m *ScanRegionsRequest) String() string
- func (m *ScanRegionsRequest) Unmarshal(dAtA []byte) error
- func (m *ScanRegionsRequest) XXX_DiscardUnknown()
- func (m *ScanRegionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScanRegionsRequest) XXX_Merge(src proto.Message)
- func (m *ScanRegionsRequest) XXX_Size() int
- func (m *ScanRegionsRequest) XXX_Unmarshal(b []byte) error
- type ScanRegionsResponse
- func (*ScanRegionsResponse) Descriptor() ([]byte, []int)
- func (m *ScanRegionsResponse) GetHeader() *ResponseHeader
- func (m *ScanRegionsResponse) GetLeaders() []*metapb.Peer
- func (m *ScanRegionsResponse) GetRegionMetas() []*metapb.Region
- func (m *ScanRegionsResponse) GetRegions() []*Region
- func (m *ScanRegionsResponse) Marshal() (dAtA []byte, err error)
- func (m *ScanRegionsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ScanRegionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ScanRegionsResponse) ProtoMessage()
- func (m *ScanRegionsResponse) Reset()
- func (m *ScanRegionsResponse) Size() (n int)
- func (m *ScanRegionsResponse) String() string
- func (m *ScanRegionsResponse) Unmarshal(dAtA []byte) error
- func (m *ScanRegionsResponse) XXX_DiscardUnknown()
- func (m *ScanRegionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScanRegionsResponse) XXX_Merge(src proto.Message)
- func (m *ScanRegionsResponse) XXX_Size() int
- func (m *ScanRegionsResponse) XXX_Unmarshal(b []byte) error
- type ScatterRegionRequest
- func (*ScatterRegionRequest) Descriptor() ([]byte, []int)
- func (m *ScatterRegionRequest) GetGroup() string
- func (m *ScatterRegionRequest) GetHeader() *RequestHeader
- func (m *ScatterRegionRequest) GetLeader() *metapb.Peer
- func (m *ScatterRegionRequest) GetRegion() *metapb.Region
- func (m *ScatterRegionRequest) GetRegionId() uint64deprecated
- func (m *ScatterRegionRequest) GetRegionsId() []uint64
- func (m *ScatterRegionRequest) GetRetryLimit() uint64
- func (m *ScatterRegionRequest) Marshal() (dAtA []byte, err error)
- func (m *ScatterRegionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ScatterRegionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ScatterRegionRequest) ProtoMessage()
- func (m *ScatterRegionRequest) Reset()
- func (m *ScatterRegionRequest) Size() (n int)
- func (m *ScatterRegionRequest) String() string
- func (m *ScatterRegionRequest) Unmarshal(dAtA []byte) error
- func (m *ScatterRegionRequest) XXX_DiscardUnknown()
- func (m *ScatterRegionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScatterRegionRequest) XXX_Merge(src proto.Message)
- func (m *ScatterRegionRequest) XXX_Size() int
- func (m *ScatterRegionRequest) XXX_Unmarshal(b []byte) error
- type ScatterRegionResponse
- func (*ScatterRegionResponse) Descriptor() ([]byte, []int)
- func (m *ScatterRegionResponse) GetFinishedPercentage() uint64
- func (m *ScatterRegionResponse) GetHeader() *ResponseHeader
- func (m *ScatterRegionResponse) Marshal() (dAtA []byte, err error)
- func (m *ScatterRegionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ScatterRegionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ScatterRegionResponse) ProtoMessage()
- func (m *ScatterRegionResponse) Reset()
- func (m *ScatterRegionResponse) Size() (n int)
- func (m *ScatterRegionResponse) String() string
- func (m *ScatterRegionResponse) Unmarshal(dAtA []byte) error
- func (m *ScatterRegionResponse) XXX_DiscardUnknown()
- func (m *ScatterRegionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScatterRegionResponse) XXX_Merge(src proto.Message)
- func (m *ScatterRegionResponse) XXX_Size() int
- func (m *ScatterRegionResponse) XXX_Unmarshal(b []byte) error
- type ServiceMode
- type SetExternalTimestampRequest
- func (*SetExternalTimestampRequest) Descriptor() ([]byte, []int)
- func (m *SetExternalTimestampRequest) GetHeader() *RequestHeader
- func (m *SetExternalTimestampRequest) GetTimestamp() uint64
- func (m *SetExternalTimestampRequest) Marshal() (dAtA []byte, err error)
- func (m *SetExternalTimestampRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SetExternalTimestampRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetExternalTimestampRequest) ProtoMessage()
- func (m *SetExternalTimestampRequest) Reset()
- func (m *SetExternalTimestampRequest) Size() (n int)
- func (m *SetExternalTimestampRequest) String() string
- func (m *SetExternalTimestampRequest) Unmarshal(dAtA []byte) error
- func (m *SetExternalTimestampRequest) XXX_DiscardUnknown()
- func (m *SetExternalTimestampRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetExternalTimestampRequest) XXX_Merge(src proto.Message)
- func (m *SetExternalTimestampRequest) XXX_Size() int
- func (m *SetExternalTimestampRequest) XXX_Unmarshal(b []byte) error
- type SetExternalTimestampResponse
- func (*SetExternalTimestampResponse) Descriptor() ([]byte, []int)
- func (m *SetExternalTimestampResponse) GetHeader() *ResponseHeader
- func (m *SetExternalTimestampResponse) Marshal() (dAtA []byte, err error)
- func (m *SetExternalTimestampResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SetExternalTimestampResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SetExternalTimestampResponse) ProtoMessage()
- func (m *SetExternalTimestampResponse) Reset()
- func (m *SetExternalTimestampResponse) Size() (n int)
- func (m *SetExternalTimestampResponse) String() string
- func (m *SetExternalTimestampResponse) Unmarshal(dAtA []byte) error
- func (m *SetExternalTimestampResponse) XXX_DiscardUnknown()
- func (m *SetExternalTimestampResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SetExternalTimestampResponse) XXX_Merge(src proto.Message)
- func (m *SetExternalTimestampResponse) XXX_Size() int
- func (m *SetExternalTimestampResponse) XXX_Unmarshal(b []byte) error
- type SlowTrend
- func (*SlowTrend) Descriptor() ([]byte, []int)
- func (m *SlowTrend) GetCauseRate() float64
- func (m *SlowTrend) GetCauseValue() float64
- func (m *SlowTrend) GetResultRate() float64
- func (m *SlowTrend) GetResultValue() float64
- func (m *SlowTrend) Marshal() (dAtA []byte, err error)
- func (m *SlowTrend) MarshalTo(dAtA []byte) (int, error)
- func (m *SlowTrend) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SlowTrend) ProtoMessage()
- func (m *SlowTrend) Reset()
- func (m *SlowTrend) Size() (n int)
- func (m *SlowTrend) String() string
- func (m *SlowTrend) Unmarshal(dAtA []byte) error
- func (m *SlowTrend) XXX_DiscardUnknown()
- func (m *SlowTrend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SlowTrend) XXX_Merge(src proto.Message)
- func (m *SlowTrend) XXX_Size() int
- func (m *SlowTrend) XXX_Unmarshal(b []byte) error
- type SnapshotStat
- func (*SnapshotStat) Descriptor() ([]byte, []int)
- func (m *SnapshotStat) GetGenerateDurationSec() uint64
- func (m *SnapshotStat) GetRegionId() uint64
- func (m *SnapshotStat) GetSendDurationSec() uint64
- func (m *SnapshotStat) GetTotalDurationSec() uint64
- func (m *SnapshotStat) GetTransportSize() uint64
- func (m *SnapshotStat) Marshal() (dAtA []byte, err error)
- func (m *SnapshotStat) MarshalTo(dAtA []byte) (int, error)
- func (m *SnapshotStat) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SnapshotStat) ProtoMessage()
- func (m *SnapshotStat) Reset()
- func (m *SnapshotStat) Size() (n int)
- func (m *SnapshotStat) String() string
- func (m *SnapshotStat) Unmarshal(dAtA []byte) error
- func (m *SnapshotStat) XXX_DiscardUnknown()
- func (m *SnapshotStat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SnapshotStat) XXX_Merge(src proto.Message)
- func (m *SnapshotStat) XXX_Size() int
- func (m *SnapshotStat) XXX_Unmarshal(b []byte) error
- type SplitAndScatterRegionsRequest
- func (*SplitAndScatterRegionsRequest) Descriptor() ([]byte, []int)
- func (m *SplitAndScatterRegionsRequest) GetGroup() string
- func (m *SplitAndScatterRegionsRequest) GetHeader() *RequestHeader
- func (m *SplitAndScatterRegionsRequest) GetRetryLimit() uint64
- func (m *SplitAndScatterRegionsRequest) GetSplitKeys() [][]byte
- func (m *SplitAndScatterRegionsRequest) Marshal() (dAtA []byte, err error)
- func (m *SplitAndScatterRegionsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SplitAndScatterRegionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SplitAndScatterRegionsRequest) ProtoMessage()
- func (m *SplitAndScatterRegionsRequest) Reset()
- func (m *SplitAndScatterRegionsRequest) Size() (n int)
- func (m *SplitAndScatterRegionsRequest) String() string
- func (m *SplitAndScatterRegionsRequest) Unmarshal(dAtA []byte) error
- func (m *SplitAndScatterRegionsRequest) XXX_DiscardUnknown()
- func (m *SplitAndScatterRegionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SplitAndScatterRegionsRequest) XXX_Merge(src proto.Message)
- func (m *SplitAndScatterRegionsRequest) XXX_Size() int
- func (m *SplitAndScatterRegionsRequest) XXX_Unmarshal(b []byte) error
- type SplitAndScatterRegionsResponse
- func (*SplitAndScatterRegionsResponse) Descriptor() ([]byte, []int)
- func (m *SplitAndScatterRegionsResponse) GetHeader() *ResponseHeader
- func (m *SplitAndScatterRegionsResponse) GetRegionsId() []uint64
- func (m *SplitAndScatterRegionsResponse) GetScatterFinishedPercentage() uint64
- func (m *SplitAndScatterRegionsResponse) GetSplitFinishedPercentage() uint64
- func (m *SplitAndScatterRegionsResponse) Marshal() (dAtA []byte, err error)
- func (m *SplitAndScatterRegionsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SplitAndScatterRegionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SplitAndScatterRegionsResponse) ProtoMessage()
- func (m *SplitAndScatterRegionsResponse) Reset()
- func (m *SplitAndScatterRegionsResponse) Size() (n int)
- func (m *SplitAndScatterRegionsResponse) String() string
- func (m *SplitAndScatterRegionsResponse) Unmarshal(dAtA []byte) error
- func (m *SplitAndScatterRegionsResponse) XXX_DiscardUnknown()
- func (m *SplitAndScatterRegionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SplitAndScatterRegionsResponse) XXX_Merge(src proto.Message)
- func (m *SplitAndScatterRegionsResponse) XXX_Size() int
- func (m *SplitAndScatterRegionsResponse) XXX_Unmarshal(b []byte) error
- type SplitID
- func (*SplitID) Descriptor() ([]byte, []int)
- func (m *SplitID) GetNewPeerIds() []uint64
- func (m *SplitID) GetNewRegionId() uint64
- func (m *SplitID) Marshal() (dAtA []byte, err error)
- func (m *SplitID) MarshalTo(dAtA []byte) (int, error)
- func (m *SplitID) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SplitID) ProtoMessage()
- func (m *SplitID) Reset()
- func (m *SplitID) Size() (n int)
- func (m *SplitID) String() string
- func (m *SplitID) Unmarshal(dAtA []byte) error
- func (m *SplitID) XXX_DiscardUnknown()
- func (m *SplitID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SplitID) XXX_Merge(src proto.Message)
- func (m *SplitID) XXX_Size() int
- func (m *SplitID) XXX_Unmarshal(b []byte) error
- type SplitRegion
- func (*SplitRegion) Descriptor() ([]byte, []int)
- func (m *SplitRegion) GetKeys() [][]byte
- func (m *SplitRegion) GetPolicy() CheckPolicy
- func (m *SplitRegion) Marshal() (dAtA []byte, err error)
- func (m *SplitRegion) MarshalTo(dAtA []byte) (int, error)
- func (m *SplitRegion) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SplitRegion) ProtoMessage()
- func (m *SplitRegion) Reset()
- func (m *SplitRegion) Size() (n int)
- func (m *SplitRegion) String() string
- func (m *SplitRegion) Unmarshal(dAtA []byte) error
- func (m *SplitRegion) XXX_DiscardUnknown()
- func (m *SplitRegion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SplitRegion) XXX_Merge(src proto.Message)
- func (m *SplitRegion) XXX_Size() int
- func (m *SplitRegion) XXX_Unmarshal(b []byte) error
- type SplitRegionsRequest
- func (*SplitRegionsRequest) Descriptor() ([]byte, []int)
- func (m *SplitRegionsRequest) GetHeader() *RequestHeader
- func (m *SplitRegionsRequest) GetRetryLimit() uint64
- func (m *SplitRegionsRequest) GetSplitKeys() [][]byte
- func (m *SplitRegionsRequest) Marshal() (dAtA []byte, err error)
- func (m *SplitRegionsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SplitRegionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SplitRegionsRequest) ProtoMessage()
- func (m *SplitRegionsRequest) Reset()
- func (m *SplitRegionsRequest) Size() (n int)
- func (m *SplitRegionsRequest) String() string
- func (m *SplitRegionsRequest) Unmarshal(dAtA []byte) error
- func (m *SplitRegionsRequest) XXX_DiscardUnknown()
- func (m *SplitRegionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SplitRegionsRequest) XXX_Merge(src proto.Message)
- func (m *SplitRegionsRequest) XXX_Size() int
- func (m *SplitRegionsRequest) XXX_Unmarshal(b []byte) error
- type SplitRegionsResponse
- func (*SplitRegionsResponse) Descriptor() ([]byte, []int)
- func (m *SplitRegionsResponse) GetFinishedPercentage() uint64
- func (m *SplitRegionsResponse) GetHeader() *ResponseHeader
- func (m *SplitRegionsResponse) GetRegionsId() []uint64
- func (m *SplitRegionsResponse) Marshal() (dAtA []byte, err error)
- func (m *SplitRegionsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SplitRegionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SplitRegionsResponse) ProtoMessage()
- func (m *SplitRegionsResponse) Reset()
- func (m *SplitRegionsResponse) Size() (n int)
- func (m *SplitRegionsResponse) String() string
- func (m *SplitRegionsResponse) Unmarshal(dAtA []byte) error
- func (m *SplitRegionsResponse) XXX_DiscardUnknown()
- func (m *SplitRegionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SplitRegionsResponse) XXX_Merge(src proto.Message)
- func (m *SplitRegionsResponse) XXX_Size() int
- func (m *SplitRegionsResponse) XXX_Unmarshal(b []byte) error
- type StoreGlobalConfigRequest
- func (*StoreGlobalConfigRequest) Descriptor() ([]byte, []int)
- func (m *StoreGlobalConfigRequest) GetChanges() []*GlobalConfigItem
- func (m *StoreGlobalConfigRequest) GetConfigPath() string
- func (m *StoreGlobalConfigRequest) Marshal() (dAtA []byte, err error)
- func (m *StoreGlobalConfigRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StoreGlobalConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StoreGlobalConfigRequest) ProtoMessage()
- func (m *StoreGlobalConfigRequest) Reset()
- func (m *StoreGlobalConfigRequest) Size() (n int)
- func (m *StoreGlobalConfigRequest) String() string
- func (m *StoreGlobalConfigRequest) Unmarshal(dAtA []byte) error
- func (m *StoreGlobalConfigRequest) XXX_DiscardUnknown()
- func (m *StoreGlobalConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StoreGlobalConfigRequest) XXX_Merge(src proto.Message)
- func (m *StoreGlobalConfigRequest) XXX_Size() int
- func (m *StoreGlobalConfigRequest) XXX_Unmarshal(b []byte) error
- type StoreGlobalConfigResponse
- func (*StoreGlobalConfigResponse) Descriptor() ([]byte, []int)
- func (m *StoreGlobalConfigResponse) GetError() *Error
- func (m *StoreGlobalConfigResponse) Marshal() (dAtA []byte, err error)
- func (m *StoreGlobalConfigResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StoreGlobalConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StoreGlobalConfigResponse) ProtoMessage()
- func (m *StoreGlobalConfigResponse) Reset()
- func (m *StoreGlobalConfigResponse) Size() (n int)
- func (m *StoreGlobalConfigResponse) String() string
- func (m *StoreGlobalConfigResponse) Unmarshal(dAtA []byte) error
- func (m *StoreGlobalConfigResponse) XXX_DiscardUnknown()
- func (m *StoreGlobalConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StoreGlobalConfigResponse) XXX_Merge(src proto.Message)
- func (m *StoreGlobalConfigResponse) XXX_Size() int
- func (m *StoreGlobalConfigResponse) XXX_Unmarshal(b []byte) error
- type StoreHeartbeatRequest
- func (*StoreHeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *StoreHeartbeatRequest) GetDrAutosyncStatus() *replication_modepb.StoreDRAutoSyncStatus
- func (m *StoreHeartbeatRequest) GetHeader() *RequestHeader
- func (m *StoreHeartbeatRequest) GetStats() *StoreStats
- func (m *StoreHeartbeatRequest) GetStoreReport() *StoreReport
- func (m *StoreHeartbeatRequest) Marshal() (dAtA []byte, err error)
- func (m *StoreHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StoreHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StoreHeartbeatRequest) ProtoMessage()
- func (m *StoreHeartbeatRequest) Reset()
- func (m *StoreHeartbeatRequest) Size() (n int)
- func (m *StoreHeartbeatRequest) String() string
- func (m *StoreHeartbeatRequest) Unmarshal(dAtA []byte) error
- func (m *StoreHeartbeatRequest) XXX_DiscardUnknown()
- func (m *StoreHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StoreHeartbeatRequest) XXX_Merge(src proto.Message)
- func (m *StoreHeartbeatRequest) XXX_Size() int
- func (m *StoreHeartbeatRequest) XXX_Unmarshal(b []byte) error
- type StoreHeartbeatResponse
- func (*StoreHeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *StoreHeartbeatResponse) GetAwakenRegions() *AwakenRegions
- func (m *StoreHeartbeatResponse) GetClusterVersion() string
- func (m *StoreHeartbeatResponse) GetHeader() *ResponseHeader
- func (m *StoreHeartbeatResponse) GetRecoveryPlan() *RecoveryPlan
- func (m *StoreHeartbeatResponse) GetReplicationStatus() *replication_modepb.ReplicationStatus
- func (m *StoreHeartbeatResponse) GetRequireDetailedReport() booldeprecated
- func (m *StoreHeartbeatResponse) Marshal() (dAtA []byte, err error)
- func (m *StoreHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StoreHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StoreHeartbeatResponse) ProtoMessage()
- func (m *StoreHeartbeatResponse) Reset()
- func (m *StoreHeartbeatResponse) Size() (n int)
- func (m *StoreHeartbeatResponse) String() string
- func (m *StoreHeartbeatResponse) Unmarshal(dAtA []byte) error
- func (m *StoreHeartbeatResponse) XXX_DiscardUnknown()
- func (m *StoreHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StoreHeartbeatResponse) XXX_Merge(src proto.Message)
- func (m *StoreHeartbeatResponse) XXX_Size() int
- func (m *StoreHeartbeatResponse) XXX_Unmarshal(b []byte) error
- type StoreReport
- func (*StoreReport) Descriptor() ([]byte, []int)
- func (m *StoreReport) GetPeerReports() []*PeerReport
- func (m *StoreReport) GetStep() uint64
- func (m *StoreReport) Marshal() (dAtA []byte, err error)
- func (m *StoreReport) MarshalTo(dAtA []byte) (int, error)
- func (m *StoreReport) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StoreReport) ProtoMessage()
- func (m *StoreReport) Reset()
- func (m *StoreReport) Size() (n int)
- func (m *StoreReport) String() string
- func (m *StoreReport) Unmarshal(dAtA []byte) error
- func (m *StoreReport) XXX_DiscardUnknown()
- func (m *StoreReport) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StoreReport) XXX_Merge(src proto.Message)
- func (m *StoreReport) XXX_Size() int
- func (m *StoreReport) XXX_Unmarshal(b []byte) error
- type StoreStats
- func (*StoreStats) Descriptor() ([]byte, []int)
- func (m *StoreStats) GetApplyingSnapCount() uint32
- func (m *StoreStats) GetAvailable() uint64
- func (m *StoreStats) GetBytesRead() uint64
- func (m *StoreStats) GetBytesWritten() uint64
- func (m *StoreStats) GetCapacity() uint64
- func (m *StoreStats) GetCpuUsages() []*RecordPair
- func (m *StoreStats) GetDamagedRegionsId() []uint64
- func (m *StoreStats) GetInterval() *TimeInterval
- func (m *StoreStats) GetIsApplyBusy() bool
- func (m *StoreStats) GetIsBusy() bool
- func (m *StoreStats) GetKeysRead() uint64
- func (m *StoreStats) GetKeysWritten() uint64
- func (m *StoreStats) GetOpLatencies() []*RecordPair
- func (m *StoreStats) GetPeerStats() []*PeerStat
- func (m *StoreStats) GetQueryStats() *QueryStats
- func (m *StoreStats) GetReadIoRates() []*RecordPair
- func (m *StoreStats) GetReceivingSnapCount() uint32
- func (m *StoreStats) GetRegionCount() uint32
- func (m *StoreStats) GetSendingSnapCount() uint32
- func (m *StoreStats) GetSlowScore() uint64
- func (m *StoreStats) GetSlowTrend() *SlowTrend
- func (m *StoreStats) GetSnapshotStats() []*SnapshotStat
- func (m *StoreStats) GetStartTime() uint32
- func (m *StoreStats) GetStoreId() uint64
- func (m *StoreStats) GetUsedSize() uint64
- func (m *StoreStats) GetWriteIoRates() []*RecordPair
- func (m *StoreStats) Marshal() (dAtA []byte, err error)
- func (m *StoreStats) MarshalTo(dAtA []byte) (int, error)
- func (m *StoreStats) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StoreStats) ProtoMessage()
- func (m *StoreStats) Reset()
- func (m *StoreStats) Size() (n int)
- func (m *StoreStats) String() string
- func (m *StoreStats) Unmarshal(dAtA []byte) error
- func (m *StoreStats) XXX_DiscardUnknown()
- func (m *StoreStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StoreStats) XXX_Merge(src proto.Message)
- func (m *StoreStats) XXX_Size() int
- func (m *StoreStats) XXX_Unmarshal(b []byte) error
- type SwitchWitness
- func (*SwitchWitness) Descriptor() ([]byte, []int)
- func (m *SwitchWitness) GetIsWitness() bool
- func (m *SwitchWitness) GetPeerId() uint64
- func (m *SwitchWitness) Marshal() (dAtA []byte, err error)
- func (m *SwitchWitness) MarshalTo(dAtA []byte) (int, error)
- func (m *SwitchWitness) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SwitchWitness) ProtoMessage()
- func (m *SwitchWitness) Reset()
- func (m *SwitchWitness) Size() (n int)
- func (m *SwitchWitness) String() string
- func (m *SwitchWitness) Unmarshal(dAtA []byte) error
- func (m *SwitchWitness) XXX_DiscardUnknown()
- func (m *SwitchWitness) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SwitchWitness) XXX_Merge(src proto.Message)
- func (m *SwitchWitness) XXX_Size() int
- func (m *SwitchWitness) XXX_Unmarshal(b []byte) error
- type SyncMaxTSRequest
- func (*SyncMaxTSRequest) Descriptor() ([]byte, []int)
- func (m *SyncMaxTSRequest) GetHeader() *RequestHeader
- func (m *SyncMaxTSRequest) GetMaxTs() *Timestamp
- func (m *SyncMaxTSRequest) GetSkipCheck() bool
- func (m *SyncMaxTSRequest) Marshal() (dAtA []byte, err error)
- func (m *SyncMaxTSRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncMaxTSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncMaxTSRequest) ProtoMessage()
- func (m *SyncMaxTSRequest) Reset()
- func (m *SyncMaxTSRequest) Size() (n int)
- func (m *SyncMaxTSRequest) String() string
- func (m *SyncMaxTSRequest) Unmarshal(dAtA []byte) error
- func (m *SyncMaxTSRequest) XXX_DiscardUnknown()
- func (m *SyncMaxTSRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncMaxTSRequest) XXX_Merge(src proto.Message)
- func (m *SyncMaxTSRequest) XXX_Size() int
- func (m *SyncMaxTSRequest) XXX_Unmarshal(b []byte) error
- type SyncMaxTSResponse
- func (*SyncMaxTSResponse) Descriptor() ([]byte, []int)
- func (m *SyncMaxTSResponse) GetHeader() *ResponseHeader
- func (m *SyncMaxTSResponse) GetMaxLocalTs() *Timestamp
- func (m *SyncMaxTSResponse) GetSyncedDcs() []string
- func (m *SyncMaxTSResponse) Marshal() (dAtA []byte, err error)
- func (m *SyncMaxTSResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncMaxTSResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncMaxTSResponse) ProtoMessage()
- func (m *SyncMaxTSResponse) Reset()
- func (m *SyncMaxTSResponse) Size() (n int)
- func (m *SyncMaxTSResponse) String() string
- func (m *SyncMaxTSResponse) Unmarshal(dAtA []byte) error
- func (m *SyncMaxTSResponse) XXX_DiscardUnknown()
- func (m *SyncMaxTSResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncMaxTSResponse) XXX_Merge(src proto.Message)
- func (m *SyncMaxTSResponse) XXX_Size() int
- func (m *SyncMaxTSResponse) XXX_Unmarshal(b []byte) error
- type SyncRegionRequest
- func (*SyncRegionRequest) Descriptor() ([]byte, []int)
- func (m *SyncRegionRequest) GetHeader() *RequestHeader
- func (m *SyncRegionRequest) GetMember() *Member
- func (m *SyncRegionRequest) GetStartIndex() uint64
- func (m *SyncRegionRequest) Marshal() (dAtA []byte, err error)
- func (m *SyncRegionRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncRegionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncRegionRequest) ProtoMessage()
- func (m *SyncRegionRequest) Reset()
- func (m *SyncRegionRequest) Size() (n int)
- func (m *SyncRegionRequest) String() string
- func (m *SyncRegionRequest) Unmarshal(dAtA []byte) error
- func (m *SyncRegionRequest) XXX_DiscardUnknown()
- func (m *SyncRegionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRegionRequest) XXX_Merge(src proto.Message)
- func (m *SyncRegionRequest) XXX_Size() int
- func (m *SyncRegionRequest) XXX_Unmarshal(b []byte) error
- type SyncRegionResponse
- func (*SyncRegionResponse) Descriptor() ([]byte, []int)
- func (m *SyncRegionResponse) GetBuckets() []*metapb.Buckets
- func (m *SyncRegionResponse) GetDownPeers() []*PeersStats
- func (m *SyncRegionResponse) GetHeader() *ResponseHeader
- func (m *SyncRegionResponse) GetPendingPeers() []*Peers
- func (m *SyncRegionResponse) GetRegionLeaders() []*metapb.Peer
- func (m *SyncRegionResponse) GetRegionStats() []*RegionStat
- func (m *SyncRegionResponse) GetRegions() []*metapb.Region
- func (m *SyncRegionResponse) GetStartIndex() uint64
- func (m *SyncRegionResponse) Marshal() (dAtA []byte, err error)
- func (m *SyncRegionResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *SyncRegionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SyncRegionResponse) ProtoMessage()
- func (m *SyncRegionResponse) Reset()
- func (m *SyncRegionResponse) Size() (n int)
- func (m *SyncRegionResponse) String() string
- func (m *SyncRegionResponse) Unmarshal(dAtA []byte) error
- func (m *SyncRegionResponse) XXX_DiscardUnknown()
- func (m *SyncRegionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SyncRegionResponse) XXX_Merge(src proto.Message)
- func (m *SyncRegionResponse) XXX_Size() int
- func (m *SyncRegionResponse) XXX_Unmarshal(b []byte) error
- type TimeInterval
- func (*TimeInterval) Descriptor() ([]byte, []int)
- func (m *TimeInterval) GetEndTimestamp() uint64
- func (m *TimeInterval) GetStartTimestamp() uint64
- func (m *TimeInterval) Marshal() (dAtA []byte, err error)
- func (m *TimeInterval) MarshalTo(dAtA []byte) (int, error)
- func (m *TimeInterval) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TimeInterval) ProtoMessage()
- func (m *TimeInterval) Reset()
- func (m *TimeInterval) Size() (n int)
- func (m *TimeInterval) String() string
- func (m *TimeInterval) Unmarshal(dAtA []byte) error
- func (m *TimeInterval) XXX_DiscardUnknown()
- func (m *TimeInterval) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeInterval) XXX_Merge(src proto.Message)
- func (m *TimeInterval) XXX_Size() int
- func (m *TimeInterval) XXX_Unmarshal(b []byte) error
- type Timestamp
- func (*Timestamp) Descriptor() ([]byte, []int)
- func (m *Timestamp) GetLogical() int64
- func (m *Timestamp) GetPhysical() int64
- func (m *Timestamp) GetSuffixBits() uint32
- func (m *Timestamp) Marshal() (dAtA []byte, err error)
- func (m *Timestamp) MarshalTo(dAtA []byte) (int, error)
- func (m *Timestamp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Timestamp) ProtoMessage()
- func (m *Timestamp) Reset()
- func (m *Timestamp) Size() (n int)
- func (m *Timestamp) String() string
- func (m *Timestamp) Unmarshal(dAtA []byte) error
- func (m *Timestamp) XXX_DiscardUnknown()
- func (m *Timestamp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Timestamp) XXX_Merge(src proto.Message)
- func (m *Timestamp) XXX_Size() int
- func (m *Timestamp) XXX_Unmarshal(b []byte) error
- type TransferLeader
- func (*TransferLeader) Descriptor() ([]byte, []int)
- func (m *TransferLeader) GetPeer() *metapb.Peer
- func (m *TransferLeader) GetPeers() []*metapb.Peer
- func (m *TransferLeader) Marshal() (dAtA []byte, err error)
- func (m *TransferLeader) MarshalTo(dAtA []byte) (int, error)
- func (m *TransferLeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TransferLeader) ProtoMessage()
- func (m *TransferLeader) Reset()
- func (m *TransferLeader) Size() (n int)
- func (m *TransferLeader) String() string
- func (m *TransferLeader) Unmarshal(dAtA []byte) error
- func (m *TransferLeader) XXX_DiscardUnknown()
- func (m *TransferLeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransferLeader) XXX_Merge(src proto.Message)
- func (m *TransferLeader) XXX_Size() int
- func (m *TransferLeader) XXX_Unmarshal(b []byte) error
- type TsoRequest
- func (*TsoRequest) Descriptor() ([]byte, []int)
- func (m *TsoRequest) GetCount() uint32
- func (m *TsoRequest) GetDcLocation() string
- func (m *TsoRequest) GetHeader() *RequestHeader
- func (m *TsoRequest) Marshal() (dAtA []byte, err error)
- func (m *TsoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *TsoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TsoRequest) ProtoMessage()
- func (m *TsoRequest) Reset()
- func (m *TsoRequest) Size() (n int)
- func (m *TsoRequest) String() string
- func (m *TsoRequest) Unmarshal(dAtA []byte) error
- func (m *TsoRequest) XXX_DiscardUnknown()
- func (m *TsoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TsoRequest) XXX_Merge(src proto.Message)
- func (m *TsoRequest) XXX_Size() int
- func (m *TsoRequest) XXX_Unmarshal(b []byte) error
- type TsoResponse
- func (*TsoResponse) Descriptor() ([]byte, []int)
- func (m *TsoResponse) GetCount() uint32
- func (m *TsoResponse) GetHeader() *ResponseHeader
- func (m *TsoResponse) GetTimestamp() *Timestamp
- func (m *TsoResponse) Marshal() (dAtA []byte, err error)
- func (m *TsoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *TsoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TsoResponse) ProtoMessage()
- func (m *TsoResponse) Reset()
- func (m *TsoResponse) Size() (n int)
- func (m *TsoResponse) String() string
- func (m *TsoResponse) Unmarshal(dAtA []byte) error
- func (m *TsoResponse) XXX_DiscardUnknown()
- func (m *TsoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TsoResponse) XXX_Merge(src proto.Message)
- func (m *TsoResponse) XXX_Size() int
- func (m *TsoResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedPDServer
- func (*UnimplementedPDServer) AllocID(ctx context.Context, req *AllocIDRequest) (*AllocIDResponse, error)
- func (*UnimplementedPDServer) AskBatchSplit(ctx context.Context, req *AskBatchSplitRequest) (*AskBatchSplitResponse, error)
- func (*UnimplementedPDServer) AskSplit(ctx context.Context, req *AskSplitRequest) (*AskSplitResponse, error)
- func (*UnimplementedPDServer) Bootstrap(ctx context.Context, req *BootstrapRequest) (*BootstrapResponse, error)
- func (*UnimplementedPDServer) GetAllStores(ctx context.Context, req *GetAllStoresRequest) (*GetAllStoresResponse, error)
- func (*UnimplementedPDServer) GetClusterConfig(ctx context.Context, req *GetClusterConfigRequest) (*GetClusterConfigResponse, error)
- func (*UnimplementedPDServer) GetClusterInfo(ctx context.Context, req *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
- func (*UnimplementedPDServer) GetDCLocationInfo(ctx context.Context, req *GetDCLocationInfoRequest) (*GetDCLocationInfoResponse, error)
- func (*UnimplementedPDServer) GetExternalTimestamp(ctx context.Context, req *GetExternalTimestampRequest) (*GetExternalTimestampResponse, error)
- func (*UnimplementedPDServer) GetGCSafePoint(ctx context.Context, req *GetGCSafePointRequest) (*GetGCSafePointResponse, error)
- func (*UnimplementedPDServer) GetGCSafePointV2(ctx context.Context, req *GetGCSafePointV2Request) (*GetGCSafePointV2Response, error)
- func (*UnimplementedPDServer) GetMembers(ctx context.Context, req *GetMembersRequest) (*GetMembersResponse, error)
- func (*UnimplementedPDServer) GetMinTS(ctx context.Context, req *GetMinTSRequest) (*GetMinTSResponse, error)
- func (*UnimplementedPDServer) GetOperator(ctx context.Context, req *GetOperatorRequest) (*GetOperatorResponse, error)
- func (*UnimplementedPDServer) GetPrevRegion(ctx context.Context, req *GetRegionRequest) (*GetRegionResponse, error)
- func (*UnimplementedPDServer) GetRegion(ctx context.Context, req *GetRegionRequest) (*GetRegionResponse, error)
- func (*UnimplementedPDServer) GetRegionByID(ctx context.Context, req *GetRegionByIDRequest) (*GetRegionResponse, error)
- func (*UnimplementedPDServer) GetStore(ctx context.Context, req *GetStoreRequest) (*GetStoreResponse, error)
- func (*UnimplementedPDServer) IsBootstrapped(ctx context.Context, req *IsBootstrappedRequest) (*IsBootstrappedResponse, error)
- func (*UnimplementedPDServer) IsSnapshotRecovering(ctx context.Context, req *IsSnapshotRecoveringRequest) (*IsSnapshotRecoveringResponse, error)
- func (*UnimplementedPDServer) LoadGlobalConfig(ctx context.Context, req *LoadGlobalConfigRequest) (*LoadGlobalConfigResponse, error)
- func (*UnimplementedPDServer) PutClusterConfig(ctx context.Context, req *PutClusterConfigRequest) (*PutClusterConfigResponse, error)
- func (*UnimplementedPDServer) PutStore(ctx context.Context, req *PutStoreRequest) (*PutStoreResponse, error)
- func (*UnimplementedPDServer) RegionHeartbeat(srv PD_RegionHeartbeatServer) error
- func (*UnimplementedPDServer) ReportBatchSplit(ctx context.Context, req *ReportBatchSplitRequest) (*ReportBatchSplitResponse, error)
- func (*UnimplementedPDServer) ReportBuckets(srv PD_ReportBucketsServer) error
- func (*UnimplementedPDServer) ReportMinResolvedTS(ctx context.Context, req *ReportMinResolvedTsRequest) (*ReportMinResolvedTsResponse, error)
- func (*UnimplementedPDServer) ReportSplit(ctx context.Context, req *ReportSplitRequest) (*ReportSplitResponse, error)
- func (*UnimplementedPDServer) ScanRegions(ctx context.Context, req *ScanRegionsRequest) (*ScanRegionsResponse, error)
- func (*UnimplementedPDServer) ScatterRegion(ctx context.Context, req *ScatterRegionRequest) (*ScatterRegionResponse, error)
- func (*UnimplementedPDServer) SetExternalTimestamp(ctx context.Context, req *SetExternalTimestampRequest) (*SetExternalTimestampResponse, error)
- func (*UnimplementedPDServer) SplitAndScatterRegions(ctx context.Context, req *SplitAndScatterRegionsRequest) (*SplitAndScatterRegionsResponse, error)
- func (*UnimplementedPDServer) SplitRegions(ctx context.Context, req *SplitRegionsRequest) (*SplitRegionsResponse, error)
- func (*UnimplementedPDServer) StoreGlobalConfig(ctx context.Context, req *StoreGlobalConfigRequest) (*StoreGlobalConfigResponse, error)
- func (*UnimplementedPDServer) StoreHeartbeat(ctx context.Context, req *StoreHeartbeatRequest) (*StoreHeartbeatResponse, error)
- func (*UnimplementedPDServer) SyncMaxTS(ctx context.Context, req *SyncMaxTSRequest) (*SyncMaxTSResponse, error)
- func (*UnimplementedPDServer) SyncRegions(srv PD_SyncRegionsServer) error
- func (*UnimplementedPDServer) Tso(srv PD_TsoServer) error
- func (*UnimplementedPDServer) UpdateGCSafePoint(ctx context.Context, req *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error)
- func (*UnimplementedPDServer) UpdateGCSafePointV2(ctx context.Context, req *UpdateGCSafePointV2Request) (*UpdateGCSafePointV2Response, error)
- func (*UnimplementedPDServer) UpdateServiceGCSafePoint(ctx context.Context, req *UpdateServiceGCSafePointRequest) (*UpdateServiceGCSafePointResponse, error)
- func (*UnimplementedPDServer) UpdateServiceSafePointV2(ctx context.Context, req *UpdateServiceSafePointV2Request) (*UpdateServiceSafePointV2Response, error)
- func (*UnimplementedPDServer) WatchGCSafePointV2(req *WatchGCSafePointV2Request, srv PD_WatchGCSafePointV2Server) error
- func (*UnimplementedPDServer) WatchGlobalConfig(req *WatchGlobalConfigRequest, srv PD_WatchGlobalConfigServer) error
- type UpdateGCSafePointRequest
- func (*UpdateGCSafePointRequest) Descriptor() ([]byte, []int)
- func (m *UpdateGCSafePointRequest) GetHeader() *RequestHeader
- func (m *UpdateGCSafePointRequest) GetSafePoint() uint64
- func (m *UpdateGCSafePointRequest) Marshal() (dAtA []byte, err error)
- func (m *UpdateGCSafePointRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateGCSafePointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateGCSafePointRequest) ProtoMessage()
- func (m *UpdateGCSafePointRequest) Reset()
- func (m *UpdateGCSafePointRequest) Size() (n int)
- func (m *UpdateGCSafePointRequest) String() string
- func (m *UpdateGCSafePointRequest) Unmarshal(dAtA []byte) error
- func (m *UpdateGCSafePointRequest) XXX_DiscardUnknown()
- func (m *UpdateGCSafePointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateGCSafePointRequest) XXX_Merge(src proto.Message)
- func (m *UpdateGCSafePointRequest) XXX_Size() int
- func (m *UpdateGCSafePointRequest) XXX_Unmarshal(b []byte) error
- type UpdateGCSafePointResponse
- func (*UpdateGCSafePointResponse) Descriptor() ([]byte, []int)
- func (m *UpdateGCSafePointResponse) GetHeader() *ResponseHeader
- func (m *UpdateGCSafePointResponse) GetNewSafePoint() uint64
- func (m *UpdateGCSafePointResponse) Marshal() (dAtA []byte, err error)
- func (m *UpdateGCSafePointResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateGCSafePointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateGCSafePointResponse) ProtoMessage()
- func (m *UpdateGCSafePointResponse) Reset()
- func (m *UpdateGCSafePointResponse) Size() (n int)
- func (m *UpdateGCSafePointResponse) String() string
- func (m *UpdateGCSafePointResponse) Unmarshal(dAtA []byte) error
- func (m *UpdateGCSafePointResponse) XXX_DiscardUnknown()
- func (m *UpdateGCSafePointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateGCSafePointResponse) XXX_Merge(src proto.Message)
- func (m *UpdateGCSafePointResponse) XXX_Size() int
- func (m *UpdateGCSafePointResponse) XXX_Unmarshal(b []byte) error
- type UpdateGCSafePointV2Request
- func (*UpdateGCSafePointV2Request) Descriptor() ([]byte, []int)
- func (m *UpdateGCSafePointV2Request) GetHeader() *RequestHeader
- func (m *UpdateGCSafePointV2Request) GetKeyspaceId() uint32
- func (m *UpdateGCSafePointV2Request) GetSafePoint() uint64
- func (m *UpdateGCSafePointV2Request) Marshal() (dAtA []byte, err error)
- func (m *UpdateGCSafePointV2Request) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateGCSafePointV2Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateGCSafePointV2Request) ProtoMessage()
- func (m *UpdateGCSafePointV2Request) Reset()
- func (m *UpdateGCSafePointV2Request) Size() (n int)
- func (m *UpdateGCSafePointV2Request) String() string
- func (m *UpdateGCSafePointV2Request) Unmarshal(dAtA []byte) error
- func (m *UpdateGCSafePointV2Request) XXX_DiscardUnknown()
- func (m *UpdateGCSafePointV2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateGCSafePointV2Request) XXX_Merge(src proto.Message)
- func (m *UpdateGCSafePointV2Request) XXX_Size() int
- func (m *UpdateGCSafePointV2Request) XXX_Unmarshal(b []byte) error
- type UpdateGCSafePointV2Response
- func (*UpdateGCSafePointV2Response) Descriptor() ([]byte, []int)
- func (m *UpdateGCSafePointV2Response) GetHeader() *ResponseHeader
- func (m *UpdateGCSafePointV2Response) GetNewSafePoint() uint64
- func (m *UpdateGCSafePointV2Response) Marshal() (dAtA []byte, err error)
- func (m *UpdateGCSafePointV2Response) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateGCSafePointV2Response) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateGCSafePointV2Response) ProtoMessage()
- func (m *UpdateGCSafePointV2Response) Reset()
- func (m *UpdateGCSafePointV2Response) Size() (n int)
- func (m *UpdateGCSafePointV2Response) String() string
- func (m *UpdateGCSafePointV2Response) Unmarshal(dAtA []byte) error
- func (m *UpdateGCSafePointV2Response) XXX_DiscardUnknown()
- func (m *UpdateGCSafePointV2Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateGCSafePointV2Response) XXX_Merge(src proto.Message)
- func (m *UpdateGCSafePointV2Response) XXX_Size() int
- func (m *UpdateGCSafePointV2Response) XXX_Unmarshal(b []byte) error
- type UpdateServiceGCSafePointRequest
- func (*UpdateServiceGCSafePointRequest) Descriptor() ([]byte, []int)
- func (m *UpdateServiceGCSafePointRequest) GetHeader() *RequestHeader
- func (m *UpdateServiceGCSafePointRequest) GetSafePoint() uint64
- func (m *UpdateServiceGCSafePointRequest) GetServiceId() []byte
- func (m *UpdateServiceGCSafePointRequest) GetTTL() int64
- func (m *UpdateServiceGCSafePointRequest) Marshal() (dAtA []byte, err error)
- func (m *UpdateServiceGCSafePointRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateServiceGCSafePointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateServiceGCSafePointRequest) ProtoMessage()
- func (m *UpdateServiceGCSafePointRequest) Reset()
- func (m *UpdateServiceGCSafePointRequest) Size() (n int)
- func (m *UpdateServiceGCSafePointRequest) String() string
- func (m *UpdateServiceGCSafePointRequest) Unmarshal(dAtA []byte) error
- func (m *UpdateServiceGCSafePointRequest) XXX_DiscardUnknown()
- func (m *UpdateServiceGCSafePointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateServiceGCSafePointRequest) XXX_Merge(src proto.Message)
- func (m *UpdateServiceGCSafePointRequest) XXX_Size() int
- func (m *UpdateServiceGCSafePointRequest) XXX_Unmarshal(b []byte) error
- type UpdateServiceGCSafePointResponse
- func (*UpdateServiceGCSafePointResponse) Descriptor() ([]byte, []int)
- func (m *UpdateServiceGCSafePointResponse) GetHeader() *ResponseHeader
- func (m *UpdateServiceGCSafePointResponse) GetMinSafePoint() uint64
- func (m *UpdateServiceGCSafePointResponse) GetServiceId() []byte
- func (m *UpdateServiceGCSafePointResponse) GetTTL() int64
- func (m *UpdateServiceGCSafePointResponse) Marshal() (dAtA []byte, err error)
- func (m *UpdateServiceGCSafePointResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateServiceGCSafePointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateServiceGCSafePointResponse) ProtoMessage()
- func (m *UpdateServiceGCSafePointResponse) Reset()
- func (m *UpdateServiceGCSafePointResponse) Size() (n int)
- func (m *UpdateServiceGCSafePointResponse) String() string
- func (m *UpdateServiceGCSafePointResponse) Unmarshal(dAtA []byte) error
- func (m *UpdateServiceGCSafePointResponse) XXX_DiscardUnknown()
- func (m *UpdateServiceGCSafePointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateServiceGCSafePointResponse) XXX_Merge(src proto.Message)
- func (m *UpdateServiceGCSafePointResponse) XXX_Size() int
- func (m *UpdateServiceGCSafePointResponse) XXX_Unmarshal(b []byte) error
- type UpdateServiceSafePointV2Request
- func (*UpdateServiceSafePointV2Request) Descriptor() ([]byte, []int)
- func (m *UpdateServiceSafePointV2Request) GetHeader() *RequestHeader
- func (m *UpdateServiceSafePointV2Request) GetKeyspaceId() uint32
- func (m *UpdateServiceSafePointV2Request) GetSafePoint() uint64
- func (m *UpdateServiceSafePointV2Request) GetServiceId() []byte
- func (m *UpdateServiceSafePointV2Request) GetTtl() int64
- func (m *UpdateServiceSafePointV2Request) Marshal() (dAtA []byte, err error)
- func (m *UpdateServiceSafePointV2Request) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateServiceSafePointV2Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateServiceSafePointV2Request) ProtoMessage()
- func (m *UpdateServiceSafePointV2Request) Reset()
- func (m *UpdateServiceSafePointV2Request) Size() (n int)
- func (m *UpdateServiceSafePointV2Request) String() string
- func (m *UpdateServiceSafePointV2Request) Unmarshal(dAtA []byte) error
- func (m *UpdateServiceSafePointV2Request) XXX_DiscardUnknown()
- func (m *UpdateServiceSafePointV2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateServiceSafePointV2Request) XXX_Merge(src proto.Message)
- func (m *UpdateServiceSafePointV2Request) XXX_Size() int
- func (m *UpdateServiceSafePointV2Request) XXX_Unmarshal(b []byte) error
- type UpdateServiceSafePointV2Response
- func (*UpdateServiceSafePointV2Response) Descriptor() ([]byte, []int)
- func (m *UpdateServiceSafePointV2Response) GetHeader() *ResponseHeader
- func (m *UpdateServiceSafePointV2Response) GetMinSafePoint() uint64
- func (m *UpdateServiceSafePointV2Response) GetServiceId() []byte
- func (m *UpdateServiceSafePointV2Response) GetTtl() int64
- func (m *UpdateServiceSafePointV2Response) Marshal() (dAtA []byte, err error)
- func (m *UpdateServiceSafePointV2Response) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateServiceSafePointV2Response) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateServiceSafePointV2Response) ProtoMessage()
- func (m *UpdateServiceSafePointV2Response) Reset()
- func (m *UpdateServiceSafePointV2Response) Size() (n int)
- func (m *UpdateServiceSafePointV2Response) String() string
- func (m *UpdateServiceSafePointV2Response) Unmarshal(dAtA []byte) error
- func (m *UpdateServiceSafePointV2Response) XXX_DiscardUnknown()
- func (m *UpdateServiceSafePointV2Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateServiceSafePointV2Response) XXX_Merge(src proto.Message)
- func (m *UpdateServiceSafePointV2Response) XXX_Size() int
- func (m *UpdateServiceSafePointV2Response) XXX_Unmarshal(b []byte) error
- type WatchGCSafePointV2Request
- func (*WatchGCSafePointV2Request) Descriptor() ([]byte, []int)
- func (m *WatchGCSafePointV2Request) GetHeader() *RequestHeader
- func (m *WatchGCSafePointV2Request) GetRevision() int64
- func (m *WatchGCSafePointV2Request) Marshal() (dAtA []byte, err error)
- func (m *WatchGCSafePointV2Request) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchGCSafePointV2Request) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchGCSafePointV2Request) ProtoMessage()
- func (m *WatchGCSafePointV2Request) Reset()
- func (m *WatchGCSafePointV2Request) Size() (n int)
- func (m *WatchGCSafePointV2Request) String() string
- func (m *WatchGCSafePointV2Request) Unmarshal(dAtA []byte) error
- func (m *WatchGCSafePointV2Request) XXX_DiscardUnknown()
- func (m *WatchGCSafePointV2Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchGCSafePointV2Request) XXX_Merge(src proto.Message)
- func (m *WatchGCSafePointV2Request) XXX_Size() int
- func (m *WatchGCSafePointV2Request) XXX_Unmarshal(b []byte) error
- type WatchGCSafePointV2Response
- func (*WatchGCSafePointV2Response) Descriptor() ([]byte, []int)
- func (m *WatchGCSafePointV2Response) GetEvents() []*SafePointEvent
- func (m *WatchGCSafePointV2Response) GetHeader() *ResponseHeader
- func (m *WatchGCSafePointV2Response) GetRevision() int64
- func (m *WatchGCSafePointV2Response) Marshal() (dAtA []byte, err error)
- func (m *WatchGCSafePointV2Response) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchGCSafePointV2Response) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchGCSafePointV2Response) ProtoMessage()
- func (m *WatchGCSafePointV2Response) Reset()
- func (m *WatchGCSafePointV2Response) Size() (n int)
- func (m *WatchGCSafePointV2Response) String() string
- func (m *WatchGCSafePointV2Response) Unmarshal(dAtA []byte) error
- func (m *WatchGCSafePointV2Response) XXX_DiscardUnknown()
- func (m *WatchGCSafePointV2Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchGCSafePointV2Response) XXX_Merge(src proto.Message)
- func (m *WatchGCSafePointV2Response) XXX_Size() int
- func (m *WatchGCSafePointV2Response) XXX_Unmarshal(b []byte) error
- type WatchGlobalConfigRequest
- func (*WatchGlobalConfigRequest) Descriptor() ([]byte, []int)
- func (m *WatchGlobalConfigRequest) GetConfigPath() string
- func (m *WatchGlobalConfigRequest) GetRevision() int64
- func (m *WatchGlobalConfigRequest) Marshal() (dAtA []byte, err error)
- func (m *WatchGlobalConfigRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchGlobalConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchGlobalConfigRequest) ProtoMessage()
- func (m *WatchGlobalConfigRequest) Reset()
- func (m *WatchGlobalConfigRequest) Size() (n int)
- func (m *WatchGlobalConfigRequest) String() string
- func (m *WatchGlobalConfigRequest) Unmarshal(dAtA []byte) error
- func (m *WatchGlobalConfigRequest) XXX_DiscardUnknown()
- func (m *WatchGlobalConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchGlobalConfigRequest) XXX_Merge(src proto.Message)
- func (m *WatchGlobalConfigRequest) XXX_Size() int
- func (m *WatchGlobalConfigRequest) XXX_Unmarshal(b []byte) error
- type WatchGlobalConfigResponse
- func (*WatchGlobalConfigResponse) Descriptor() ([]byte, []int)
- func (m *WatchGlobalConfigResponse) GetChanges() []*GlobalConfigItem
- func (m *WatchGlobalConfigResponse) GetHeader() *ResponseHeader
- func (m *WatchGlobalConfigResponse) GetRevision() int64
- func (m *WatchGlobalConfigResponse) Marshal() (dAtA []byte, err error)
- func (m *WatchGlobalConfigResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchGlobalConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchGlobalConfigResponse) ProtoMessage()
- func (m *WatchGlobalConfigResponse) Reset()
- func (m *WatchGlobalConfigResponse) Size() (n int)
- func (m *WatchGlobalConfigResponse) String() string
- func (m *WatchGlobalConfigResponse) Unmarshal(dAtA []byte) error
- func (m *WatchGlobalConfigResponse) XXX_DiscardUnknown()
- func (m *WatchGlobalConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchGlobalConfigResponse) XXX_Merge(src proto.Message)
- func (m *WatchGlobalConfigResponse) XXX_Size() int
- func (m *WatchGlobalConfigResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthPdpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPdpb = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPdpb = fmt.Errorf("proto: unexpected end of group") )
View Source
var CheckPolicy_name = map[int32]string{
0: "SCAN",
1: "APPROXIMATE",
2: "USEKEY",
}
View Source
var CheckPolicy_value = map[string]int32{
"SCAN": 0,
"APPROXIMATE": 1,
"USEKEY": 2,
}
View Source
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",
7: "GLOBAL_CONFIG_NOT_FOUND",
8: "DUPLICATED_ENTRY",
9: "ENTRY_NOT_FOUND",
10: "INVALID_VALUE",
11: "DATA_COMPACTED",
}
View Source
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,
"GLOBAL_CONFIG_NOT_FOUND": 7,
"DUPLICATED_ENTRY": 8,
"ENTRY_NOT_FOUND": 9,
"INVALID_VALUE": 10,
"DATA_COMPACTED": 11,
}
View Source
var EventType_name = map[int32]string{
0: "PUT",
1: "DELETE",
}
View Source
var EventType_value = map[string]int32{
"PUT": 0,
"DELETE": 1,
}
View Source
var OperatorStatus_name = map[int32]string{
0: "SUCCESS",
1: "TIMEOUT",
2: "CANCEL",
3: "REPLACE",
4: "RUNNING",
}
View Source
var OperatorStatus_value = map[string]int32{
"SUCCESS": 0,
"TIMEOUT": 1,
"CANCEL": 2,
"REPLACE": 3,
"RUNNING": 4,
}
View Source
var QueryKind_name = map[int32]string{
0: "Others",
1: "GC",
2: "Get",
3: "Scan",
4: "Coprocessor",
5: "Delete",
6: "DeleteRange",
7: "Put",
8: "Prewrite",
9: "AcquirePessimisticLock",
10: "Commit",
11: "Rollback",
}
View Source
var QueryKind_value = map[string]int32{
"Others": 0,
"GC": 1,
"Get": 2,
"Scan": 3,
"Coprocessor": 4,
"Delete": 5,
"DeleteRange": 6,
"Put": 7,
"Prewrite": 8,
"AcquirePessimisticLock": 9,
"Commit": 10,
"Rollback": 11,
}
View Source
var ServiceMode_name = map[int32]string{
0: "UNKNOWN_SVC_MODE",
1: "PD_SVC_MODE",
2: "API_SVC_MODE",
}
View Source
var ServiceMode_value = map[string]int32{
"UNKNOWN_SVC_MODE": 0,
"PD_SVC_MODE": 1,
"API_SVC_MODE": 2,
}
Functions ¶
func RegisterPDServer ¶
Types ¶
type AllocIDRequest ¶
type AllocIDRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AllocIDRequest) Descriptor ¶
func (*AllocIDRequest) Descriptor() ([]byte, []int)
func (*AllocIDRequest) GetHeader ¶
func (m *AllocIDRequest) GetHeader() *RequestHeader
func (*AllocIDRequest) Marshal ¶
func (m *AllocIDRequest) Marshal() (dAtA []byte, err error)
func (*AllocIDRequest) MarshalToSizedBuffer ¶
func (m *AllocIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AllocIDRequest) ProtoMessage ¶
func (*AllocIDRequest) ProtoMessage()
func (*AllocIDRequest) Reset ¶
func (m *AllocIDRequest) Reset()
func (*AllocIDRequest) Size ¶
func (m *AllocIDRequest) Size() (n int)
func (*AllocIDRequest) String ¶
func (m *AllocIDRequest) String() string
func (*AllocIDRequest) Unmarshal ¶
func (m *AllocIDRequest) Unmarshal(dAtA []byte) error
func (*AllocIDRequest) XXX_DiscardUnknown ¶
func (m *AllocIDRequest) XXX_DiscardUnknown()
func (*AllocIDRequest) XXX_Marshal ¶
func (m *AllocIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AllocIDRequest) XXX_Merge ¶
func (m *AllocIDRequest) XXX_Merge(src proto.Message)
func (*AllocIDRequest) XXX_Size ¶
func (m *AllocIDRequest) XXX_Size() int
func (*AllocIDRequest) XXX_Unmarshal ¶
func (m *AllocIDRequest) XXX_Unmarshal(b []byte) error
type AllocIDResponse ¶
type AllocIDResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AllocIDResponse) Descriptor ¶
func (*AllocIDResponse) Descriptor() ([]byte, []int)
func (*AllocIDResponse) GetHeader ¶
func (m *AllocIDResponse) GetHeader() *ResponseHeader
func (*AllocIDResponse) GetId ¶
func (m *AllocIDResponse) GetId() uint64
func (*AllocIDResponse) Marshal ¶
func (m *AllocIDResponse) Marshal() (dAtA []byte, err error)
func (*AllocIDResponse) MarshalToSizedBuffer ¶
func (m *AllocIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AllocIDResponse) ProtoMessage ¶
func (*AllocIDResponse) ProtoMessage()
func (*AllocIDResponse) Reset ¶
func (m *AllocIDResponse) Reset()
func (*AllocIDResponse) Size ¶
func (m *AllocIDResponse) Size() (n int)
func (*AllocIDResponse) String ¶
func (m *AllocIDResponse) String() string
func (*AllocIDResponse) Unmarshal ¶
func (m *AllocIDResponse) Unmarshal(dAtA []byte) error
func (*AllocIDResponse) XXX_DiscardUnknown ¶
func (m *AllocIDResponse) XXX_DiscardUnknown()
func (*AllocIDResponse) XXX_Marshal ¶
func (m *AllocIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AllocIDResponse) XXX_Merge ¶
func (m *AllocIDResponse) XXX_Merge(src proto.Message)
func (*AllocIDResponse) XXX_Size ¶
func (m *AllocIDResponse) XXX_Size() int
func (*AllocIDResponse) XXX_Unmarshal ¶
func (m *AllocIDResponse) XXX_Unmarshal(b []byte) error
type AskBatchSplitRequest ¶
type AskBatchSplitRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Region *metapb.Region `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"` SplitCount uint32 `protobuf:"varint,3,opt,name=split_count,json=splitCount,proto3" json:"split_count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AskBatchSplitRequest) Descriptor ¶
func (*AskBatchSplitRequest) Descriptor() ([]byte, []int)
func (*AskBatchSplitRequest) GetHeader ¶
func (m *AskBatchSplitRequest) GetHeader() *RequestHeader
func (*AskBatchSplitRequest) GetRegion ¶
func (m *AskBatchSplitRequest) GetRegion() *metapb.Region
func (*AskBatchSplitRequest) GetSplitCount ¶
func (m *AskBatchSplitRequest) GetSplitCount() uint32
func (*AskBatchSplitRequest) Marshal ¶
func (m *AskBatchSplitRequest) Marshal() (dAtA []byte, err error)
func (*AskBatchSplitRequest) MarshalTo ¶
func (m *AskBatchSplitRequest) MarshalTo(dAtA []byte) (int, error)
func (*AskBatchSplitRequest) MarshalToSizedBuffer ¶
func (m *AskBatchSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskBatchSplitRequest) ProtoMessage ¶
func (*AskBatchSplitRequest) ProtoMessage()
func (*AskBatchSplitRequest) Reset ¶
func (m *AskBatchSplitRequest) Reset()
func (*AskBatchSplitRequest) Size ¶
func (m *AskBatchSplitRequest) Size() (n int)
func (*AskBatchSplitRequest) String ¶
func (m *AskBatchSplitRequest) String() string
func (*AskBatchSplitRequest) Unmarshal ¶
func (m *AskBatchSplitRequest) Unmarshal(dAtA []byte) error
func (*AskBatchSplitRequest) XXX_DiscardUnknown ¶
func (m *AskBatchSplitRequest) XXX_DiscardUnknown()
func (*AskBatchSplitRequest) XXX_Marshal ¶
func (m *AskBatchSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskBatchSplitRequest) XXX_Merge ¶
func (m *AskBatchSplitRequest) XXX_Merge(src proto.Message)
func (*AskBatchSplitRequest) XXX_Size ¶
func (m *AskBatchSplitRequest) XXX_Size() int
func (*AskBatchSplitRequest) XXX_Unmarshal ¶
func (m *AskBatchSplitRequest) XXX_Unmarshal(b []byte) error
type AskBatchSplitResponse ¶
type AskBatchSplitResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Ids []*SplitID `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AskBatchSplitResponse) Descriptor ¶
func (*AskBatchSplitResponse) Descriptor() ([]byte, []int)
func (*AskBatchSplitResponse) GetHeader ¶
func (m *AskBatchSplitResponse) GetHeader() *ResponseHeader
func (*AskBatchSplitResponse) GetIds ¶
func (m *AskBatchSplitResponse) GetIds() []*SplitID
func (*AskBatchSplitResponse) Marshal ¶
func (m *AskBatchSplitResponse) Marshal() (dAtA []byte, err error)
func (*AskBatchSplitResponse) MarshalTo ¶
func (m *AskBatchSplitResponse) MarshalTo(dAtA []byte) (int, error)
func (*AskBatchSplitResponse) MarshalToSizedBuffer ¶
func (m *AskBatchSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskBatchSplitResponse) ProtoMessage ¶
func (*AskBatchSplitResponse) ProtoMessage()
func (*AskBatchSplitResponse) Reset ¶
func (m *AskBatchSplitResponse) Reset()
func (*AskBatchSplitResponse) Size ¶
func (m *AskBatchSplitResponse) Size() (n int)
func (*AskBatchSplitResponse) String ¶
func (m *AskBatchSplitResponse) String() string
func (*AskBatchSplitResponse) Unmarshal ¶
func (m *AskBatchSplitResponse) Unmarshal(dAtA []byte) error
func (*AskBatchSplitResponse) XXX_DiscardUnknown ¶
func (m *AskBatchSplitResponse) XXX_DiscardUnknown()
func (*AskBatchSplitResponse) XXX_Marshal ¶
func (m *AskBatchSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskBatchSplitResponse) XXX_Merge ¶
func (m *AskBatchSplitResponse) XXX_Merge(src proto.Message)
func (*AskBatchSplitResponse) XXX_Size ¶
func (m *AskBatchSplitResponse) XXX_Size() int
func (*AskBatchSplitResponse) XXX_Unmarshal ¶
func (m *AskBatchSplitResponse) XXX_Unmarshal(b []byte) error
type AskSplitRequest ¶
type AskSplitRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Region *metapb.Region `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AskSplitRequest) Descriptor ¶
func (*AskSplitRequest) Descriptor() ([]byte, []int)
func (*AskSplitRequest) GetHeader ¶
func (m *AskSplitRequest) GetHeader() *RequestHeader
func (*AskSplitRequest) GetRegion ¶
func (m *AskSplitRequest) GetRegion() *metapb.Region
func (*AskSplitRequest) Marshal ¶
func (m *AskSplitRequest) Marshal() (dAtA []byte, err error)
func (*AskSplitRequest) MarshalToSizedBuffer ¶
func (m *AskSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskSplitRequest) ProtoMessage ¶
func (*AskSplitRequest) ProtoMessage()
func (*AskSplitRequest) Reset ¶
func (m *AskSplitRequest) Reset()
func (*AskSplitRequest) Size ¶
func (m *AskSplitRequest) Size() (n int)
func (*AskSplitRequest) String ¶
func (m *AskSplitRequest) String() string
func (*AskSplitRequest) Unmarshal ¶
func (m *AskSplitRequest) Unmarshal(dAtA []byte) error
func (*AskSplitRequest) XXX_DiscardUnknown ¶
func (m *AskSplitRequest) XXX_DiscardUnknown()
func (*AskSplitRequest) XXX_Marshal ¶
func (m *AskSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskSplitRequest) XXX_Merge ¶
func (m *AskSplitRequest) XXX_Merge(src proto.Message)
func (*AskSplitRequest) XXX_Size ¶
func (m *AskSplitRequest) XXX_Size() int
func (*AskSplitRequest) XXX_Unmarshal ¶
func (m *AskSplitRequest) XXX_Unmarshal(b []byte) error
type AskSplitResponse ¶
type AskSplitResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" 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,proto3" json:"new_peer_ids,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AskSplitResponse) Descriptor ¶
func (*AskSplitResponse) Descriptor() ([]byte, []int)
func (*AskSplitResponse) GetHeader ¶
func (m *AskSplitResponse) GetHeader() *ResponseHeader
func (*AskSplitResponse) GetNewPeerIds ¶
func (m *AskSplitResponse) GetNewPeerIds() []uint64
func (*AskSplitResponse) GetNewRegionId ¶
func (m *AskSplitResponse) GetNewRegionId() uint64
func (*AskSplitResponse) Marshal ¶
func (m *AskSplitResponse) Marshal() (dAtA []byte, err error)
func (*AskSplitResponse) MarshalToSizedBuffer ¶
func (m *AskSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskSplitResponse) ProtoMessage ¶
func (*AskSplitResponse) ProtoMessage()
func (*AskSplitResponse) Reset ¶
func (m *AskSplitResponse) Reset()
func (*AskSplitResponse) Size ¶
func (m *AskSplitResponse) Size() (n int)
func (*AskSplitResponse) String ¶
func (m *AskSplitResponse) String() string
func (*AskSplitResponse) Unmarshal ¶
func (m *AskSplitResponse) Unmarshal(dAtA []byte) error
func (*AskSplitResponse) XXX_DiscardUnknown ¶
func (m *AskSplitResponse) XXX_DiscardUnknown()
func (*AskSplitResponse) XXX_Marshal ¶
func (m *AskSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskSplitResponse) XXX_Merge ¶
func (m *AskSplitResponse) XXX_Merge(src proto.Message)
func (*AskSplitResponse) XXX_Size ¶
func (m *AskSplitResponse) XXX_Size() int
func (*AskSplitResponse) XXX_Unmarshal ¶
func (m *AskSplitResponse) XXX_Unmarshal(b []byte) error
type AwakenRegions ¶
type AwakenRegions struct { // Awake all regions if abnormal_stores is empty. AbnormalStores []uint64 `protobuf:"varint,1,rep,packed,name=abnormal_stores,json=abnormalStores,proto3" json:"abnormal_stores,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AwakenRegions) Descriptor ¶
func (*AwakenRegions) Descriptor() ([]byte, []int)
func (*AwakenRegions) GetAbnormalStores ¶
func (m *AwakenRegions) GetAbnormalStores() []uint64
func (*AwakenRegions) Marshal ¶
func (m *AwakenRegions) Marshal() (dAtA []byte, err error)
func (*AwakenRegions) MarshalToSizedBuffer ¶
func (m *AwakenRegions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AwakenRegions) ProtoMessage ¶
func (*AwakenRegions) ProtoMessage()
func (*AwakenRegions) Reset ¶
func (m *AwakenRegions) Reset()
func (*AwakenRegions) Size ¶
func (m *AwakenRegions) Size() (n int)
func (*AwakenRegions) String ¶
func (m *AwakenRegions) String() string
func (*AwakenRegions) Unmarshal ¶
func (m *AwakenRegions) Unmarshal(dAtA []byte) error
func (*AwakenRegions) XXX_DiscardUnknown ¶
func (m *AwakenRegions) XXX_DiscardUnknown()
func (*AwakenRegions) XXX_Marshal ¶
func (m *AwakenRegions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AwakenRegions) XXX_Merge ¶
func (m *AwakenRegions) XXX_Merge(src proto.Message)
func (*AwakenRegions) XXX_Size ¶
func (m *AwakenRegions) XXX_Size() int
func (*AwakenRegions) XXX_Unmarshal ¶
func (m *AwakenRegions) XXX_Unmarshal(b []byte) error
type BatchSwitchWitness ¶
type BatchSwitchWitness struct { SwitchWitnesses []*SwitchWitness `protobuf:"bytes,1,rep,name=switch_witnesses,json=switchWitnesses,proto3" json:"switch_witnesses,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BatchSwitchWitness) Descriptor ¶
func (*BatchSwitchWitness) Descriptor() ([]byte, []int)
func (*BatchSwitchWitness) GetSwitchWitnesses ¶
func (m *BatchSwitchWitness) GetSwitchWitnesses() []*SwitchWitness
func (*BatchSwitchWitness) Marshal ¶
func (m *BatchSwitchWitness) Marshal() (dAtA []byte, err error)
func (*BatchSwitchWitness) MarshalTo ¶
func (m *BatchSwitchWitness) MarshalTo(dAtA []byte) (int, error)
func (*BatchSwitchWitness) MarshalToSizedBuffer ¶
func (m *BatchSwitchWitness) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BatchSwitchWitness) ProtoMessage ¶
func (*BatchSwitchWitness) ProtoMessage()
func (*BatchSwitchWitness) Reset ¶
func (m *BatchSwitchWitness) Reset()
func (*BatchSwitchWitness) Size ¶
func (m *BatchSwitchWitness) Size() (n int)
func (*BatchSwitchWitness) String ¶
func (m *BatchSwitchWitness) String() string
func (*BatchSwitchWitness) Unmarshal ¶
func (m *BatchSwitchWitness) Unmarshal(dAtA []byte) error
func (*BatchSwitchWitness) XXX_DiscardUnknown ¶
func (m *BatchSwitchWitness) XXX_DiscardUnknown()
func (*BatchSwitchWitness) XXX_Marshal ¶
func (m *BatchSwitchWitness) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BatchSwitchWitness) XXX_Merge ¶
func (m *BatchSwitchWitness) XXX_Merge(src proto.Message)
func (*BatchSwitchWitness) XXX_Size ¶
func (m *BatchSwitchWitness) XXX_Size() int
func (*BatchSwitchWitness) XXX_Unmarshal ¶
func (m *BatchSwitchWitness) XXX_Unmarshal(b []byte) error
type BootstrapRequest ¶
type BootstrapRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Store *metapb.Store `protobuf:"bytes,2,opt,name=store,proto3" json:"store,omitempty"` Region *metapb.Region `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BootstrapRequest) Descriptor ¶
func (*BootstrapRequest) Descriptor() ([]byte, []int)
func (*BootstrapRequest) GetHeader ¶
func (m *BootstrapRequest) GetHeader() *RequestHeader
func (*BootstrapRequest) GetRegion ¶
func (m *BootstrapRequest) GetRegion() *metapb.Region
func (*BootstrapRequest) GetStore ¶
func (m *BootstrapRequest) GetStore() *metapb.Store
func (*BootstrapRequest) Marshal ¶
func (m *BootstrapRequest) Marshal() (dAtA []byte, err error)
func (*BootstrapRequest) MarshalToSizedBuffer ¶
func (m *BootstrapRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BootstrapRequest) ProtoMessage ¶
func (*BootstrapRequest) ProtoMessage()
func (*BootstrapRequest) Reset ¶
func (m *BootstrapRequest) Reset()
func (*BootstrapRequest) Size ¶
func (m *BootstrapRequest) Size() (n int)
func (*BootstrapRequest) String ¶
func (m *BootstrapRequest) String() string
func (*BootstrapRequest) Unmarshal ¶
func (m *BootstrapRequest) Unmarshal(dAtA []byte) error
func (*BootstrapRequest) XXX_DiscardUnknown ¶
func (m *BootstrapRequest) XXX_DiscardUnknown()
func (*BootstrapRequest) XXX_Marshal ¶
func (m *BootstrapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BootstrapRequest) XXX_Merge ¶
func (m *BootstrapRequest) XXX_Merge(src proto.Message)
func (*BootstrapRequest) XXX_Size ¶
func (m *BootstrapRequest) XXX_Size() int
func (*BootstrapRequest) XXX_Unmarshal ¶
func (m *BootstrapRequest) XXX_Unmarshal(b []byte) error