core

package

Go to main page

Versions in this module

v3

v3.1.2

Apr 26, 2020

v3.1.1

Apr 26, 2020

Changes in this version

type StoreCreateOption

+ func AttachAvailableFunc(limitType storelimit.Type, f func() bool) StoreCreateOption

v3.1.0

Apr 10, 2020

Changes in this version

+ func DistinctScore(labels []string, stores []*StoreInfo, other *StoreInfo) float64

type BasicCluster

+ func (bc *BasicCluster) AttachAvailableFunc(storeID uint64, f func() bool)

+ func (bc *BasicCluster) CheckAndPutRegion(region *RegionInfo) []*RegionInfo

+ func (bc *BasicCluster) GetMetaRegions() []*metapb.Region

+ func (bc *BasicCluster) GetMetaStores() []*metapb.Store

+ func (bc *BasicCluster) GetOverlaps(region *RegionInfo) []*RegionInfo

+ func (bc *BasicCluster) GetRegionCount() int

+ func (bc *BasicCluster) GetRegions() []*RegionInfo

+ func (bc *BasicCluster) GetStoreCount() int

+ func (bc *BasicCluster) GetStoreFollowerCount(storeID uint64) int

+ func (bc *BasicCluster) GetStoreLeaderCount(storeID uint64) int

+ func (bc *BasicCluster) GetStoreLeaderRegionSize(storeID uint64) int64

+ func (bc *BasicCluster) GetStorePendingPeerCount(storeID uint64) int

+ func (bc *BasicCluster) GetStoreRegionCount(storeID uint64) int

+ func (bc *BasicCluster) GetStoreRegionSize(storeID uint64) int64

+ func (bc *BasicCluster) GetStoreRegions(storeID uint64) []*RegionInfo

+ func (bc *BasicCluster) Length() int

+ func (bc *BasicCluster) RandLearnerRegion(storeID uint64, ranges []KeyRange, opts ...RegionOption) *RegionInfo

+ func (bc *BasicCluster) RemoveRegion(region *RegionInfo)

+ func (bc *BasicCluster) ScanRange(startKey, endKey []byte, limit int) []*RegionInfo

+ func (bc *BasicCluster) SearchPrevRegion(regionKey []byte) *RegionInfo

+ func (bc *BasicCluster) SearchRegion(regionKey []byte) *RegionInfo

+ func (bc *BasicCluster) TakeStore(storeID uint64) *StoreInfo

+ func (bc *BasicCluster) UpdateStoreStatus(storeID uint64, leaderCount int, regionCount int, pendingPeerCount int, ...)

+ type KeyRange struct

+ EndKey []byte

+ StartKey []byte

+ func NewKeyRange(startKey, endKey string) KeyRange

+ type KeyType int

+ const Raw

+ const Table

+ const Txn

+ func StringToKeyType(input string) KeyType

+ func (k KeyType) String() string

type RegionCreateOption

+ func SetReportInterval(v uint64) RegionCreateOption

+ func WithReplacePeerStore(oldStoreID, newStoreID uint64) RegionCreateOption

type RegionInfo

+ func NewTestRegionInfo(start, end []byte) *RegionInfo

+ func (r *RegionInfo) GetInterval() *pdpb.TimeInterval

+ type RegionSetInformer interface

+ GetAdjacentRegions func(region *RegionInfo) (*RegionInfo, *RegionInfo)

+ GetAverageRegionSize func() int64

+ GetRegion func(id uint64) *RegionInfo

+ GetStoreRegionCount func(storeID uint64) int

+ RandFollowerRegion func(storeID uint64, ranges []KeyRange, opts ...RegionOption) *RegionInfo

+ RandLeaderRegion func(storeID uint64, ranges []KeyRange, opts ...RegionOption) *RegionInfo

+ RandLearnerRegion func(storeID uint64, ranges []KeyRange, opts ...RegionOption) *RegionInfo

+ RandPendingRegion func(storeID uint64, ranges []KeyRange, opts ...RegionOption) *RegionInfo

+ ScanRegions func(startKey, endKey []byte, limit int) []*RegionInfo

+ type RegionStorage struct

+ func NewRegionStorage(ctx context.Context, path string) (*RegionStorage, error)

+ func (s *RegionStorage) Close() error

+ func (s *RegionStorage) FlushRegion() error

+ func (s *RegionStorage) SaveRegion(region *metapb.Region) error

type RegionsInfo

+ func (r *RegionsInfo) RandFollowerRegions(storeID uint64, ranges []KeyRange, n int) []*RegionInfo

+ func (r *RegionsInfo) RandLeaderRegions(storeID uint64, ranges []KeyRange, n int) []*RegionInfo

+ func (r *RegionsInfo) RandLearnerRegion(storeID uint64, ranges []KeyRange) *RegionInfo

+ func (r *RegionsInfo) RandLearnerRegions(storeID uint64, ranges []KeyRange, n int) []*RegionInfo

+ func (r *RegionsInfo) RandPendingRegions(storeID uint64, ranges []KeyRange, n int) []*RegionInfo

+ type Storage struct

+ func NewStorage(base kv.Base) *Storage

+ func (s *Storage) Close() error

+ func (s *Storage) ClusterStatePath(option string) string

+ func (s *Storage) DeleteRegion(region *metapb.Region) error

+ func (s *Storage) DeleteRule(ruleKey string) error

+ func (s *Storage) DeleteStore(store *metapb.Store) error

+ func (s *Storage) Flush() error

+ func (s *Storage) GetRegionStorage() *RegionStorage

+ func (s *Storage) LoadAllScheduleConfig() ([]string, []string, error)

+ func (s *Storage) LoadComponentsConfig(cfg interface{}) (bool, error)

+ func (s *Storage) LoadConfig(cfg interface{}) (bool, error)

+ func (s *Storage) LoadGCSafePoint() (uint64, error)

+ func (s *Storage) LoadMeta(meta *metapb.Cluster) (bool, error)

+ func (s *Storage) LoadRegion(regionID uint64, region *metapb.Region) (bool, error)

+ func (s *Storage) LoadRegions(f func(region *RegionInfo) []*RegionInfo) error

+ func (s *Storage) LoadRegionsOnce(f func(region *RegionInfo) []*RegionInfo) error

+ func (s *Storage) LoadRules(f func(k, v string)) (bool, error)

+ func (s *Storage) LoadScheduleConfig(scheduleName string) (string, error)

+ func (s *Storage) LoadStore(storeID uint64, store *metapb.Store) (bool, error)

+ func (s *Storage) LoadStores(f func(store *StoreInfo)) error

+ func (s *Storage) RemoveScheduleConfig(scheduleName string) error

+ func (s *Storage) SaveComponentsConfig(cfg interface{}) error

+ func (s *Storage) SaveConfig(cfg interface{}) error

+ func (s *Storage) SaveGCSafePoint(safePoint uint64) error

+ func (s *Storage) SaveMeta(meta *metapb.Cluster) error

+ func (s *Storage) SaveRegion(region *metapb.Region) error

+ func (s *Storage) SaveRule(ruleKey string, rules interface{}) error

+ func (s *Storage) SaveScheduleConfig(scheduleName string, data []byte) error

+ func (s *Storage) SaveStore(store *metapb.Store) error

+ func (s *Storage) SaveStoreWeight(storeID uint64, leader, region float64) error

+ func (s *Storage) SetRegionStorage(regionStorage *RegionStorage) *Storage

+ func (s *Storage) SwitchToDefaultStorage()

+ func (s *Storage) SwitchToRegionStorage()

type StoreCreateOption

+ func SetAvailableFunc(f func() bool) StoreCreateOption

+ func SetStoreStartTime(startTs int64) StoreCreateOption

type StoreInfo

+ func NewStoreInfoWithLabel(id uint64, regionCount int, labels map[string]string) *StoreInfo

+ func (s *StoreInfo) IsAvailable() bool

+ func (s *StoreInfo) IsBusy() bool

+ type StoreSetController interface

+ AttachAvailableFunc func(id uint64, f func() bool)

+ BlockStore func(id uint64) error

+ UnblockStore func(id uint64)

+ type StoreSetInformer interface

+ GetFollowerStores func(region *RegionInfo) []*StoreInfo

+ GetLeaderStore func(region *RegionInfo) *StoreInfo

+ GetRegionStores func(region *RegionInfo) []*StoreInfo

+ GetStore func(id uint64) *StoreInfo

+ GetStores func() []*StoreInfo

type StoresInfo

+ func (s *StoresInfo) AttachAvailableFunc(storeID uint64, f func() bool)

+ func (s *StoresInfo) UpdateStoreStatus(storeID uint64, leaderCount int, regionCount int, pendingPeerCount int, ...)

v3.1.0-rc

Apr 1, 2020

v3.1.0-beta.2

Feb 27, 2020

v3.0.18

Aug 14, 2020

v3.0.17

Jul 27, 2020

v3.0.16

Jun 28, 2020

v3.0.15

May 29, 2020

Changes in this version

+ type ScheduleKind struct

+ Policy SchedulePolicy

+ Resource ResourceKind

+ func NewScheduleKind(Resource ResourceKind, Policy SchedulePolicy) ScheduleKind

+ type SchedulePolicy int

+ const ByCount

+ const BySize

+ func StringToSchedulePolicy(input string) SchedulePolicy

+ func (k SchedulePolicy) String() string

type StoreInfo

+ func NewStoreInfoWithSizeCount(id uint64, regionCount, leaderCount int, regionSize, leaderSize int64) *StoreInfo

v3.0.14

Mar 12, 2020

v3.0.13

Mar 12, 2020

v3.0.12

Mar 12, 2020

v3.0.11

Feb 20, 2020

Changes in this version

+ const EmptyRegionApproximateSize

+ const LeaderKind

+ const RegionKind

+ var ErrRegionIsStale = func(region *metapb.Region, origin *metapb.Region) error

+ var StoreBlockedCode = storeStateCode.Child("state.store.blocked")

+ var StoreTombstonedCode = storeStateCode.Child("state.store.tombstoned").SetHTTP(http.StatusGone)

+ func DiffRegionKeyInfo(origin *RegionInfo, other *RegionInfo) string

+ func DiffRegionPeersInfo(origin *RegionInfo, other *RegionInfo) string

+ func EncodeToString(src []byte) []byte

+ func HexRegionKey(key []byte) []byte

+ func HexRegionKeyStr(key []byte) string

+ func MergeRegions(regions []*metapb.Region) []*metapb.Region

+ func NewRegion(start, end []byte) *metapb.Region

+ func NewStoreNotFoundErr(storeID uint64) errcode.ErrorCode

+ func SplitRegions(regions []*metapb.Region) []*metapb.Region

+ func String(b []byte) (s string)

+ func ToUpperASCIIInplace(s []byte) []byte

+ type BasicCluster struct

+ Regions *RegionsInfo

+ Stores *StoresInfo

+ func NewBasicCluster() *BasicCluster

+ func (bc *BasicCluster) AttachOverloadStatus(storeID uint64, f func() bool)

+ func (bc *BasicCluster) BlockStore(storeID uint64) error

+ func (bc *BasicCluster) DeleteStore(store *StoreInfo)

+ func (bc *BasicCluster) GetAdjacentRegions(region *RegionInfo) (*RegionInfo, *RegionInfo)

+ func (bc *BasicCluster) GetAverageRegionSize() int64

+ func (bc *BasicCluster) GetFollowerStores(region *RegionInfo) []*StoreInfo

+ func (bc *BasicCluster) GetLeaderStore(region *RegionInfo) *StoreInfo

+ func (bc *BasicCluster) GetRegion(regionID uint64) *RegionInfo

+ func (bc *BasicCluster) GetRegionStores(region *RegionInfo) []*StoreInfo

+ func (bc *BasicCluster) GetStore(storeID uint64) *StoreInfo

+ func (bc *BasicCluster) GetStores() []*StoreInfo

+ func (bc *BasicCluster) PreCheckPutRegion(region *RegionInfo) (*RegionInfo, error)

+ func (bc *BasicCluster) PutRegion(region *RegionInfo)

+ func (bc *BasicCluster) PutStore(store *StoreInfo)

+ func (bc *BasicCluster) RandFollowerRegion(storeID uint64, opts ...RegionOption) *RegionInfo

+ func (bc *BasicCluster) RandLeaderRegion(storeID uint64, opts ...RegionOption) *RegionInfo

+ func (bc *BasicCluster) RandPendingRegion(storeID uint64, opts ...RegionOption) *RegionInfo

+ func (bc *BasicCluster) UnblockStore(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 IDAllocator interface

+ Alloc func() (uint64, error)

+ type KV struct

+ func NewKV(base KVBase) *KV

+ func (kv *KV) Close() error

+ func (kv *KV) ClusterStatePath(option string) string

+ func (kv *KV) DeleteRegion(region *metapb.Region) error

+ func (kv *KV) DeleteStore(store *metapb.Store) error

+ func (kv *KV) Flush() error

+ func (kv *KV) GetRegionKV() *RegionKV

+ func (kv *KV) LoadConfig(cfg interface{}) (bool, error)

+ func (kv *KV) LoadGCSafePoint() (uint64, error)

+ func (kv *KV) LoadMeta(meta *metapb.Cluster) (bool, error)

+ func (kv *KV) LoadRegion(regionID uint64, region *metapb.Region) (bool, error)

+ func (kv *KV) LoadRegions(f func(region *RegionInfo) []*metapb.Region) error

+ func (kv *KV) LoadStore(storeID uint64, store *metapb.Store) (bool, error)

+ func (kv *KV) LoadStores(stores *StoresInfo) error

+ func (kv *KV) SaveConfig(cfg interface{}) error

+ func (kv *KV) SaveGCSafePoint(safePoint uint64) error

+ func (kv *KV) SaveMeta(meta *metapb.Cluster) error

+ func (kv *KV) SaveRegion(region *metapb.Region) error

+ func (kv *KV) SaveStore(store *metapb.Store) error

+ func (kv *KV) SaveStoreWeight(storeID uint64, leader, region float64) error

+ func (kv *KV) SetRegionKV(regionKV *RegionKV) *KV

+ func (kv *KV) SwitchToDefaultStorage()

+ func (kv *KV) SwitchToRegionStorage()

+ type KVBase interface

+ Delete func(key string) error

+ Load func(key string) (string, error)

+ LoadRange func(key, endKey string, limit int) (keys []string, values []string, err error)

+ Save func(key, value string) error

+ func NewMemoryKV() KVBase

+ type PriorityLevel int

+ const HighPriority

+ const LowPriority

+ const NormalPriority

+ type RegionCreateOption func(region *RegionInfo)

+ func SetApproximateKeys(v int64) RegionCreateOption

+ func SetApproximateSize(v int64) RegionCreateOption

+ func SetPeers(peers []*metapb.Peer) RegionCreateOption

+ func SetReadBytes(v uint64) RegionCreateOption

+ func SetReadKeys(v uint64) RegionCreateOption

+ func SetRegionConfVer(confVer uint64) RegionCreateOption

+ func SetRegionVersion(version uint64) RegionCreateOption

+ func SetWrittenBytes(v uint64) RegionCreateOption

+ func SetWrittenKeys(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 WithIncConfVer() RegionCreateOption

+ func WithIncVersion() 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(pengdingPeers []*metapb.Peer) RegionCreateOption

+ func WithPromoteLearner(peerID uint64) RegionCreateOption

+ func WithRemoveStorePeer(storeID uint64) RegionCreateOption

+ func WithStartKey(key []byte) RegionCreateOption

+ type RegionInfo struct

+ func NewRegionInfo(region *metapb.Region, leader *metapb.Peer, opts ...RegionCreateOption) *RegionInfo

+ func RegionFromHeartbeat(heartbeat *pdpb.RegionHeartbeatRequest) *RegionInfo

+ func (r *RegionInfo) Clone(opts ...RegionCreateOption) *RegionInfo

+ func (r *RegionInfo) GetApproximateKeys() int64

+ func (r *RegionInfo) GetApproximateSize() int64

+ func (r *RegionInfo) GetBytesRead() uint64

+ func (r *RegionInfo) GetBytesWritten() 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) GetKeysRead() uint64

+ func (r *RegionInfo) GetKeysWritten() uint64

+ func (r *RegionInfo) GetLeader() *metapb.Peer

+ func (r *RegionInfo) GetLearners() []*metapb.Peer

+ func (r *RegionInfo) GetMeta() *metapb.Region

+ 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) GetRegionEpoch() *metapb.RegionEpoch

+ func (r *RegionInfo) GetStartKey() []byte

+ 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) GetStoreVoter(storeID uint64) *metapb.Peer

+ func (r *RegionInfo) GetVoters() []*metapb.Peer

+ type RegionKV struct

+ func NewRegionKV(path string) (*RegionKV, error)

+ func (kv *RegionKV) Close() error

+ func (kv *RegionKV) FlushRegion() error

+ func (kv *RegionKV) SaveRegion(region *metapb.Region) error

+ func (kv RegionKV) Delete(key string) error

+ func (kv RegionKV) Load(key string) (string, error)

+ func (kv RegionKV) LoadRange(startKey, endKey string, limit int) ([]string, []string, error)

+ func (kv RegionKV) Save(key, value string) error

+ func (kv RegionKV) SaveRegions(regions map[string]*metapb.Region) error

+ type RegionOption func(region *RegionInfo) bool

+ func HealthRegion() RegionOption

+ func HealthRegionAllowPending() RegionOption

+ type RegionsInfo struct

+ func NewRegionsInfo() *RegionsInfo

+ func (r *RegionsInfo) AddRegion(region *RegionInfo) []*metapb.Region

+ func (r *RegionsInfo) GetAdjacentRegions(region *RegionInfo) (*RegionInfo, *RegionInfo)

+ func (r *RegionsInfo) GetAverageRegionSize() int64

+ func (r *RegionsInfo) GetFollower(storeID uint64, regionID uint64) *RegionInfo

+ func (r *RegionsInfo) GetLeader(storeID uint64, regionID uint64) *RegionInfo

+ func (r *RegionsInfo) GetMetaRegions() []*metapb.Region

+ func (r *RegionsInfo) GetOverlaps(region *RegionInfo) []*metapb.Region

+ func (r *RegionsInfo) GetRegion(regionID uint64) *RegionInfo

+ func (r *RegionsInfo) GetRegionCount() int

+ func (r *RegionsInfo) GetRegions() []*RegionInfo

+ 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) 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) Length() int

+ func (r *RegionsInfo) RandFollowerRegion(storeID uint64, opts ...RegionOption) *RegionInfo

+ func (r *RegionsInfo) RandLeaderRegion(storeID uint64, opts ...RegionOption) *RegionInfo

+ func (r *RegionsInfo) RandPendingRegion(storeID uint64, opts ...RegionOption) *RegionInfo

+ func (r *RegionsInfo) RandRegion(opts ...RegionOption) *RegionInfo

+ func (r *RegionsInfo) RemoveRegion(region *RegionInfo)

+ func (r *RegionsInfo) ScanRange(startKey []byte, limit int) []*RegionInfo

+ func (r *RegionsInfo) ScanRangeWithEndKey(startKey, endKey []byte) []*RegionInfo

+ func (r *RegionsInfo) ScanRangeWithIterator(startKey []byte, iterator func(metaRegion *metapb.Region) bool)

+ func (r *RegionsInfo) SearchPrevRegion(regionKey []byte) *RegionInfo

+ func (r *RegionsInfo) SearchRegion(regionKey []byte) *RegionInfo

+ func (r *RegionsInfo) SetRegion(region *RegionInfo) []*metapb.Region

+ func (r *RegionsInfo) TreeLength() int

+ type ResourceKind int

+ func (k ResourceKind) String() string

+ type StoreBlockedErr StoreErr

+ func (e StoreBlockedErr) Code() errcode.Code

+ func (e StoreBlockedErr) Error() string

+ type StoreCreateOption func(region *StoreInfo)

+ func SetLastHeartbeatTS(lastHeartbeatTS time.Time) StoreCreateOption

+ func SetLeaderCount(leaderCount int) StoreCreateOption

+ func SetLeaderSize(leaderSize int64) StoreCreateOption

+ func SetLeaderWeight(leaderWeight float64) StoreCreateOption

+ func SetOverloadStatus(f func() bool) StoreCreateOption

+ func SetPendingPeerCount(pendingPeerCount int) StoreCreateOption

+ func SetRegionCount(regionCount int) StoreCreateOption

+ func SetRegionSize(regionSize int64) StoreCreateOption

+ func SetRegionWeight(regionWeight float64) StoreCreateOption

+ func SetStoreAddress(address string) StoreCreateOption

+ func SetStoreBlock() StoreCreateOption

+ func SetStoreLabels(labels []*metapb.StoreLabel) StoreCreateOption

+ func SetStoreState(state metapb.StoreState) StoreCreateOption

+ func SetStoreStats(stats *pdpb.StoreStats) StoreCreateOption

+ func SetStoreUnBlock() StoreCreateOption

+ func SetStoreVersion(version string) StoreCreateOption

+ type StoreErr struct

+ StoreID uint64

+ type StoreInfo struct

+ func NewStoreInfo(store *metapb.Store, opts ...StoreCreateOption) *StoreInfo

+ 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) GetAddress() string

+ func (s *StoreInfo) GetApplyingSnapCount() uint32

+ func (s *StoreInfo) GetAvailable() uint64

+ func (s *StoreInfo) GetBytesRead() uint64

+ func (s *StoreInfo) GetBytesWritten() uint64

+ func (s *StoreInfo) GetCapacity() uint64

+ func (s *StoreInfo) GetID() uint64

+ func (s *StoreInfo) GetIsBusy() bool

+ func (s *StoreInfo) GetKeysRead() uint64

+ func (s *StoreInfo) GetKeysWritten() 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) GetMeta() *metapb.Store

+ func (s *StoreInfo) GetPendingPeerCount() int

+ func (s *StoreInfo) GetReceivingSnapCount() uint32

+ func (s *StoreInfo) GetRegionCount() int

+ func (s *StoreInfo) GetRegionSize() int64

+ func (s *StoreInfo) GetRegionWeight() float64

+ func (s *StoreInfo) GetSendingSnapCount() uint32

+ func (s *StoreInfo) GetStartTS() time.Time

+ func (s *StoreInfo) GetStartTime() uint32

+ func (s *StoreInfo) GetState() metapb.StoreState

+ func (s *StoreInfo) GetStoreStats() *pdpb.StoreStats

+ func (s *StoreInfo) GetUptime() time.Duration

+ func (s *StoreInfo) GetUsedSize() uint64

+ func (s *StoreInfo) GetVersion() string

+ func (s *StoreInfo) IsBlocked() bool

+ func (s *StoreInfo) IsDisconnected() bool

+ func (s *StoreInfo) IsLowSpace(lowSpaceRatio float64) bool

+ func (s *StoreInfo) IsOffline() bool

+ func (s *StoreInfo) IsOverloaded() bool

+ func (s *StoreInfo) IsTombstone() bool

+ func (s *StoreInfo) IsUnhealth() bool

+ func (s *StoreInfo) IsUp() bool

+ func (s *StoreInfo) LeaderScore(delta int64) float64

+ func (s *StoreInfo) MergeLabels(labels []*metapb.StoreLabel) []*metapb.StoreLabel

+ func (s *StoreInfo) RegionScore(highSpaceRatio, lowSpaceRatio float64, delta int64) float64

+ func (s *StoreInfo) ResourceCount(kind ResourceKind) uint64

+ func (s *StoreInfo) ResourceScore(kind ResourceKind, highSpaceRatio, lowSpaceRatio float64, delta int64) float64

+ func (s *StoreInfo) ResourceSize(kind ResourceKind) int64

+ func (s *StoreInfo) ResourceWeight(kind ResourceKind) float64

+ func (s *StoreInfo) StorageSize() uint64

+ type StoreTombstonedErr StoreErr

+ func (e StoreTombstonedErr) Code() errcode.Code

+ func (e StoreTombstonedErr) Error() string

+ type StoresInfo struct

+ func NewStoresInfo() *StoresInfo

+ func (s *StoresInfo) AttachOverloadStatus(storeID uint64, f func() bool)

+ func (s *StoresInfo) BlockStore(storeID uint64) errcode.ErrorCode

+ 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) 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) TakeStore(storeID uint64) *StoreInfo

+ func (s *StoresInfo) UnblockStore(storeID uint64)

+ func (s *StoresInfo) UpdateStoreStatusLocked(storeID uint64, leaderCount int, regionCount int, pendingPeerCount int, ...)

Other modules containing this package

github.com/pingcap/pd

github.com/pingcap/pd/v4

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL