config

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 15, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const RejectLeader = "reject-leader"

RejectLeader is the label property type that suggests a store should not have any region leaders.

Variables

This section is empty.

Functions

func IsSchedulerRegistered

func IsSchedulerRegistered(name string) bool

IsSchedulerRegistered checks if the named scheduler type is registered.

func RegisterScheduler

func RegisterScheduler(typ string)

RegisterScheduler registers the scheduler type.

Types

type Config

type Config interface {
	GetReplicaScheduleLimit() uint64
	GetRegionScheduleLimit() uint64
	GetMergeScheduleLimit() uint64
	GetLeaderScheduleLimit() uint64
	GetHotRegionScheduleLimit() uint64
	GetWitnessScheduleLimit() uint64

	GetHotRegionCacheHitsThreshold() int
	GetMaxMovableHotPeerSize() int64
	IsTraceRegionFlow() bool

	GetSplitMergeInterval() time.Duration
	GetMaxMergeRegionSize() uint64
	GetMaxMergeRegionKeys() uint64
	GetKeyType() constant.KeyType
	IsOneWayMergeEnabled() bool
	IsCrossTableMergeEnabled() bool

	IsPlacementRulesEnabled() bool
	IsPlacementRulesCacheEnabled() bool

	GetMaxReplicas() int
	GetPatrolRegionInterval() time.Duration
	GetMaxStoreDownTime() time.Duration
	GetLocationLabels() []string
	GetIsolationLevel() string
	IsReplaceOfflineReplicaEnabled() bool
	IsMakeUpReplicaEnabled() bool
	IsRemoveExtraReplicaEnabled() bool
	IsLocationReplacementEnabled() bool
	IsRemoveDownReplicaEnabled() bool

	GetSwitchWitnessInterval() time.Duration
	IsWitnessAllowed() bool

	GetLowSpaceRatio() float64
	GetHighSpaceRatio() float64
	GetTolerantSizeRatio() float64
	GetLeaderSchedulePolicy() constant.SchedulePolicy
	GetRegionScoreFormulaVersion() string

	GetMaxSnapshotCount() uint64
	GetMaxPendingPeerCount() uint64
	GetSchedulerMaxWaitingOperator() uint64
	GetStoreLimitByType(uint64, storelimit.Type) float64
	SetAllStoresLimit(storelimit.Type, float64)
	GetSlowStoreEvictingAffectedStoreRatioThreshold() float64
	IsUseJointConsensus() bool
	CheckLabelProperty(string, []*metapb.StoreLabel) bool
	IsDebugMetricsEnabled() bool
	GetClusterVersion() *semver.Version
	GetStoreLimitVersion() string
	// for test purpose
	SetPlacementRuleEnabled(bool)
	SetSplitMergeInterval(time.Duration)
	SetMaxReplicas(int)
	SetPlacementRulesCacheEnabled(bool)
	SetWitnessEnabled(bool)
	// only for store configuration
	UseRaftV2()
}

Config is the interface that wraps the Config related methods.

type StoreConfig

type StoreConfig interface {
	GetRegionMaxSize() uint64
	CheckRegionSize(uint64, uint64) error
	CheckRegionKeys(uint64, uint64) error
	IsEnableRegionBucket() bool
	IsRaftKV2() bool
	// for test purpose
	SetRegionBucketEnabled(bool)
}

StoreConfig is the interface that wraps the StoreConfig related methods.

Jump to

Keyboard shortcuts

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