statistics

package

Go to main page

Versions in this module

v3

v3.1.2

Apr 26, 2020

v3.1.1

Apr 26, 2020

v3.1.0

Apr 10, 2020

Changes in this version

+ const DefaultAotSize

+ const DefaultReadMfSize

+ const DefaultWriteMfSize

+ var Denoising = true

+ func NewHotStoresStats(kind FlowKind) *hotPeerCache

+ type AvgOverTime struct

+ func NewAvgOverTime(interval time.Duration) *AvgOverTime

+ func (aot *AvgOverTime) Add(delta float64, interval time.Duration)

+ func (aot *AvgOverTime) Clear()

+ func (aot *AvgOverTime) Get() float64

+ func (aot *AvgOverTime) Set(avg float64)

type FlowKind

+ func (k FlowKind) String() string

+ type HotCache struct

+ func NewHotCache() *HotCache

+ func (w *HotCache) CheckRead(region *core.RegionInfo, stats *StoresStats) []*HotPeerStat

+ func (w *HotCache) CheckWrite(region *core.RegionInfo, stats *StoresStats) []*HotPeerStat

+ func (w *HotCache) CollectMetrics(stats *StoresStats)

+ func (w *HotCache) IsRegionHot(region *core.RegionInfo, hotDegree int) bool

+ func (w *HotCache) RandHotRegionFromStore(storeID uint64, kind FlowKind, hotDegree int) *HotPeerStat

+ func (w *HotCache) RegionStats(kind FlowKind) map[uint64][]*HotPeerStat

+ func (w *HotCache) ResetMetrics()

+ func (w *HotCache) Update(item *HotPeerStat)

+ type HotPeerStat struct

+ AntiCount int

+ ByteRate float64

+ HotDegree int

+ KeyRate float64

+ Kind FlowKind

+ LastUpdateTime time.Time

+ RegionID uint64

+ StoreID uint64

+ Version uint64

+ func (stat *HotPeerStat) Clone() *HotPeerStat

+ func (stat *HotPeerStat) GetByteRate() float64

+ func (stat *HotPeerStat) GetKeyRate() float64

+ func (stat *HotPeerStat) ID() uint64

+ func (stat *HotPeerStat) IsLeader() bool

+ func (stat *HotPeerStat) IsNeedDelete() bool

+ func (stat *HotPeerStat) IsNew() bool

+ func (stat *HotPeerStat) Less(k int, than TopNItem) bool

+ type HotPeersStat struct

+ Count int

+ Stats []HotPeerStat

+ TotalBytesRate float64

+ TotalKeysRate float64

+ type LabelStatistics struct

+ func NewLabelStatistics() *LabelStatistics

+ func (l *LabelStatistics) ClearDefunctRegion(regionID uint64, labels []string)

+ func (l *LabelStatistics) Collect()

+ func (l *LabelStatistics) Observe(region *core.RegionInfo, stores []*core.StoreInfo, labels []string)

+ func (l *LabelStatistics) Reset()

+ type MedianFilter struct

+ func NewMedianFilter(size int) *MedianFilter

+ func (r *MedianFilter) Add(n float64)

+ func (r *MedianFilter) Get() float64

+ func (r *MedianFilter) Reset()

+ func (r *MedianFilter) Set(n float64)

+ type MovingAvg interface

+ Add func(data float64)

+ Get func() float64

+ Reset func()

+ Set func(data float64)

+ type RegionStatInformer interface

+ IsRegionHot func(region *core.RegionInfo) bool

+ RandHotRegionFromStore func(store uint64, kind FlowKind) *core.RegionInfo

+ RegionReadStats func() map[uint64][]*HotPeerStat

+ RegionWriteStats func() map[uint64][]*HotPeerStat

type RollingStoreStats

+ func (r *RollingStoreStats) GetBytesReadRate() float64

+ func (r *RollingStoreStats) GetBytesWriteRate() float64

+ func (r *RollingStoreStats) GetCPUUsage() float64

+ func (r *RollingStoreStats) GetDiskReadRate() float64

+ func (r *RollingStoreStats) GetDiskWriteRate() float64

+ func (r *RollingStoreStats) Set(stats *pdpb.StoreStats)

type ScheduleOptions

+ GetKeyType func() core.KeyType

+ type StoreHotPeersInfos struct

+ AsLeader StoreHotPeersStat

+ AsPeer StoreHotPeersStat

+ type StoreHotPeersStat map[uint64]*HotPeersStat

+ type StoreStatInformer interface

+ GetStoresStats func() *StoresStats

type StoresStats

+ func (s *StoresStats) GetOrCreateRollingStoreStats(storeID uint64) *RollingStoreStats

+ func (s *StoresStats) GetStoreBytesRate(storeID uint64) (writeRate float64, readRate float64)

+ func (s *StoresStats) GetStoreBytesReadRate(storeID uint64) float64

+ func (s *StoresStats) GetStoreBytesWriteRate(storeID uint64) float64

+ func (s *StoresStats) GetStoreCPUUsage(storeID uint64) float64

+ func (s *StoresStats) GetStoreDiskReadRate(storeID uint64) float64

+ func (s *StoresStats) GetStoreDiskWriteRate(storeID uint64) float64

+ func (s *StoresStats) GetStoresCPUUsage() map[uint64]float64

+ func (s *StoresStats) GetStoresDiskReadRate() map[uint64]float64

+ func (s *StoresStats) GetStoresDiskWriteRate() map[uint64]float64

+ func (s *StoresStats) Set(storeID uint64, stats *pdpb.StoreStats)

+ type TimeMedian struct

+ func NewTimeMedian(aotSize, mfSize int) *TimeMedian

+ func (t *TimeMedian) Add(delta float64, interval time.Duration)

+ func (t *TimeMedian) Get() float64

+ func (t *TimeMedian) Set(avg float64)

+ type TopN struct

+ func NewTopN(k, n int, ttl time.Duration) *TopN

+ func (tn *TopN) Get(id uint64) TopNItem

+ func (tn *TopN) GetAll() []TopNItem

+ func (tn *TopN) GetAllTopN(k int) []TopNItem

+ func (tn *TopN) GetTopNMin(k int) TopNItem

+ func (tn *TopN) Len() int

+ func (tn *TopN) Put(item TopNItem) (isUpdate bool)

+ func (tn *TopN) Remove(id uint64) (item TopNItem)

+ func (tn *TopN) RemoveExpired()

+ type TopNItem interface

+ ID func() uint64

+ Less func(k int, than TopNItem) bool

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 ScheduleOptions

+ GetLeaderSchedulePolicy func() core.SchedulePolicy

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 RegionHeartBeatReportInterval

+ const StoreHeartBeatReportInterval

+ var Simulating bool

+ func NewStoreStatisticsMap(opt ScheduleOptions, classifier namespace.Classifier) *storeStatisticsMap

+ type FlowKind uint32

+ const ReadFlow

+ const WriteFlow

+ type HotRegionsStat struct

+ RegionsCount int

+ RegionsStat RegionsStat

+ TotalFlowBytes uint64

+ type HotSpotCache struct

+ func NewHotSpotCache() *HotSpotCache

+ func (w *HotSpotCache) CheckRead(region *core.RegionInfo, stats *StoresStats) (bool, *RegionStat)

+ func (w *HotSpotCache) CheckWrite(region *core.RegionInfo, stats *StoresStats) (bool, *RegionStat)

+ func (w *HotSpotCache) CollectMetrics(stats *StoresStats)

+ func (w *HotSpotCache) IsRegionHot(id uint64, hotThreshold int) bool

+ func (w *HotSpotCache) RandHotRegionFromStore(storeID uint64, kind FlowKind, hotThreshold int) *RegionStat

+ func (w *HotSpotCache) RegionStats(kind FlowKind) []*RegionStat

+ func (w *HotSpotCache) ResetMetrics()

+ func (w *HotSpotCache) Update(key uint64, item *RegionStat, kind FlowKind)

+ type LabelLevelStatistics struct

+ func NewLabelLevelStatistics() *LabelLevelStatistics

+ func (l *LabelLevelStatistics) ClearDefunctRegion(regionID uint64, labels []string)

+ func (l *LabelLevelStatistics) Collect()

+ func (l *LabelLevelStatistics) Observe(region *core.RegionInfo, stores []*core.StoreInfo, labels []string)

+ func (l *LabelLevelStatistics) Reset()

+ type RegionStat struct

+ AntiCount int

+ FlowBytes uint64

+ HotDegree int

+ LastUpdateTime time.Time

+ RegionID uint64

+ Stats *RollingStats

+ StoreID uint64

+ Version uint64

+ func NewRegionStat(region *core.RegionInfo, flowBytes uint64, antiCount int) *RegionStat

+ type RegionStatisticType uint32

+ const DownPeer

+ const EmptyRegion

+ const ExtraPeer

+ const IncorrectNamespace

+ const LearnerPeer

+ const MissPeer

+ const OfflinePeer

+ const PendingPeer

+ type RegionStatistics struct

+ func NewRegionStatistics(opt ScheduleOptions, classifier namespace.Classifier) *RegionStatistics

+ func (r *RegionStatistics) ClearDefunctRegion(regionID uint64)

+ func (r *RegionStatistics) Collect()

+ func (r *RegionStatistics) GetRegionStatsByType(typ RegionStatisticType) []*core.RegionInfo

+ func (r *RegionStatistics) Observe(region *core.RegionInfo, stores []*core.StoreInfo)

+ func (r *RegionStatistics) Reset()

+ type RegionStats struct

+ Count int

+ EmptyCount int

+ StorageKeys int64

+ StorageSize int64

+ StoreLeaderCount map[uint64]int

+ StoreLeaderKeys map[uint64]int64

+ StoreLeaderSize map[uint64]int64

+ StorePeerCount map[uint64]int

+ StorePeerKeys map[uint64]int64

+ StorePeerSize map[uint64]int64

+ func GetRegionStats(r *core.RegionsInfo, startKey, endKey []byte) *RegionStats

+ func (s *RegionStats) Observe(r *core.RegionInfo)

+ type RegionsStat []RegionStat

+ func (m RegionsStat) Len() int

+ func (m RegionsStat) Less(i, j int) bool

+ func (m RegionsStat) Swap(i, j int)

+ type RollingStats struct

+ func NewRollingStats(size int) *RollingStats

+ func (r *RollingStats) Add(n float64)

+ func (r *RollingStats) Median() float64

+ type RollingStoreStats struct

+ func (r *RollingStoreStats) GetBytesRate() (writeRate float64, readRate float64)

+ func (r *RollingStoreStats) GetKeysReadRate() float64

+ func (r *RollingStoreStats) GetKeysWriteRate() float64

+ func (r *RollingStoreStats) Observe(stats *pdpb.StoreStats)

+ type ScheduleOptions interface

+ GetHighSpaceRatio func() float64

+ GetHotRegionCacheHitsThreshold func() int

+ GetHotRegionScheduleLimit func(name string) uint64

+ GetLeaderScheduleLimit func(name string) uint64

+ GetLocationLabels func() []string

+ GetLowSpaceRatio func() float64

+ GetMaxMergeRegionKeys func() uint64

+ GetMaxMergeRegionSize func() uint64

+ GetMaxPendingPeerCount func() uint64

+ GetMaxReplicas func(name string) int

+ GetMaxSnapshotCount func() uint64

+ GetMaxStoreDownTime func() time.Duration

+ GetMergeScheduleLimit func(name string) uint64

+ GetRegionScheduleLimit func(name string) uint64

+ GetReplicaScheduleLimit func(name string) uint64

+ GetSchedulerMaxWaitingOperator func() uint64

+ GetStoreBalanceRate func() float64

+ GetTolerantSizeRatio func() float64

+ IsMakeUpReplicaEnabled func() bool

+ IsRaftLearnerEnabled func() bool

+ IsRemoveDownReplicaEnabled func() bool

+ IsRemoveExtraReplicaEnabled func() bool

+ IsReplaceOfflineReplicaEnabled func() bool

+ type StoreHotRegionInfos struct

+ AsLeader StoreHotRegionsStat

+ AsPeer StoreHotRegionsStat

+ type StoreHotRegionsStat map[uint64]*HotRegionsStat

+ type StoresStats struct

+ func NewStoresStats() *StoresStats

+ func (s *StoresStats) CreateRollingStoreStats(storeID uint64)

+ func (s *StoresStats) GetRollingStoreStats(storeID uint64) *RollingStoreStats

+ func (s *StoresStats) GetStoresBytesReadStat() map[uint64]uint64

+ func (s *StoresStats) GetStoresBytesWriteStat() map[uint64]uint64

+ func (s *StoresStats) GetStoresKeysReadStat() map[uint64]uint64

+ func (s *StoresStats) GetStoresKeysWriteStat() map[uint64]uint64

+ func (s *StoresStats) Observe(storeID uint64, stats *pdpb.StoreStats)

+ func (s *StoresStats) RemoveRollingStoreStats(storeID uint64)

+ func (s *StoresStats) TotalBytesReadRate() float64

+ func (s *StoresStats) TotalBytesWriteRate() float64

+ func (s *StoresStats) UpdateTotalBytesRate(stores *core.StoresInfo)

Other modules containing this package

github.com/pingcap/pd/v4

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