Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var CheckPolicy_name = map[int32]string + var CheckPolicy_value = map[string]int32 + var ErrIntOverflowTmpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTmpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupTmpb = fmt.Errorf("proto: unexpected end of group") + var ErrorType_name = map[int32]string + var ErrorType_value = map[string]int32 + var EventType_name = map[int32]string + var EventType_value = map[string]int32 + var OperatorStatus_name = map[int32]string + var OperatorStatus_value = map[string]int32 + var QueryKind_name = map[int32]string + var QueryKind_value = map[string]int32 + var ServiceMode_name = map[int32]string + var ServiceMode_value = map[string]int32 + func RegisterTMServer(s *grpc.Server, srv TMServer) + type AllocIDRequest struct + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AllocIDRequest) Descriptor() ([]byte, []int) + func (*AllocIDRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + Id uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AllocIDResponse) Descriptor() ([]byte, []int) + func (*AllocIDResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + Region *metapb.Region + SplitCount uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AskBatchSplitRequest) Descriptor() ([]byte, []int) + func (*AskBatchSplitRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + Ids []*SplitID + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AskBatchSplitResponse) Descriptor() ([]byte, []int) + func (*AskBatchSplitResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AskSplitRequest) Descriptor() ([]byte, []int) + func (*AskSplitRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + NewPeerIds []uint64 + NewRegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AskSplitResponse) Descriptor() ([]byte, []int) + func (*AskSplitResponse) ProtoMessage() + 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 (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 struct + AbnormalStores []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AwakenRegions) Descriptor() ([]byte, []int) + func (*AwakenRegions) ProtoMessage() + 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 (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 struct + SwitchWitnesses []*SwitchWitness + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchSwitchWitness) Descriptor() ([]byte, []int) + func (*BatchSwitchWitness) ProtoMessage() + 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 (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 struct + Header *RequestHeader + Region *metapb.Region + Store *metapb.Store + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BootstrapRequest) Descriptor() ([]byte, []int) + func (*BootstrapRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + ReplicationStatus *replication_modepb.ReplicationStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BootstrapResponse) Descriptor() ([]byte, []int) + func (*BootstrapResponse) ProtoMessage() + 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 (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 struct + ChangeType eraftpb.ConfChangeType + Peer *metapb.Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangePeer) Descriptor() ([]byte, []int) + func (*ChangePeer) ProtoMessage() + 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 (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 struct + Changes []*ChangePeer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChangePeerV2) Descriptor() ([]byte, []int) + func (*ChangePeerV2) ProtoMessage() + 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 (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 int32 + const CheckPolicy_APPROXIMATE + const CheckPolicy_SCAN + const CheckPolicy_USEKEY + func (CheckPolicy) EnumDescriptor() ([]byte, []int) + func (x CheckPolicy) String() string + type DemoteFailedVoters struct + FailedVoters []*metapb.Peer + RegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DemoteFailedVoters) Descriptor() ([]byte, []int) + func (*DemoteFailedVoters) ProtoMessage() + 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 (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 struct + Message string + Type ErrorType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + 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 (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 int32 + const ErrorType_ALREADY_BOOTSTRAPPED + const ErrorType_DATA_COMPACTED + const ErrorType_DUPLICATED_ENTRY + const ErrorType_ENTRY_NOT_FOUND + const ErrorType_GLOBAL_CONFIG_NOT_FOUND + const ErrorType_INCOMPATIBLE_VERSION + const ErrorType_INVALID_VALUE + const ErrorType_NOT_BOOTSTRAPPED + const ErrorType_OK + const ErrorType_REGION_NOT_FOUND + const ErrorType_STORE_TOMBSTONE + const ErrorType_UNKNOWN + func (ErrorType) EnumDescriptor() ([]byte, []int) + func (x ErrorType) String() string + type EventType int32 + const EventType_DELETE + const EventType_PUT + func (EventType) EnumDescriptor() ([]byte, []int) + func (x EventType) String() string + type ForceLeader struct + EnterForceLeaders []uint64 + FailedStores []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ForceLeader) Descriptor() ([]byte, []int) + func (*ForceLeader) ProtoMessage() + 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 (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 struct + ExcludeTombstoneStores bool + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetAllStoresRequest) Descriptor() ([]byte, []int) + func (*GetAllStoresRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + Stores []*metapb.Store + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetAllStoresResponse) Descriptor() ([]byte, []int) + func (*GetAllStoresResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetClusterConfigRequest) Descriptor() ([]byte, []int) + func (*GetClusterConfigRequest) ProtoMessage() + 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 (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 struct + Cluster *metapb.Cluster + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetClusterConfigResponse) Descriptor() ([]byte, []int) + func (*GetClusterConfigResponse) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetClusterInfoRequest) Descriptor() ([]byte, []int) + func (*GetClusterInfoRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + ServiceModes []ServiceMode + TsoUrls []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetClusterInfoResponse) Descriptor() ([]byte, []int) + func (*GetClusterInfoResponse) ProtoMessage() + 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 (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 struct + DcLocation string + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDCLocationInfoRequest) Descriptor() ([]byte, []int) + func (*GetDCLocationInfoRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + MaxTs *Timestamp + Suffix int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDCLocationInfoResponse) Descriptor() ([]byte, []int) + func (*GetDCLocationInfoResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetExternalTimestampRequest) Descriptor() ([]byte, []int) + func (*GetExternalTimestampRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + Timestamp uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetExternalTimestampResponse) Descriptor() ([]byte, []int) + func (*GetExternalTimestampResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetGCSafePointRequest) Descriptor() ([]byte, []int) + func (*GetGCSafePointRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + SafePoint uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetGCSafePointResponse) Descriptor() ([]byte, []int) + func (*GetGCSafePointResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + KeyspaceId uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetGCSafePointV2Request) Descriptor() ([]byte, []int) + func (*GetGCSafePointV2Request) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + SafePoint uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetGCSafePointV2Response) Descriptor() ([]byte, []int) + func (*GetGCSafePointV2Response) ProtoMessage() + 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 (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 struct + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMembersRequest) Descriptor() ([]byte, []int) + func (*GetMembersRequest) ProtoMessage() + 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 (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 struct + EtcdLeader *Member + Header *ResponseHeader + Leader *Member + Members []*Member + TsoAllocatorLeaders map[string]*Member + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMembersResponse) Descriptor() ([]byte, []int) + func (*GetMembersResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMinTSRequest) Descriptor() ([]byte, []int) + func (*GetMinTSRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + Timestamp *Timestamp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMinTSResponse) Descriptor() ([]byte, []int) + func (*GetMinTSResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + RegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetOperatorRequest) Descriptor() ([]byte, []int) + func (*GetOperatorRequest) ProtoMessage() + 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 (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 struct + Desc []byte + Header *ResponseHeader + Kind []byte + RegionId uint64 + Status OperatorStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetOperatorResponse) Descriptor() ([]byte, []int) + func (*GetOperatorResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + NeedBuckets bool + RegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRegionByIDRequest) Descriptor() ([]byte, []int) + func (*GetRegionByIDRequest) ProtoMessage() + 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 (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 struct + Header *RequestHeader + NeedBuckets bool + RegionKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRegionRequest) Descriptor() ([]byte, []int) + func (*GetRegionRequest) ProtoMessage() + 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 (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 struct + Buckets *metapb.Buckets + DownPeers []*PeerStats + Header *ResponseHeader + Leader *metapb.Peer + PendingPeers []*metapb.Peer + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetRegionResponse) Descriptor() ([]byte, []int) + func (*GetRegionResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetStoreRequest) Descriptor() ([]byte, []int) + func (*GetStoreRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + Stats *StoreStats + Store *metapb.Store + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetStoreResponse) Descriptor() ([]byte, []int) + func (*GetStoreResponse) ProtoMessage() + 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 (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 struct + Error *Error + Kind EventType + Name string + Payload []byte + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GlobalConfigItem) Descriptor() ([]byte, []int) + func (*GlobalConfigItem) ProtoMessage() + 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 (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 struct + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IsBootstrappedRequest) Descriptor() ([]byte, []int) + func (*IsBootstrappedRequest) ProtoMessage() + 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 (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 struct + Bootstrapped bool + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IsBootstrappedResponse) Descriptor() ([]byte, []int) + func (*IsBootstrappedResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IsSnapshotRecoveringRequest) Descriptor() ([]byte, []int) + func (*IsSnapshotRecoveringRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + Marked bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IsSnapshotRecoveringResponse) Descriptor() ([]byte, []int) + func (*IsSnapshotRecoveringResponse) ProtoMessage() + 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 (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 struct + ConfigPath string + Names []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadGlobalConfigRequest) Descriptor() ([]byte, []int) + func (*LoadGlobalConfigRequest) ProtoMessage() + 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 (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 struct + Items []*GlobalConfigItem + Revision int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LoadGlobalConfigResponse) Descriptor() ([]byte, []int) + func (*LoadGlobalConfigResponse) ProtoMessage() + 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 (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 struct + BinaryVersion string + ClientUrls []string + DcLocation string + DeployPath string + GitHash string + LeaderPriority int32 + MemberId uint64 + Name string + PeerUrls []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + 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 (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 struct + Target *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Merge) Descriptor() ([]byte, []int) + func (*Merge) ProtoMessage() + 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 (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 int32 + const OperatorStatus_CANCEL + const OperatorStatus_REPLACE + const OperatorStatus_RUNNING + const OperatorStatus_SUCCESS + const OperatorStatus_TIMEOUT + func (OperatorStatus) EnumDescriptor() ([]byte, []int) + func (x OperatorStatus) String() string + type PeerReport struct + HasCommitMerge bool + IsForceLeader bool + RaftState *raft_serverpb.RaftLocalState + RegionState *raft_serverpb.RegionLocalState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeerReport) Descriptor() ([]byte, []int) + func (*PeerReport) ProtoMessage() + 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 (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 struct + QueryStats *QueryStats + ReadBytes uint64 + ReadKeys uint64 + RegionId uint64 + WrittenBytes uint64 + WrittenKeys uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeerStat) Descriptor() ([]byte, []int) + func (*PeerStat) ProtoMessage() + 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 (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 struct + DownSeconds uint64 + Peer *metapb.Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeerStats) Descriptor() ([]byte, []int) + func (*PeerStats) ProtoMessage() + 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 (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 struct + Peers []*metapb.Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Peers) Descriptor() ([]byte, []int) + func (*Peers) ProtoMessage() + 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 (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 struct + Peers []*PeerStats + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeersStats) Descriptor() ([]byte, []int) + func (*PeersStats) ProtoMessage() + 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 (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 struct + Cluster *metapb.Cluster + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutClusterConfigRequest) Descriptor() ([]byte, []int) + func (*PutClusterConfigRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutClusterConfigResponse) Descriptor() ([]byte, []int) + func (*PutClusterConfigResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + Store *metapb.Store + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutStoreRequest) Descriptor() ([]byte, []int) + func (*PutStoreRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + ReplicationStatus *replication_modepb.ReplicationStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PutStoreResponse) Descriptor() ([]byte, []int) + func (*PutStoreResponse) ProtoMessage() + 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 (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 int32 + const QueryKind_AcquirePessimisticLock + const QueryKind_Commit + const QueryKind_Coprocessor + const QueryKind_Delete + const QueryKind_DeleteRange + const QueryKind_GC + const QueryKind_Get + const QueryKind_Others + const QueryKind_Prewrite + const QueryKind_Put + const QueryKind_Rollback + const QueryKind_Scan + func (QueryKind) EnumDescriptor() ([]byte, []int) + func (x QueryKind) String() string + type QueryStats struct + AcquirePessimisticLock uint64 + Commit uint64 + Coprocessor uint64 + Delete uint64 + DeleteRange uint64 + GC uint64 + Get uint64 + Prewrite uint64 + Put uint64 + Rollback uint64 + Scan uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*QueryStats) Descriptor() ([]byte, []int) + func (*QueryStats) ProtoMessage() + 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 (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 struct + Key string + Value uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RecordPair) Descriptor() ([]byte, []int) + func (*RecordPair) ProtoMessage() + 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 (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 struct + Creates []*metapb.Region + Demotes []*DemoteFailedVoters + ForceLeader *ForceLeader + Step uint64 + Tombstones []uint64 + Updates []*metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RecoveryPlan) Descriptor() ([]byte, []int) + func (*RecoveryPlan) ProtoMessage() + 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.Region + 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 (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 struct + DownPeers []*PeerStats + Leader *metapb.Peer + PendingPeers []*metapb.Peer + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Region) Descriptor() ([]byte, []int) + func (*Region) ProtoMessage() + 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 (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 struct + ApproximateKeys uint64 + ApproximateKvSize uint64 + ApproximateSize uint64 + BytesRead uint64 + BytesWritten uint64 + CpuUsage uint64 + DownPeers []*PeerStats + Header *RequestHeader + Interval *TimeInterval + KeysRead uint64 + KeysWritten uint64 + Leader *metapb.Peer + PendingPeers []*metapb.Peer + QueryStats *QueryStats + Region *metapb.Region + ReplicationStatus *replication_modepb.RegionReplicationStatus + Term uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionHeartbeatRequest) Descriptor() ([]byte, []int) + func (*RegionHeartbeatRequest) ProtoMessage() + 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 (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 struct + ChangePeer *ChangePeer + ChangePeerV2 *ChangePeerV2 + Header *ResponseHeader + Merge *Merge + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + SplitRegion *SplitRegion + SwitchWitnesses *BatchSwitchWitness + TargetPeer *metapb.Peer + TransferLeader *TransferLeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionHeartbeatResponse) Descriptor() ([]byte, []int) + func (*RegionHeartbeatResponse) ProtoMessage() + 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 (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 struct + BytesRead uint64 + BytesWritten uint64 + KeysRead uint64 + KeysWritten uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionStat) Descriptor() ([]byte, []int) + func (*RegionStat) ProtoMessage() + 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 (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 struct + Header *RequestHeader + Regions []*metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportBatchSplitRequest) Descriptor() ([]byte, []int) + func (*ReportBatchSplitRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportBatchSplitResponse) Descriptor() ([]byte, []int) + func (*ReportBatchSplitResponse) ProtoMessage() + 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 (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 struct + Buckets *metapb.Buckets + Header *RequestHeader + RegionEpoch *metapb.RegionEpoch + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportBucketsRequest) Descriptor() ([]byte, []int) + func (*ReportBucketsRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportBucketsResponse) Descriptor() ([]byte, []int) + func (*ReportBucketsResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + MinResolvedTs uint64 + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportMinResolvedTsRequest) Descriptor() ([]byte, []int) + func (*ReportMinResolvedTsRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportMinResolvedTsResponse) Descriptor() ([]byte, []int) + func (*ReportMinResolvedTsResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + Left *metapb.Region + Right *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportSplitRequest) Descriptor() ([]byte, []int) + func (*ReportSplitRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportSplitResponse) Descriptor() ([]byte, []int) + func (*ReportSplitResponse) ProtoMessage() + 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 (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 struct + ClusterId uint64 + SenderId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RequestHeader) Descriptor() ([]byte, []int) + func (*RequestHeader) ProtoMessage() + 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 (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 struct + ClusterId uint64 + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResponseHeader) Descriptor() ([]byte, []int) + func (*ResponseHeader) ProtoMessage() + 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 (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 struct + KeyspaceId uint32 + SafePoint uint64 + Type EventType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SafePointEvent) Descriptor() ([]byte, []int) + func (*SafePointEvent) ProtoMessage() + 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 (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 struct + EndKey []byte + Header *RequestHeader + Limit int32 + StartKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ScanRegionsRequest) Descriptor() ([]byte, []int) + func (*ScanRegionsRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + Leaders []*metapb.Peer + RegionMetas []*metapb.Region + Regions []*Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ScanRegionsResponse) Descriptor() ([]byte, []int) + func (*ScanRegionsResponse) ProtoMessage() + 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 (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 struct + Group string + Header *RequestHeader + Leader *metapb.Peer + Region *metapb.Region + RegionId uint64 + RegionsId []uint64 + RetryLimit uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ScatterRegionRequest) Descriptor() ([]byte, []int) + func (*ScatterRegionRequest) ProtoMessage() + 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() uint64 + 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 (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 struct + FinishedPercentage uint64 + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ScatterRegionResponse) Descriptor() ([]byte, []int) + func (*ScatterRegionResponse) ProtoMessage() + 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 (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 int32 + const ServiceMode_API_SVC_MODE + const ServiceMode_TM_SVC_MODE + const ServiceMode_UNKNOWN_SVC_MODE + func (ServiceMode) EnumDescriptor() ([]byte, []int) + func (x ServiceMode) String() string + type SetExternalTimestampRequest struct + Header *RequestHeader + Timestamp uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetExternalTimestampRequest) Descriptor() ([]byte, []int) + func (*SetExternalTimestampRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetExternalTimestampResponse) Descriptor() ([]byte, []int) + func (*SetExternalTimestampResponse) ProtoMessage() + 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 (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 struct + CauseRate float64 + CauseValue float64 + ResultRate float64 + ResultValue float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SlowTrend) Descriptor() ([]byte, []int) + func (*SlowTrend) ProtoMessage() + 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 (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 struct + GenerateDurationSec uint64 + RegionId uint64 + SendDurationSec uint64 + TotalDurationSec uint64 + TransportSize uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SnapshotStat) Descriptor() ([]byte, []int) + func (*SnapshotStat) ProtoMessage() + 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 (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 struct + Group string + Header *RequestHeader + RetryLimit uint64 + SplitKeys [][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitAndScatterRegionsRequest) Descriptor() ([]byte, []int) + func (*SplitAndScatterRegionsRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + RegionsId []uint64 + ScatterFinishedPercentage uint64 + SplitFinishedPercentage uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitAndScatterRegionsResponse) Descriptor() ([]byte, []int) + func (*SplitAndScatterRegionsResponse) ProtoMessage() + 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 (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 struct + NewPeerIds []uint64 + NewRegionId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitID) Descriptor() ([]byte, []int) + func (*SplitID) ProtoMessage() + 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 (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 struct + Keys [][]byte + Policy CheckPolicy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitRegion) Descriptor() ([]byte, []int) + func (*SplitRegion) ProtoMessage() + 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 (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 struct + Header *RequestHeader + RetryLimit uint64 + SplitKeys [][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitRegionsRequest) Descriptor() ([]byte, []int) + func (*SplitRegionsRequest) ProtoMessage() + 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 (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 struct + FinishedPercentage uint64 + Header *ResponseHeader + RegionsId []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitRegionsResponse) Descriptor() ([]byte, []int) + func (*SplitRegionsResponse) ProtoMessage() + 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 (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 struct + Changes []*GlobalConfigItem + ConfigPath string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreGlobalConfigRequest) Descriptor() ([]byte, []int) + func (*StoreGlobalConfigRequest) ProtoMessage() + 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 (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 struct + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreGlobalConfigResponse) Descriptor() ([]byte, []int) + func (*StoreGlobalConfigResponse) ProtoMessage() + 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 (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 struct + DrAutosyncStatus *replication_modepb.StoreDRAutoSyncStatus + Header *RequestHeader + Stats *StoreStats + StoreReport *StoreReport + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreHeartbeatRequest) Descriptor() ([]byte, []int) + func (*StoreHeartbeatRequest) ProtoMessage() + 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 (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 struct + AwakenRegions *AwakenRegions + ClusterVersion string + Header *ResponseHeader + RecoveryPlan *RecoveryPlan + ReplicationStatus *replication_modepb.ReplicationStatus + RequireDetailedReport bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreHeartbeatResponse) Descriptor() ([]byte, []int) + func (*StoreHeartbeatResponse) ProtoMessage() + 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() bool + 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 (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 struct + PeerReports []*PeerReport + Step uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreReport) Descriptor() ([]byte, []int) + func (*StoreReport) ProtoMessage() + 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 (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 struct + ApplyingSnapCount uint32 + Available uint64 + BytesRead uint64 + BytesWritten uint64 + Capacity uint64 + CpuUsages []*RecordPair + DamagedRegionsId []uint64 + Interval *TimeInterval + IsApplyBusy bool + IsBusy bool + KeysRead uint64 + KeysWritten uint64 + OpLatencies []*RecordPair + PeerStats []*PeerStat + QueryStats *QueryStats + ReadIoRates []*RecordPair + ReceivingSnapCount uint32 + RegionCount uint32 + SendingSnapCount uint32 + SlowScore uint64 + SlowTrend *SlowTrend + SnapshotStats []*SnapshotStat + StartTime uint32 + StoreId uint64 + UsedSize uint64 + WriteIoRates []*RecordPair + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreStats) Descriptor() ([]byte, []int) + func (*StoreStats) ProtoMessage() + 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 (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 struct + IsWitness bool + PeerId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SwitchWitness) Descriptor() ([]byte, []int) + func (*SwitchWitness) ProtoMessage() + 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 (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 struct + Header *RequestHeader + MaxTs *Timestamp + SkipCheck bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SyncMaxTSRequest) Descriptor() ([]byte, []int) + func (*SyncMaxTSRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + MaxLocalTs *Timestamp + SyncedDcs []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SyncMaxTSResponse) Descriptor() ([]byte, []int) + func (*SyncMaxTSResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + Member *Member + StartIndex uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SyncRegionRequest) Descriptor() ([]byte, []int) + func (*SyncRegionRequest) ProtoMessage() + 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 (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 struct + Buckets []*metapb.Buckets + DownPeers []*PeersStats + Header *ResponseHeader + PendingPeers []*Peers + RegionLeaders []*metapb.Peer + RegionStats []*RegionStat + Regions []*metapb.Region + StartIndex uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SyncRegionResponse) Descriptor() ([]byte, []int) + func (*SyncRegionResponse) ProtoMessage() + 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 (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 TMClient interface + AllocID func(ctx context.Context, in *AllocIDRequest, opts ...grpc.CallOption) (*AllocIDResponse, error) + AskBatchSplit func(ctx context.Context, in *AskBatchSplitRequest, opts ...grpc.CallOption) (*AskBatchSplitResponse, error) + AskSplit func(ctx context.Context, in *AskSplitRequest, opts ...grpc.CallOption) (*AskSplitResponse, error) + Bootstrap func(ctx context.Context, in *BootstrapRequest, opts ...grpc.CallOption) (*BootstrapResponse, error) + GetAllStores func(ctx context.Context, in *GetAllStoresRequest, opts ...grpc.CallOption) (*GetAllStoresResponse, error) + GetClusterConfig func(ctx context.Context, in *GetClusterConfigRequest, opts ...grpc.CallOption) (*GetClusterConfigResponse, error) + GetClusterInfo func(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error) + GetDCLocationInfo func(ctx context.Context, in *GetDCLocationInfoRequest, opts ...grpc.CallOption) (*GetDCLocationInfoResponse, error) + GetExternalTimestamp func(ctx context.Context, in *GetExternalTimestampRequest, opts ...grpc.CallOption) (*GetExternalTimestampResponse, error) + GetGCSafePoint func(ctx context.Context, in *GetGCSafePointRequest, opts ...grpc.CallOption) (*GetGCSafePointResponse, error) + GetGCSafePointV2 func(ctx context.Context, in *GetGCSafePointV2Request, opts ...grpc.CallOption) (*GetGCSafePointV2Response, error) + GetMembers func(ctx context.Context, in *GetMembersRequest, opts ...grpc.CallOption) (*GetMembersResponse, error) + GetMinTS func(ctx context.Context, in *GetMinTSRequest, opts ...grpc.CallOption) (*GetMinTSResponse, error) + GetOperator func(ctx context.Context, in *GetOperatorRequest, opts ...grpc.CallOption) (*GetOperatorResponse, error) + GetPrevRegion func(ctx context.Context, in *GetRegionRequest, opts ...grpc.CallOption) (*GetRegionResponse, error) + GetRegion func(ctx context.Context, in *GetRegionRequest, opts ...grpc.CallOption) (*GetRegionResponse, error) + GetRegionByID func(ctx context.Context, in *GetRegionByIDRequest, opts ...grpc.CallOption) (*GetRegionResponse, error) + GetStore func(ctx context.Context, in *GetStoreRequest, opts ...grpc.CallOption) (*GetStoreResponse, error) + IsBootstrapped func(ctx context.Context, in *IsBootstrappedRequest, opts ...grpc.CallOption) (*IsBootstrappedResponse, error) + IsSnapshotRecovering func(ctx context.Context, in *IsSnapshotRecoveringRequest, opts ...grpc.CallOption) (*IsSnapshotRecoveringResponse, error) + LoadGlobalConfig func(ctx context.Context, in *LoadGlobalConfigRequest, opts ...grpc.CallOption) (*LoadGlobalConfigResponse, error) + PutClusterConfig func(ctx context.Context, in *PutClusterConfigRequest, opts ...grpc.CallOption) (*PutClusterConfigResponse, error) + PutStore func(ctx context.Context, in *PutStoreRequest, opts ...grpc.CallOption) (*PutStoreResponse, error) + RegionHeartbeat func(ctx context.Context, opts ...grpc.CallOption) (TM_RegionHeartbeatClient, error) + ReportBatchSplit func(ctx context.Context, in *ReportBatchSplitRequest, opts ...grpc.CallOption) (*ReportBatchSplitResponse, error) + ReportBuckets func(ctx context.Context, opts ...grpc.CallOption) (TM_ReportBucketsClient, error) + ReportMinResolvedTS func(ctx context.Context, in *ReportMinResolvedTsRequest, opts ...grpc.CallOption) (*ReportMinResolvedTsResponse, error) + ReportSplit func(ctx context.Context, in *ReportSplitRequest, opts ...grpc.CallOption) (*ReportSplitResponse, error) + ScanRegions func(ctx context.Context, in *ScanRegionsRequest, opts ...grpc.CallOption) (*ScanRegionsResponse, error) + ScatterRegion func(ctx context.Context, in *ScatterRegionRequest, opts ...grpc.CallOption) (*ScatterRegionResponse, error) + SetExternalTimestamp func(ctx context.Context, in *SetExternalTimestampRequest, opts ...grpc.CallOption) (*SetExternalTimestampResponse, error) + SplitAndScatterRegions func(ctx context.Context, in *SplitAndScatterRegionsRequest, ...) (*SplitAndScatterRegionsResponse, error) + SplitRegions func(ctx context.Context, in *SplitRegionsRequest, opts ...grpc.CallOption) (*SplitRegionsResponse, error) + StoreGlobalConfig func(ctx context.Context, in *StoreGlobalConfigRequest, opts ...grpc.CallOption) (*StoreGlobalConfigResponse, error) + StoreHeartbeat func(ctx context.Context, in *StoreHeartbeatRequest, opts ...grpc.CallOption) (*StoreHeartbeatResponse, error) + SyncMaxTS func(ctx context.Context, in *SyncMaxTSRequest, opts ...grpc.CallOption) (*SyncMaxTSResponse, error) + SyncRegions func(ctx context.Context, opts ...grpc.CallOption) (TM_SyncRegionsClient, error) + Tso func(ctx context.Context, opts ...grpc.CallOption) (TM_TsoClient, error) + UpdateGCSafePoint func(ctx context.Context, in *UpdateGCSafePointRequest, opts ...grpc.CallOption) (*UpdateGCSafePointResponse, error) + UpdateGCSafePointV2 func(ctx context.Context, in *UpdateGCSafePointV2Request, opts ...grpc.CallOption) (*UpdateGCSafePointV2Response, error) + UpdateServiceGCSafePoint func(ctx context.Context, in *UpdateServiceGCSafePointRequest, ...) (*UpdateServiceGCSafePointResponse, error) + UpdateServiceSafePointV2 func(ctx context.Context, in *UpdateServiceSafePointV2Request, ...) (*UpdateServiceSafePointV2Response, error) + WatchGCSafePointV2 func(ctx context.Context, in *WatchGCSafePointV2Request, opts ...grpc.CallOption) (TM_WatchGCSafePointV2Client, error) + WatchGlobalConfig func(ctx context.Context, in *WatchGlobalConfigRequest, opts ...grpc.CallOption) (TM_WatchGlobalConfigClient, error) + func NewTMClient(cc *grpc.ClientConn) TMClient + type TMServer interface + AllocID func(context.Context, *AllocIDRequest) (*AllocIDResponse, error) + AskBatchSplit func(context.Context, *AskBatchSplitRequest) (*AskBatchSplitResponse, error) + AskSplit func(context.Context, *AskSplitRequest) (*AskSplitResponse, error) + Bootstrap func(context.Context, *BootstrapRequest) (*BootstrapResponse, error) + GetAllStores func(context.Context, *GetAllStoresRequest) (*GetAllStoresResponse, error) + GetClusterConfig func(context.Context, *GetClusterConfigRequest) (*GetClusterConfigResponse, error) + GetClusterInfo func(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error) + GetDCLocationInfo func(context.Context, *GetDCLocationInfoRequest) (*GetDCLocationInfoResponse, error) + GetExternalTimestamp func(context.Context, *GetExternalTimestampRequest) (*GetExternalTimestampResponse, error) + GetGCSafePoint func(context.Context, *GetGCSafePointRequest) (*GetGCSafePointResponse, error) + GetGCSafePointV2 func(context.Context, *GetGCSafePointV2Request) (*GetGCSafePointV2Response, error) + GetMembers func(context.Context, *GetMembersRequest) (*GetMembersResponse, error) + GetMinTS func(context.Context, *GetMinTSRequest) (*GetMinTSResponse, error) + GetOperator func(context.Context, *GetOperatorRequest) (*GetOperatorResponse, error) + GetPrevRegion func(context.Context, *GetRegionRequest) (*GetRegionResponse, error) + GetRegion func(context.Context, *GetRegionRequest) (*GetRegionResponse, error) + GetRegionByID func(context.Context, *GetRegionByIDRequest) (*GetRegionResponse, error) + GetStore func(context.Context, *GetStoreRequest) (*GetStoreResponse, error) + IsBootstrapped func(context.Context, *IsBootstrappedRequest) (*IsBootstrappedResponse, error) + IsSnapshotRecovering func(context.Context, *IsSnapshotRecoveringRequest) (*IsSnapshotRecoveringResponse, error) + LoadGlobalConfig func(context.Context, *LoadGlobalConfigRequest) (*LoadGlobalConfigResponse, error) + PutClusterConfig func(context.Context, *PutClusterConfigRequest) (*PutClusterConfigResponse, error) + PutStore func(context.Context, *PutStoreRequest) (*PutStoreResponse, error) + RegionHeartbeat func(TM_RegionHeartbeatServer) error + ReportBatchSplit func(context.Context, *ReportBatchSplitRequest) (*ReportBatchSplitResponse, error) + ReportBuckets func(TM_ReportBucketsServer) error + ReportMinResolvedTS func(context.Context, *ReportMinResolvedTsRequest) (*ReportMinResolvedTsResponse, error) + ReportSplit func(context.Context, *ReportSplitRequest) (*ReportSplitResponse, error) + ScanRegions func(context.Context, *ScanRegionsRequest) (*ScanRegionsResponse, error) + ScatterRegion func(context.Context, *ScatterRegionRequest) (*ScatterRegionResponse, error) + SetExternalTimestamp func(context.Context, *SetExternalTimestampRequest) (*SetExternalTimestampResponse, error) + SplitAndScatterRegions func(context.Context, *SplitAndScatterRegionsRequest) (*SplitAndScatterRegionsResponse, error) + SplitRegions func(context.Context, *SplitRegionsRequest) (*SplitRegionsResponse, error) + StoreGlobalConfig func(context.Context, *StoreGlobalConfigRequest) (*StoreGlobalConfigResponse, error) + StoreHeartbeat func(context.Context, *StoreHeartbeatRequest) (*StoreHeartbeatResponse, error) + SyncMaxTS func(context.Context, *SyncMaxTSRequest) (*SyncMaxTSResponse, error) + SyncRegions func(TM_SyncRegionsServer) error + Tso func(TM_TsoServer) error + UpdateGCSafePoint func(context.Context, *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error) + UpdateGCSafePointV2 func(context.Context, *UpdateGCSafePointV2Request) (*UpdateGCSafePointV2Response, error) + UpdateServiceGCSafePoint func(context.Context, *UpdateServiceGCSafePointRequest) (*UpdateServiceGCSafePointResponse, error) + UpdateServiceSafePointV2 func(context.Context, *UpdateServiceSafePointV2Request) (*UpdateServiceSafePointV2Response, error) + WatchGCSafePointV2 func(*WatchGCSafePointV2Request, TM_WatchGCSafePointV2Server) error + WatchGlobalConfig func(*WatchGlobalConfigRequest, TM_WatchGlobalConfigServer) error + type TM_RegionHeartbeatClient interface + Recv func() (*RegionHeartbeatResponse, error) + Send func(*RegionHeartbeatRequest) error + type TM_RegionHeartbeatServer interface + Recv func() (*RegionHeartbeatRequest, error) + Send func(*RegionHeartbeatResponse) error + type TM_ReportBucketsClient interface + CloseAndRecv func() (*ReportBucketsResponse, error) + Send func(*ReportBucketsRequest) error + type TM_ReportBucketsServer interface + Recv func() (*ReportBucketsRequest, error) + SendAndClose func(*ReportBucketsResponse) error + type TM_SyncRegionsClient interface + Recv func() (*SyncRegionResponse, error) + Send func(*SyncRegionRequest) error + type TM_SyncRegionsServer interface + Recv func() (*SyncRegionRequest, error) + Send func(*SyncRegionResponse) error + type TM_TsoClient interface + Recv func() (*TsoResponse, error) + Send func(*TsoRequest) error + type TM_TsoServer interface + Recv func() (*TsoRequest, error) + Send func(*TsoResponse) error + type TM_WatchGCSafePointV2Client interface + Recv func() (*WatchGCSafePointV2Response, error) + type TM_WatchGCSafePointV2Server interface + Send func(*WatchGCSafePointV2Response) error + type TM_WatchGlobalConfigClient interface + Recv func() (*WatchGlobalConfigResponse, error) + type TM_WatchGlobalConfigServer interface + Send func(*WatchGlobalConfigResponse) error + type TimeInterval struct + EndTimestamp uint64 + StartTimestamp uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TimeInterval) Descriptor() ([]byte, []int) + func (*TimeInterval) ProtoMessage() + 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 (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 struct + Logical int64 + Physical int64 + SuffixBits uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Timestamp) Descriptor() ([]byte, []int) + func (*Timestamp) ProtoMessage() + 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 (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 struct + Peer *metapb.Peer + Peers []*metapb.Peer + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TransferLeader) Descriptor() ([]byte, []int) + func (*TransferLeader) ProtoMessage() + 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 (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 struct + Count uint32 + DcLocation string + Header *RequestHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TsoRequest) Descriptor() ([]byte, []int) + func (*TsoRequest) ProtoMessage() + 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 (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 struct + Count uint32 + Header *ResponseHeader + Timestamp *Timestamp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TsoResponse) Descriptor() ([]byte, []int) + func (*TsoResponse) ProtoMessage() + 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 (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 UnimplementedTMServer struct + func (*UnimplementedTMServer) AllocID(ctx context.Context, req *AllocIDRequest) (*AllocIDResponse, error) + func (*UnimplementedTMServer) AskBatchSplit(ctx context.Context, req *AskBatchSplitRequest) (*AskBatchSplitResponse, error) + func (*UnimplementedTMServer) AskSplit(ctx context.Context, req *AskSplitRequest) (*AskSplitResponse, error) + func (*UnimplementedTMServer) Bootstrap(ctx context.Context, req *BootstrapRequest) (*BootstrapResponse, error) + func (*UnimplementedTMServer) GetAllStores(ctx context.Context, req *GetAllStoresRequest) (*GetAllStoresResponse, error) + func (*UnimplementedTMServer) GetClusterConfig(ctx context.Context, req *GetClusterConfigRequest) (*GetClusterConfigResponse, error) + func (*UnimplementedTMServer) GetClusterInfo(ctx context.Context, req *GetClusterInfoRequest) (*GetClusterInfoResponse, error) + func (*UnimplementedTMServer) GetDCLocationInfo(ctx context.Context, req *GetDCLocationInfoRequest) (*GetDCLocationInfoResponse, error) + func (*UnimplementedTMServer) GetExternalTimestamp(ctx context.Context, req *GetExternalTimestampRequest) (*GetExternalTimestampResponse, error) + func (*UnimplementedTMServer) GetGCSafePoint(ctx context.Context, req *GetGCSafePointRequest) (*GetGCSafePointResponse, error) + func (*UnimplementedTMServer) GetGCSafePointV2(ctx context.Context, req *GetGCSafePointV2Request) (*GetGCSafePointV2Response, error) + func (*UnimplementedTMServer) GetMembers(ctx context.Context, req *GetMembersRequest) (*GetMembersResponse, error) + func (*UnimplementedTMServer) GetMinTS(ctx context.Context, req *GetMinTSRequest) (*GetMinTSResponse, error) + func (*UnimplementedTMServer) GetOperator(ctx context.Context, req *GetOperatorRequest) (*GetOperatorResponse, error) + func (*UnimplementedTMServer) GetPrevRegion(ctx context.Context, req *GetRegionRequest) (*GetRegionResponse, error) + func (*UnimplementedTMServer) GetRegion(ctx context.Context, req *GetRegionRequest) (*GetRegionResponse, error) + func (*UnimplementedTMServer) GetRegionByID(ctx context.Context, req *GetRegionByIDRequest) (*GetRegionResponse, error) + func (*UnimplementedTMServer) GetStore(ctx context.Context, req *GetStoreRequest) (*GetStoreResponse, error) + func (*UnimplementedTMServer) IsBootstrapped(ctx context.Context, req *IsBootstrappedRequest) (*IsBootstrappedResponse, error) + func (*UnimplementedTMServer) IsSnapshotRecovering(ctx context.Context, req *IsSnapshotRecoveringRequest) (*IsSnapshotRecoveringResponse, error) + func (*UnimplementedTMServer) LoadGlobalConfig(ctx context.Context, req *LoadGlobalConfigRequest) (*LoadGlobalConfigResponse, error) + func (*UnimplementedTMServer) PutClusterConfig(ctx context.Context, req *PutClusterConfigRequest) (*PutClusterConfigResponse, error) + func (*UnimplementedTMServer) PutStore(ctx context.Context, req *PutStoreRequest) (*PutStoreResponse, error) + func (*UnimplementedTMServer) RegionHeartbeat(srv TM_RegionHeartbeatServer) error + func (*UnimplementedTMServer) ReportBatchSplit(ctx context.Context, req *ReportBatchSplitRequest) (*ReportBatchSplitResponse, error) + func (*UnimplementedTMServer) ReportBuckets(srv TM_ReportBucketsServer) error + func (*UnimplementedTMServer) ReportMinResolvedTS(ctx context.Context, req *ReportMinResolvedTsRequest) (*ReportMinResolvedTsResponse, error) + func (*UnimplementedTMServer) ReportSplit(ctx context.Context, req *ReportSplitRequest) (*ReportSplitResponse, error) + func (*UnimplementedTMServer) ScanRegions(ctx context.Context, req *ScanRegionsRequest) (*ScanRegionsResponse, error) + func (*UnimplementedTMServer) ScatterRegion(ctx context.Context, req *ScatterRegionRequest) (*ScatterRegionResponse, error) + func (*UnimplementedTMServer) SetExternalTimestamp(ctx context.Context, req *SetExternalTimestampRequest) (*SetExternalTimestampResponse, error) + func (*UnimplementedTMServer) SplitAndScatterRegions(ctx context.Context, req *SplitAndScatterRegionsRequest) (*SplitAndScatterRegionsResponse, error) + func (*UnimplementedTMServer) SplitRegions(ctx context.Context, req *SplitRegionsRequest) (*SplitRegionsResponse, error) + func (*UnimplementedTMServer) StoreGlobalConfig(ctx context.Context, req *StoreGlobalConfigRequest) (*StoreGlobalConfigResponse, error) + func (*UnimplementedTMServer) StoreHeartbeat(ctx context.Context, req *StoreHeartbeatRequest) (*StoreHeartbeatResponse, error) + func (*UnimplementedTMServer) SyncMaxTS(ctx context.Context, req *SyncMaxTSRequest) (*SyncMaxTSResponse, error) + func (*UnimplementedTMServer) SyncRegions(srv TM_SyncRegionsServer) error + func (*UnimplementedTMServer) Tso(srv TM_TsoServer) error + func (*UnimplementedTMServer) UpdateGCSafePoint(ctx context.Context, req *UpdateGCSafePointRequest) (*UpdateGCSafePointResponse, error) + func (*UnimplementedTMServer) UpdateGCSafePointV2(ctx context.Context, req *UpdateGCSafePointV2Request) (*UpdateGCSafePointV2Response, error) + func (*UnimplementedTMServer) UpdateServiceGCSafePoint(ctx context.Context, req *UpdateServiceGCSafePointRequest) (*UpdateServiceGCSafePointResponse, error) + func (*UnimplementedTMServer) UpdateServiceSafePointV2(ctx context.Context, req *UpdateServiceSafePointV2Request) (*UpdateServiceSafePointV2Response, error) + func (*UnimplementedTMServer) WatchGCSafePointV2(req *WatchGCSafePointV2Request, srv TM_WatchGCSafePointV2Server) error + func (*UnimplementedTMServer) WatchGlobalConfig(req *WatchGlobalConfigRequest, srv TM_WatchGlobalConfigServer) error + type UpdateGCSafePointRequest struct + Header *RequestHeader + SafePoint uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateGCSafePointRequest) Descriptor() ([]byte, []int) + func (*UpdateGCSafePointRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + NewSafePoint uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateGCSafePointResponse) Descriptor() ([]byte, []int) + func (*UpdateGCSafePointResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + KeyspaceId uint32 + SafePoint uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateGCSafePointV2Request) Descriptor() ([]byte, []int) + func (*UpdateGCSafePointV2Request) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + NewSafePoint uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateGCSafePointV2Response) Descriptor() ([]byte, []int) + func (*UpdateGCSafePointV2Response) ProtoMessage() + 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 (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 struct + Header *RequestHeader + SafePoint uint64 + ServiceId []byte + TTL int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateServiceGCSafePointRequest) Descriptor() ([]byte, []int) + func (*UpdateServiceGCSafePointRequest) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + MinSafePoint uint64 + ServiceId []byte + TTL int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateServiceGCSafePointResponse) Descriptor() ([]byte, []int) + func (*UpdateServiceGCSafePointResponse) ProtoMessage() + 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 (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 struct + Header *RequestHeader + KeyspaceId uint32 + SafePoint uint64 + ServiceId []byte + Ttl int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateServiceSafePointV2Request) Descriptor() ([]byte, []int) + func (*UpdateServiceSafePointV2Request) ProtoMessage() + 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 (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 struct + Header *ResponseHeader + MinSafePoint uint64 + ServiceId []byte + Ttl int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateServiceSafePointV2Response) Descriptor() ([]byte, []int) + func (*UpdateServiceSafePointV2Response) ProtoMessage() + 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 (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 struct + Header *RequestHeader + Revision int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchGCSafePointV2Request) Descriptor() ([]byte, []int) + func (*WatchGCSafePointV2Request) ProtoMessage() + 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 (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 struct + Events []*SafePointEvent + Header *ResponseHeader + Revision int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchGCSafePointV2Response) Descriptor() ([]byte, []int) + func (*WatchGCSafePointV2Response) ProtoMessage() + 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 (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 struct + ConfigPath string + Revision int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchGlobalConfigRequest) Descriptor() ([]byte, []int) + func (*WatchGlobalConfigRequest) ProtoMessage() + 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 (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 struct + Changes []*GlobalConfigItem + Header *ResponseHeader + Revision int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WatchGlobalConfigResponse) Descriptor() ([]byte, []int) + func (*WatchGlobalConfigResponse) ProtoMessage() + 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 (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