Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + const EmptyRegionApproximateSize + const EngineKey + const EngineTiFlash + const EngineTiKV + const ImpossibleFlowSize + const InitClusterRegionThreshold + var ClusterFactory = func() *metapb.Cluster + var KeyDictionaryFactory = func() *encryptionpb.KeyDictionary + var MemberFactory = func() *pdpb.Member + var PeerStatsFactory = func() *pdpb.PeerStats + var QueryStatsFactory = func() *pdpb.QueryStats + var RegionFactory = func() *metapb.Region + var RegionHeartbeatResponseFactory = func() *pdpb.RegionHeartbeatResponse + var RegionPeerFactory = func() *metapb.Peer + var StoreFactory = func() *metapb.Store + var StoreStatsFactory = func() *pdpb.StoreStats + var TimeIntervalFactory = func() *pdpb.TimeInterval + func CountInJointState(peers ...*metapb.Peer) int + func DiffRegionKeyInfo(origin *RegionInfo, other *RegionInfo) string + func DiffRegionPeersInfo(origin *RegionInfo, other *RegionInfo) string + func DistinctScore(labels []string, stores []*StoreInfo, other *StoreInfo) float64 + func EncodeToString(src []byte) []byte + func GetReadQueryNum(stats *pdpb.QueryStats) uint64 + func GetWriteQueryNum(stats *pdpb.QueryStats) uint64 + func HexRegionKey(key []byte) []byte + func HexRegionKeyStr(key []byte) string + func IsAvailableForMinResolvedTS(s *StoreInfo) bool + func IsInJointState(peers ...*metapb.Peer) bool + func IsLearner(peer *metapb.Peer) bool + func IsLearnerOrDemotingVoter(peer *metapb.Peer) bool + func IsStoreContainLabel(store *metapb.Store, key, value string) bool + func IsVoter(peer *metapb.Peer) bool + func IsVoterOrIncomingVoter(peer *metapb.Peer) bool + func IsWitness(peer *metapb.Peer) bool + func MergeLabels(origin []*metapb.StoreLabel, labels []*metapb.StoreLabel) []*metapb.StoreLabel + func NeedTransferWitnessLeader(region *RegionInfo) bool + func RandomKindReadQuery(queryRead uint64) *pdpb.QueryStats + func RandomKindWriteQuery(queryWrite uint64) *pdpb.QueryStats + func SortedPeersEqual(peersA, peersB []*metapb.Peer) bool + func SortedPeersStatsEqual(peersA, peersB []*pdpb.PeerStats) bool + func String(b []byte) (s string) + func ToUpperASCIIInplace(s []byte) []byte + type BasicCluster struct + Stores struct{ ... } + func NewBasicCluster() *BasicCluster + func (bc *BasicCluster) DeleteStore(store *StoreInfo) + func (bc *BasicCluster) GetFollowerStores(region *RegionInfo) []*StoreInfo + func (bc *BasicCluster) GetLeaderStore(region *RegionInfo) *StoreInfo + func (bc *BasicCluster) GetLeaderStoreByRegionID(regionID uint64) *StoreInfo + func (bc *BasicCluster) GetMetaStores() []*metapb.Store + func (bc *BasicCluster) GetNonWitnessVoterStores(region *RegionInfo) []*StoreInfo + func (bc *BasicCluster) GetRegionStores(region *RegionInfo) []*StoreInfo + func (bc *BasicCluster) GetStore(storeID uint64) *StoreInfo + func (bc *BasicCluster) GetStoreCount() int + func (bc *BasicCluster) GetStores() []*StoreInfo + func (bc *BasicCluster) GetStoresLeaderWriteRate() (storeIDs []uint64, bytesRates, keysRates []float64) + func (bc *BasicCluster) GetStoresWriteRate() (storeIDs []uint64, bytesRates, keysRates []float64) + func (bc *BasicCluster) PauseLeaderTransfer(storeID uint64) error + func (bc *BasicCluster) PutStore(store *StoreInfo) + func (bc *BasicCluster) ResetStoreLimit(storeID uint64, limitType storelimit.Type, ratePerSec ...float64) + func (bc *BasicCluster) ResetStores() + func (bc *BasicCluster) ResumeLeaderTransfer(storeID uint64) + func (bc *BasicCluster) SlowStoreEvicted(storeID uint64) error + func (bc *BasicCluster) SlowStoreRecovered(storeID uint64) + func (bc *BasicCluster) SlowTrendEvicted(storeID uint64) error + func (bc *BasicCluster) SlowTrendRecovered(storeID uint64) + func (bc *BasicCluster) UpdateStoreStatus(storeID uint64) + type HexRegionMeta struct + func RegionToHexMeta(meta *metapb.Region) HexRegionMeta + func (h HexRegionMeta) String() string + type HexRegionsMeta []*metapb.Region + func RegionsToHexMeta(regions []*metapb.Region) HexRegionsMeta + func (h HexRegionsMeta) String() string + type KeyRange struct + EndKey []byte + StartKey []byte + func NewKeyRange(startKey, endKey string) KeyRange + type PeerInfo struct + func NewPeerInfo(meta *metapb.Peer, loads []float64, interval uint64) *PeerInfo + func (p *PeerInfo) GetInterval() uint64 + func (p *PeerInfo) GetLoads() []float64 + func (p *PeerInfo) GetPeerID() uint64 + type RegionCreateOption func(region *RegionInfo) + func AddQueryStats(v *pdpb.QueryStats) RegionCreateOption + func SetApproximateKeys(v int64) RegionCreateOption + func SetApproximateSize(v int64) RegionCreateOption + func SetBuckets(buckets *metapb.Buckets) RegionCreateOption + func SetCPUUsage(v uint64) RegionCreateOption + func SetFromHeartbeat(fromHeartbeat bool) RegionCreateOption + func SetPeers(peers []*metapb.Peer) RegionCreateOption + func SetQueryStats(v *pdpb.QueryStats) RegionCreateOption + func SetReadBytes(v uint64) RegionCreateOption + func SetReadKeys(v uint64) RegionCreateOption + func SetReadQuery(v uint64) RegionCreateOption + func SetRegionConfVer(confVer uint64) RegionCreateOption + func SetRegionVersion(version uint64) RegionCreateOption + func SetReplicationStatus(status *replication_modepb.RegionReplicationStatus) RegionCreateOption + func SetReportInterval(start, end uint64) RegionCreateOption + func SetWrittenBytes(v uint64) RegionCreateOption + func SetWrittenKeys(v uint64) RegionCreateOption + func SetWrittenQuery(v uint64) RegionCreateOption + func WithAddPeer(peer *metapb.Peer) RegionCreateOption + func WithDecConfVer() RegionCreateOption + func WithDecVersion() RegionCreateOption + func WithDownPeers(downPeers []*pdpb.PeerStats) RegionCreateOption + func WithEndKey(key []byte) RegionCreateOption + func WithFlowRoundByDigit(digit int) RegionCreateOption + func WithIncConfVer() RegionCreateOption + func WithIncVersion() RegionCreateOption + func WithInterval(interval *pdpb.TimeInterval) RegionCreateOption + func WithLeader(leader *metapb.Peer) RegionCreateOption + func WithLearners(learners []*metapb.Peer) RegionCreateOption + func WithNewPeerIDs(peerIDs ...uint64) RegionCreateOption + func WithNewRegionID(id uint64) RegionCreateOption + func WithPendingPeers(pendingPeers []*metapb.Peer) RegionCreateOption + func WithRemoveStorePeer(storeID uint64) RegionCreateOption + func WithReplacePeerStore(oldStoreID, newStoreID uint64) RegionCreateOption + func WithRole(peerID uint64, role metapb.PeerRole) RegionCreateOption + func WithStartKey(key []byte) RegionCreateOption + func WithWitness(peerID uint64) RegionCreateOption + func WithWitnesses(witnesses []*metapb.Peer) RegionCreateOption + type RegionGuideFunc func(region, origin *RegionInfo) (isNew, saveKV, saveCache, needSync bool) + func GenerateRegionGuideFunc(enableLog bool) RegionGuideFunc + type RegionInfo struct + func MergeRegions(regions []*RegionInfo) []*RegionInfo + func NewRegionInfo(region *metapb.Region, leader *metapb.Peer, opts ...RegionCreateOption) *RegionInfo + func NewTestRegionInfo(regionID, storeID uint64, start, end []byte, opts ...RegionCreateOption) *RegionInfo + func RegionFromHeartbeat(heartbeat *pdpb.RegionHeartbeatRequest, opts ...RegionCreateOption) *RegionInfo + func SplitRegions(regions []*RegionInfo) []*RegionInfo + func (r *RegionInfo) Clone(opts ...RegionCreateOption) *RegionInfo + func (r *RegionInfo) GetApproximateKeys() int64 + func (r *RegionInfo) GetApproximateSize() int64 + func (r *RegionInfo) GetBuckets() *metapb.Buckets + func (r *RegionInfo) GetBytesRead() uint64 + func (r *RegionInfo) GetBytesWritten() uint64 + func (r *RegionInfo) GetCPUUsage() uint64 + func (r *RegionInfo) GetDiffFollowers(other *RegionInfo) []*metapb.Peer + func (r *RegionInfo) GetDownLearner(peerID uint64) *metapb.Peer + func (r *RegionInfo) GetDownPeer(peerID uint64) *metapb.Peer + func (r *RegionInfo) GetDownPeers() []*pdpb.PeerStats + func (r *RegionInfo) GetDownVoter(peerID uint64) *metapb.Peer + func (r *RegionInfo) GetEndKey() []byte + func (r *RegionInfo) GetFollower() *metapb.Peer + func (r *RegionInfo) GetFollowers() map[uint64]*metapb.Peer + func (r *RegionInfo) GetID() uint64 + func (r *RegionInfo) GetInterval() *pdpb.TimeInterval + func (r *RegionInfo) GetKeysRead() uint64 + func (r *RegionInfo) GetKeysWritten() uint64 + func (r *RegionInfo) GetLeader() *metapb.Peer + func (r *RegionInfo) GetLearners() []*metapb.Peer + func (r *RegionInfo) GetLoads() []float64 + func (r *RegionInfo) GetMeta() *metapb.Region + func (r *RegionInfo) GetNonWitnessVoters() map[uint64]*metapb.Peer + func (r *RegionInfo) GetPeer(peerID uint64) *metapb.Peer + func (r *RegionInfo) GetPeers() []*metapb.Peer + func (r *RegionInfo) GetPendingLearner(peerID uint64) *metapb.Peer + func (r *RegionInfo) GetPendingPeer(peerID uint64) *metapb.Peer + func (r *RegionInfo) GetPendingPeers() []*metapb.Peer + func (r *RegionInfo) GetPendingVoter(peerID uint64) *metapb.Peer + func (r *RegionInfo) GetReadQueryNum() uint64 + func (r *RegionInfo) GetRegionEpoch() *metapb.RegionEpoch + func (r *RegionInfo) GetReplicationStatus() *replication_modepb.RegionReplicationStatus + func (r *RegionInfo) GetRoundBytesRead() uint64 + func (r *RegionInfo) GetRoundBytesWritten() uint64 + func (r *RegionInfo) GetStartKey() []byte + func (r *RegionInfo) GetStat() *pdpb.RegionStat + func (r *RegionInfo) GetStoreIDs() map[uint64]struct{} + func (r *RegionInfo) GetStoreLearner(storeID uint64) *metapb.Peer + func (r *RegionInfo) GetStorePeer(storeID uint64) *metapb.Peer + func (r *RegionInfo) GetStorePeerApproximateKeys(storeID uint64) int64 + func (r *RegionInfo) GetStorePeerApproximateSize(storeID uint64) int64 + func (r *RegionInfo) GetStoreVoter(storeID uint64) *metapb.Peer + func (r *RegionInfo) GetStoreWitness(storeID uint64) *metapb.Peer + func (r *RegionInfo) GetTerm() uint64 + func (r *RegionInfo) GetVoters() []*metapb.Peer + func (r *RegionInfo) GetWitnesses() []*metapb.Peer + func (r *RegionInfo) GetWriteLoads() []float64 + func (r *RegionInfo) GetWriteQueryNum() uint64 + func (r *RegionInfo) GetWriteRate() (bytesRate, keysRate float64) + func (r *RegionInfo) Inherit(origin *RegionInfo, bucketEnable bool) + func (r *RegionInfo) IsFromHeartbeat() bool + func (r *RegionInfo) IsOversized(maxSize int64, maxKeys int64) bool + func (r *RegionInfo) NeedMerge(mergeSize int64, mergeKeys int64) bool + func (r *RegionInfo) UpdateBuckets(buckets, old *metapb.Buckets) bool + type RegionSetInformer interface + GetAdjacentRegions func(region *RegionInfo) (*RegionInfo, *RegionInfo) + GetAverageRegionSize func() int64 + GetRegion func(id uint64) *RegionInfo + GetRegionByKey func(regionKey []byte) *RegionInfo + GetRegionCount func() int + GetStoreRegionCount func(storeID uint64) int + RandFollowerRegions func(storeID uint64, ranges []KeyRange) []*RegionInfo + RandLeaderRegions func(storeID uint64, ranges []KeyRange) []*RegionInfo + RandLearnerRegions func(storeID uint64, ranges []KeyRange) []*RegionInfo + RandPendingRegions func(storeID uint64, ranges []KeyRange) []*RegionInfo + RandWitnessRegions func(storeID uint64, ranges []KeyRange) []*RegionInfo + ScanRegions func(startKey, endKey []byte, limit int) []*RegionInfo + type RegionsInfo struct + func NewRegionsInfo() *RegionsInfo + func (r *RegionsInfo) AtomicCheckAndPutRegion(region *RegionInfo) ([]*RegionInfo, error) + func (r *RegionsInfo) CheckAndPutRegion(region *RegionInfo) []*RegionInfo + func (r *RegionsInfo) GetAdjacentRegions(region *RegionInfo) (*RegionInfo, *RegionInfo) + func (r *RegionsInfo) GetAverageRegionSize() int64 + func (r *RegionsInfo) GetFollower(storeID uint64, region *RegionInfo) *RegionInfo + func (r *RegionsInfo) GetLeader(storeID uint64, region *RegionInfo) *RegionInfo + func (r *RegionsInfo) GetMetaRegions() []*metapb.Region + func (r *RegionsInfo) GetOverlaps(region *RegionInfo) []*regionItem + func (r *RegionsInfo) GetPrevRegionByKey(regionKey []byte) *RegionInfo + func (r *RegionsInfo) GetRangeCount(startKey, endKey []byte) int + func (r *RegionsInfo) GetRangeHoles() [][]string + func (r *RegionsInfo) GetRegion(regionID uint64) *RegionInfo + func (r *RegionsInfo) GetRegionByKey(regionKey []byte) *RegionInfo + func (r *RegionsInfo) GetRegionCount() int + func (r *RegionsInfo) GetRegionSizeByRange(startKey, endKey []byte) int64 + func (r *RegionsInfo) GetRegions() []*RegionInfo + func (r *RegionsInfo) GetRelevantRegions(region *RegionInfo) (origin *RegionInfo, overlaps []*regionItem) + func (r *RegionsInfo) GetStoreFollowerCount(storeID uint64) int + func (r *RegionsInfo) GetStoreFollowerRegionSize(storeID uint64) int64 + func (r *RegionsInfo) GetStoreLeaderCount(storeID uint64) int + func (r *RegionsInfo) GetStoreLeaderRegionSize(storeID uint64) int64 + func (r *RegionsInfo) GetStoreLeaderWriteRate(storeID uint64) (bytesRate, keysRate float64) + func (r *RegionsInfo) GetStoreLearnerCount(storeID uint64) int + func (r *RegionsInfo) GetStoreLearnerRegionSize(storeID uint64) int64 + func (r *RegionsInfo) GetStorePendingPeerCount(storeID uint64) int + func (r *RegionsInfo) GetStoreRegionCount(storeID uint64) int + func (r *RegionsInfo) GetStoreRegionSize(storeID uint64) int64 + func (r *RegionsInfo) GetStoreRegions(storeID uint64) []*RegionInfo + func (r *RegionsInfo) GetStoreStats(storeID uint64) (leader, region, witness, learner, pending int, leaderSize, regionSize int64) + func (r *RegionsInfo) GetStoreWitnessCount(storeID uint64) int + func (r *RegionsInfo) GetStoreWriteRate(storeID uint64) (bytesRate, keysRate float64) + func (r *RegionsInfo) PreCheckPutRegion(region *RegionInfo) (*RegionInfo, []*regionItem, error) + func (r *RegionsInfo) PutRegion(region *RegionInfo) []*RegionInfo + func (r *RegionsInfo) RandFollowerRegion(storeID uint64, ranges []KeyRange) *RegionInfo + func (r *RegionsInfo) RandFollowerRegions(storeID uint64, ranges []KeyRange) []*RegionInfo + func (r *RegionsInfo) RandLeaderRegion(storeID uint64, ranges []KeyRange) *RegionInfo + func (r *RegionsInfo) RandLeaderRegions(storeID uint64, ranges []KeyRange) []*RegionInfo + func (r *RegionsInfo) RandLearnerRegion(storeID uint64, ranges []KeyRange) *RegionInfo + func (r *RegionsInfo) RandLearnerRegions(storeID uint64, ranges []KeyRange) []*RegionInfo + func (r *RegionsInfo) RandPendingRegion(storeID uint64, ranges []KeyRange) *RegionInfo + func (r *RegionsInfo) RandPendingRegions(storeID uint64, ranges []KeyRange) []*RegionInfo + func (r *RegionsInfo) RandWitnessRegion(storeID uint64, ranges []KeyRange) *RegionInfo + func (r *RegionsInfo) RandWitnessRegions(storeID uint64, ranges []KeyRange) []*RegionInfo + func (r *RegionsInfo) RemoveRegion(region *RegionInfo) + func (r *RegionsInfo) RemoveRegionFromSubTree(region *RegionInfo) + func (r *RegionsInfo) RemoveRegionIfExist(id uint64) + func (r *RegionsInfo) ResetRegionCache() + func (r *RegionsInfo) ScanRange(startKey, endKey []byte, limit int) []*RegionInfo + func (r *RegionsInfo) ScanRangeWithIterator(startKey []byte, iterator func(region *RegionInfo) bool) + func (r *RegionsInfo) SetRegion(region *RegionInfo) (*RegionInfo, []*RegionInfo, bool) + func (r *RegionsInfo) TreeLen() int + func (r *RegionsInfo) UpdateSubTree(region, origin *RegionInfo, overlaps []*RegionInfo, rangeChanged bool) + type StoreCreateOption func(store *StoreInfo) + func OfflineStore(physicallyDestroyed bool) StoreCreateOption + func PauseLeaderTransfer() StoreCreateOption + func ResetStoreLimit(limitType storelimit.Type, ratePerSec ...float64) StoreCreateOption + func ResumeLeaderTransfer() StoreCreateOption + func SetLastAwakenTime(lastAwaken time.Time) StoreCreateOption + func SetLastHeartbeatTS(lastHeartbeatTS time.Time) StoreCreateOption + func SetLastPersistTime(lastPersist time.Time) StoreCreateOption + func SetLeaderCount(leaderCount int) StoreCreateOption + func SetLeaderSize(leaderSize int64) StoreCreateOption + func SetLeaderWeight(leaderWeight float64) StoreCreateOption + func SetLearnerCount(learnerCount int) StoreCreateOption + func SetMinResolvedTS(minResolvedTS uint64) StoreCreateOption + func SetNewStoreStats(stats *pdpb.StoreStats) StoreCreateOption + func SetPendingPeerCount(pendingPeerCount int) StoreCreateOption + func SetRegionCount(regionCount int) StoreCreateOption + func SetRegionSize(regionSize int64) StoreCreateOption + func SetRegionWeight(regionWeight float64) StoreCreateOption + func SetStoreAddress(address, statusAddress, peerAddress string) StoreCreateOption + func SetStoreDeployPath(deployPath string) StoreCreateOption + func SetStoreLabels(labels []*metapb.StoreLabel) StoreCreateOption + func SetStoreLimit(limit storelimit.StoreLimit) StoreCreateOption + func SetStoreStartTime(startTS int64) StoreCreateOption + func SetStoreStats(stats *pdpb.StoreStats) StoreCreateOption + func SetStoreVersion(githash, version string) StoreCreateOption + func SetWitnessCount(witnessCount int) StoreCreateOption + func SlowStoreEvicted() StoreCreateOption + func SlowStoreRecovered() StoreCreateOption + func SlowTrendEvicted() StoreCreateOption + func SlowTrendRecovered() StoreCreateOption + func TombstoneStore() StoreCreateOption + func UpStore() StoreCreateOption + type StoreInfo struct + func NewStoreInfo(store *metapb.Store, opts ...StoreCreateOption) *StoreInfo + func NewStoreInfoWithLabel(id uint64, labels map[string]string) *StoreInfo + func (s *StoreInfo) AllowLeaderTransfer() bool + func (s *StoreInfo) AvailableRatio() float64 + func (s *StoreInfo) Clone(opts ...StoreCreateOption) *StoreInfo + func (s *StoreInfo) CompareLocation(other *StoreInfo, labels []string) int + func (s *StoreInfo) DownTime() time.Duration + func (s *StoreInfo) EvictedAsSlowStore() bool + func (s *StoreInfo) Feedback(e float64) + func (s *StoreInfo) GetAddress() string + func (s *StoreInfo) GetID() uint64 + func (s *StoreInfo) GetLabelValue(key string) string + func (s *StoreInfo) GetLabels() []*metapb.StoreLabel + func (s *StoreInfo) GetLastHeartbeatTS() time.Time + func (s *StoreInfo) GetLeaderCount() int + func (s *StoreInfo) GetLeaderSize() int64 + func (s *StoreInfo) GetLeaderWeight() float64 + func (s *StoreInfo) GetLearnerCount() int + func (s *StoreInfo) GetMeta() *metapb.Store + func (s *StoreInfo) GetMinResolvedTS() uint64 + func (s *StoreInfo) GetNodeState() metapb.NodeState + func (s *StoreInfo) GetPendingPeerCount() int + func (s *StoreInfo) GetRegionCount() int + func (s *StoreInfo) GetRegionSize() int64 + func (s *StoreInfo) GetRegionWeight() float64 + func (s *StoreInfo) GetSlowScore() uint64 + func (s *StoreInfo) GetSlowTrend() *pdpb.SlowTrend + func (s *StoreInfo) GetStartTime() time.Time + func (s *StoreInfo) GetState() metapb.StoreState + func (s *StoreInfo) GetStatusAddress() string + func (s *StoreInfo) GetStoreLimit() storelimit.StoreLimit + func (s *StoreInfo) GetUptime() time.Duration + func (s *StoreInfo) GetVersion() string + func (s *StoreInfo) GetWitnessCount() int + func (s *StoreInfo) IsAvailable(limitType storelimit.Type, level constant.PriorityLevel) bool + func (s *StoreInfo) IsDisconnected() bool + func (s *StoreInfo) IsEvictedAsSlowTrend() bool + func (s *StoreInfo) IsLowSpace(lowSpaceRatio float64) bool + func (s *StoreInfo) IsPhysicallyDestroyed() bool + func (s *StoreInfo) IsPreparing() bool + func (s *StoreInfo) IsRemoved() bool + func (s *StoreInfo) IsRemoving() bool + func (s *StoreInfo) IsServing() bool + func (s *StoreInfo) IsSlow() bool + func (s *StoreInfo) IsTiFlash() bool + func (s *StoreInfo) IsUnhealthy() bool + func (s *StoreInfo) IsUp() bool + func (s *StoreInfo) LeaderScore(policy constant.SchedulePolicy, delta int64) float64 + func (s *StoreInfo) LimitVersion() string + func (s *StoreInfo) NeedAwakenStore() bool + func (s *StoreInfo) NeedPersist() bool + func (s *StoreInfo) RegionScore(version string, highSpaceRatio, lowSpaceRatio float64, delta int64) float64 + func (s *StoreInfo) ResourceCount(kind constant.ResourceKind) uint64 + func (s *StoreInfo) ResourceSize(kind constant.ResourceKind) int64 + func (s *StoreInfo) ResourceWeight(kind constant.ResourceKind) float64 + func (s *StoreInfo) ShallowClone(opts ...StoreCreateOption) *StoreInfo + func (s *StoreInfo) StorageSize() uint64 + func (s *StoreInfo) WitnessScore(delta int64) float64 + func (ss StoreInfo) CloneStoreStats() *pdpb.StoreStats + func (ss StoreInfo) GetAvailable() uint64 + func (ss StoreInfo) GetAvgAvailable() uint64 + func (ss StoreInfo) GetBytesRead() uint64 + func (ss StoreInfo) GetBytesWritten() uint64 + func (ss StoreInfo) GetCapacity() uint64 + func (ss StoreInfo) GetKeysRead() uint64 + func (ss StoreInfo) GetKeysWritten() uint64 + func (ss StoreInfo) GetReceivingSnapCount() uint32 + func (ss StoreInfo) GetSendingSnapCount() uint32 + func (ss StoreInfo) GetStoreStats() *pdpb.StoreStats + func (ss StoreInfo) GetUsedSize() uint64 + func (ss StoreInfo) IsBusy() bool + type StoreSetController interface + PauseLeaderTransfer func(id uint64) error + ResumeLeaderTransfer func(id uint64) + SlowStoreEvicted func(id uint64) error + SlowStoreRecovered func(id uint64) + SlowTrendEvicted func(id uint64) error + SlowTrendRecovered func(id uint64) + type StoreSetInformer interface + GetFollowerStores func(region *RegionInfo) []*StoreInfo + GetLeaderStore func(region *RegionInfo) *StoreInfo + GetNonWitnessVoterStores func(region *RegionInfo) []*StoreInfo + GetRegionStores func(region *RegionInfo) []*StoreInfo + GetStore func(id uint64) *StoreInfo + GetStores func() []*StoreInfo + type StoresInfo struct + func NewStoresInfo() *StoresInfo + func (s *StoresInfo) DeleteStore(store *StoreInfo) + func (s *StoresInfo) GetMetaStores() []*metapb.Store + func (s *StoresInfo) GetStore(storeID uint64) *StoreInfo + func (s *StoresInfo) GetStoreCount() int + func (s *StoresInfo) GetStores() []*StoreInfo + func (s *StoresInfo) PauseLeaderTransfer(storeID uint64) error + func (s *StoresInfo) ResetStoreLimit(storeID uint64, limitType storelimit.Type, ratePerSec ...float64) + func (s *StoresInfo) ResumeLeaderTransfer(storeID uint64) + func (s *StoresInfo) SetLeaderCount(storeID uint64, leaderCount int) + func (s *StoresInfo) SetLeaderSize(storeID uint64, leaderSize int64) + func (s *StoresInfo) SetPendingPeerCount(storeID uint64, pendingPeerCount int) + func (s *StoresInfo) SetRegionCount(storeID uint64, regionCount int) + func (s *StoresInfo) SetRegionSize(storeID uint64, regionSize int64) + func (s *StoresInfo) SetStore(store *StoreInfo) + func (s *StoresInfo) SlowStoreEvicted(storeID uint64) error + func (s *StoresInfo) SlowStoreRecovered(storeID uint64) + func (s *StoresInfo) SlowTrendEvicted(storeID uint64) error + func (s *StoresInfo) SlowTrendRecovered(storeID uint64) + func (s *StoresInfo) UpdateStoreStatus(storeID uint64, ...)