Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 v0.2.0 Jan 5, 2022 v0.1.0 Oct 13, 2021 Changes in this version + const BalanceLeaderName + const BalanceLeaderType + const BalanceResourceName + const BalanceResourceType + const EvictLeaderBatchSize + const EvictLeaderName + const EvictLeaderType + const GrantLeaderName + const GrantLeaderType + const HotReadResourceType + const HotResourceName + const HotResourceType + const HotWriteResourceType + const KB + const LabelName + const LabelType + const MB + const MaxScheduleInterval + const MinScheduleInterval + const MinSlowScheduleInterval + const RandomMergeName + const RandomMergeType + const ScatterRangeName + const ScatterRangeType + const ScheduleIntervalFactor + const ShuffleHotResourceName + const ShuffleHotResourceType + const ShuffleLeaderName + const ShuffleLeaderType + const ShuffleResourceName + const ShuffleResourceType + type BalanceLeaderCreateOption func(s *balanceLeaderScheduler) + func WithBalanceLeaderCounter(counter *prometheus.CounterVec) BalanceLeaderCreateOption + func WithBalanceLeaderName(name string) BalanceLeaderCreateOption + type BalanceResourceCreateOption func(s *balanceResourceScheduler) + func WithBalanceResourceCounter(counter *prometheus.CounterVec) BalanceResourceCreateOption + func WithBalanceResourceName(name string) BalanceResourceCreateOption + type BaseScheduler struct + OpController *schedule.OperatorController + func NewBaseScheduler(opController *schedule.OperatorController) *BaseScheduler + func (s *BaseScheduler) Cleanup(cluster opt.Cluster) + func (s *BaseScheduler) EncodeConfig() ([]byte, error) + func (s *BaseScheduler) GetMinInterval() time.Duration + func (s *BaseScheduler) GetNextInterval(interval time.Duration) time.Duration + func (s *BaseScheduler) Prepare(cluster opt.Cluster) error + func (s *BaseScheduler) ServeHTTP(w http.ResponseWriter, r *http.Request) + type Influence struct + ByteRate float64 + Count float64 + KeyRate float64
Go to main page