Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 v0.2.0 Jan 5, 2022 Changes in this version type Cluster + func (mc *Cluster) GetLogger() *zap.Logger v0.1.0 Oct 13, 2021 Changes in this version + type Cluster struct + ID uint64 + func NewCluster(opts *config.PersistOptions) *Cluster + func (mc *Cluster) AddLabelsContainer(containerID uint64, resourceCount int, labels map[string]string) + func (mc *Cluster) AddLeaderContainer(containerID uint64, leaderCount int, leaderSizes ...int64) + func (mc *Cluster) AddLeaderResource(resID uint64, leaderContainerID uint64, followerContainerIDs ...uint64) *core.CachedResource + func (mc *Cluster) AddLeaderResourceWithRange(resID uint64, startKey string, endKey string, leaderID uint64, ...) + func (mc *Cluster) AddLeaderResourceWithReadInfo(resID uint64, leaderID uint64, readBytes, readKeys uint64, ...) []*statistics.HotPeerStat + func (mc *Cluster) AddLeaderResourceWithWriteInfo(resID uint64, leaderID uint64, writtenBytes, writtenKeys uint64, ...) []*statistics.HotPeerStat + func (mc *Cluster) AddResourceContainer(containerID uint64, resourceCount int) + func (mc *Cluster) AddResourceContainerWithLeader(containerID uint64, resourceCount int, leaderCounts ...int) + func (mc *Cluster) AddResourceWithLearner(resID uint64, leaderContainerID uint64, ...) *core.CachedResource + func (mc *Cluster) AddSuspectResources(ids ...uint64) + func (mc *Cluster) AllocID() (uint64, error) + func (mc *Cluster) AllocPeer(containerID uint64) (metapb.Peer, error) + func (mc *Cluster) CheckLabelProperty(typ string, labels []metapb.Pair) bool + func (mc *Cluster) CheckResourceUnderSuspect(id uint64) bool + func (mc *Cluster) DisableJointConsensus() + func (mc *Cluster) FitResource(res *core.CachedResource) *placement.ResourceFit + func (mc *Cluster) GetContainer(containerID uint64) *core.CachedContainer + func (mc *Cluster) GetContainerResourceCount(containerID uint64) int + func (mc *Cluster) GetContainersLoads() map[uint64][]float64 + func (mc *Cluster) GetOpts() *config.PersistOptions + func (mc *Cluster) GetResourceByKey(group uint64, resKey []byte) *core.CachedResource + func (mc *Cluster) GetResourceFactory() func() metadata.Resource + func (mc *Cluster) GetRuleManager() *placement.RuleManager + func (mc *Cluster) IsResourceHot(res *core.CachedResource) bool + func (mc *Cluster) JointConsensusEnabled() bool + func (mc *Cluster) LoadResource(resID uint64, followerIds ...uint64) + func (mc *Cluster) MockCachedResource(resID uint64, leaderContainerID uint64, ...) *core.CachedResource + func (mc *Cluster) PutContainerWithLabels(id uint64, labelPairs ...string) + func (mc *Cluster) PutResourceContainers(id uint64, containerIDs ...uint64) + func (mc *Cluster) RandHotResourceFromContainer(containerID uint64, kind statistics.FlowKind) *core.CachedResource + func (mc *Cluster) RemoveScheduler(name string) error + func (mc *Cluster) ResetSuspectResources() + func (mc *Cluster) ResourceReadStats() map[uint64][]*statistics.HotPeerStat + func (mc *Cluster) ResourceWriteStats() map[uint64][]*statistics.HotPeerStat + func (mc *Cluster) ScanResources(group uint64, startKey, endKey []byte, limit int) []*core.CachedResource + func (mc *Cluster) SetContainerBusy(containerID uint64, busy bool) + func (mc *Cluster) SetContainerDisconnect(containerID uint64) + func (mc *Cluster) SetContainerDown(containerID uint64) + func (mc *Cluster) SetContainerLabel(containerID uint64, labels map[string]string) + func (mc *Cluster) SetContainerLastHeartbeatInterval(containerID uint64, interval time.Duration) + func (mc *Cluster) SetContainerOffline(containerID uint64) + func (mc *Cluster) SetContainerUP(containerID uint64) + func (mc *Cluster) SetEnableLocationReplacement(v bool) + func (mc *Cluster) SetEnableMakeUpReplica(v bool) + func (mc *Cluster) SetEnableOneWayMerge(v bool) + func (mc *Cluster) SetEnablePlacementRules(v bool) + func (mc *Cluster) SetEnableRemoveDownReplica(v bool) + func (mc *Cluster) SetEnableRemoveExtraReplica(v bool) + func (mc *Cluster) SetEnableReplaceOfflineReplica(v bool) + func (mc *Cluster) SetHotResourceCacheHitsThreshold(v int) + func (mc *Cluster) SetHotResourceScheduleLimit(v int) + func (mc *Cluster) SetLeaderScheduleLimit(v int) + func (mc *Cluster) SetLeaderSchedulePolicy(v string) + func (mc *Cluster) SetLocationLabels(v []string) + func (mc *Cluster) SetMaxMergeResourceKeys(v int) + func (mc *Cluster) SetMaxMergeResourceSize(v int) + func (mc *Cluster) SetMaxReplicas(v int) + func (mc *Cluster) SetMaxSnapshotCount(v int) + func (mc *Cluster) SetMergeScheduleLimit(v int) + func (mc *Cluster) SetResourceScheduleLimit(v int) + func (mc *Cluster) SetResourceScoreFormulaVersion(v string) + func (mc *Cluster) SetSplitMergeInterval(v time.Duration) + func (mc *Cluster) SetTolerantSizeRatio(v float64) + func (mc *Cluster) UpdateContainerLeaderSize(containerID uint64, size int64) + func (mc *Cluster) UpdateContainerLeaderWeight(containerID uint64, weight float64) + func (mc *Cluster) UpdateContainerResourceSize(containerID uint64, size int64) + func (mc *Cluster) UpdateContainerResourceWeight(containerID uint64, weight float64) + func (mc *Cluster) UpdateContainerStatus(id uint64) + func (mc *Cluster) UpdateLeaderCount(containerID uint64, leaderCount int) + func (mc *Cluster) UpdatePendingPeerCount(containerID uint64, pendingPeerCount int) + func (mc *Cluster) UpdateResourceCount(containerID uint64, resourceCount int) + func (mc *Cluster) UpdateSnapshotCount(containerID uint64, snapshotCount int) + func (mc *Cluster) UpdateStorageRatio(containerID uint64, usedRatio, availableRatio float64) + func (mc *Cluster) UpdateStorageReadBytes(containerID uint64, bytesRead uint64) + func (mc *Cluster) UpdateStorageReadKeys(containerID uint64, keysRead uint64) + func (mc *Cluster) UpdateStorageReadStats(containerID, bytesWritten, keysWritten uint64) + func (mc *Cluster) UpdateStorageWrittenBytes(containerID uint64, bytesWritten uint64) + func (mc *Cluster) UpdateStorageWrittenKeys(containerID uint64, keysWritten uint64) + func (mc *Cluster) UpdateStorageWrittenStats(containerID, bytesWritten, keysWritten uint64)
Go to main page