placement

Jul 21, 2020

Changes in this version

type RuleFit

+ IsolationScore float64

May 27, 2020

Changes in this version

+ func CompareRegionFit(a, b *RegionFit) int

+ func MatchLabelConstraints(store *core.StoreInfo, constraints []LabelConstraint) bool

+ type LabelConstraint struct

+ Key string

+ Op LabelConstraintOp

+ Values []string

+ func (c *LabelConstraint) MatchStore(store *core.StoreInfo) bool

+ type LabelConstraintOp string

+ const Exists

+ const In

+ const NotExists

+ const NotIn

+ type PeerRoleType string

+ const Follower

+ const Leader

+ const Learner

+ const Voter

+ type RegionFit struct

+ OrphanPeers []*metapb.Peer

+ RuleFits []*RuleFit

+ func FitRegion(stores core.StoreSetInformer, region *core.RegionInfo, rules []*Rule) *RegionFit

+ func (f *RegionFit) GetRuleFit(peerID uint64) *RuleFit

+ func (f *RegionFit) IsSatisfied() bool

+ type Rule struct

+ Count int

+ EndKey []byte

+ EndKeyHex string

+ GroupID string

+ ID string

+ Index int

+ LabelConstraints []LabelConstraint

+ LocationLabels []string

+ Override bool

+ Role PeerRoleType

+ StartKey []byte

+ StartKeyHex string

+ func (r Rule) Key() [2]string

+ func (r Rule) StoreKey() string

+ func (r Rule) String() string

+ type RuleFit struct

+ IsolationLevel int

+ Peers []*metapb.Peer

+ PeersWithDifferentRole []*metapb.Peer

+ Rule *Rule

+ func (f *RuleFit) IsSatisfied() bool

+ type RuleManager struct

+ func NewRuleManager(store *core.Storage) *RuleManager

+ func (m *RuleManager) DeleteRule(group, id string) error

+ func (m *RuleManager) FitRegion(stores core.StoreSetInformer, region *core.RegionInfo) *RegionFit

+ func (m *RuleManager) GetAllRules() []*Rule

+ func (m *RuleManager) GetRule(group, id string) *Rule

+ func (m *RuleManager) GetRulesByGroup(group string) []*Rule

+ func (m *RuleManager) GetRulesByKey(key []byte) []*Rule

+ func (m *RuleManager) GetRulesForApplyRegion(region *core.RegionInfo) []*Rule

+ func (m *RuleManager) GetSplitKeys(start, end []byte) [][]byte

+ func (m *RuleManager) Initialize(maxReplica int, locationLabels []string) error

+ func (m *RuleManager) SetRule(rule *Rule) error