Documentation
¶
Index ¶
- Constants
- func DefaultResourceAmplificationCfg() *configuration.ResourceAmplificationCfg
- type Plugin
- func (p *Plugin) Calculate(_ *configuration.ColocationStrategy, node *corev1.Node, _ *corev1.PodList, ...) ([]framework.ResourceItem, error)
- func (p *Plugin) Name() string
- func (p *Plugin) NeedSyncMeta(_ *configuration.ColocationStrategy, oldNode, newNode *corev1.Node) (bool, string)
- func (p *Plugin) Prepare(_ *configuration.ColocationStrategy, node *corev1.Node, ...) error
- func (p *Plugin) Reset(node *corev1.Node, message string) []framework.ResourceItem
- func (p *Plugin) Setup(opt *framework.Option) error
Constants ¶
View Source
const PluginName = "ResourceAmplification"
View Source
const (
ReasonResourceAmplificationConfigUnmarshalFailed = "ResourceAmplificationCfgUnmarshalFailed"
)
Variables ¶
This section is empty.
Functions ¶
func DefaultResourceAmplificationCfg ¶ added in v1.6.0
func DefaultResourceAmplificationCfg() *configuration.ResourceAmplificationCfg
Types ¶
type Plugin ¶
type Plugin struct{}
Plugin calculates and updates final node resource amplification ratios automatically based on user config and node cpu normalization ratio.
func (*Plugin) Calculate ¶
func (p *Plugin) Calculate(_ *configuration.ColocationStrategy, node *corev1.Node, _ *corev1.PodList, _ *framework.ResourceMetrics) ([]framework.ResourceItem, error)
Calculate calculates resource amplification ratio, resource final ratio should >= 1 cpuAmplificationRatio = amplificationStrategy.resourceAmplificationRatio["cpu"] * CPUNormalizationRatio otherResourceAmplificationRatio = amplificationStrategy.resourceAmplificationRatio["other-resource"]
func (*Plugin) NeedSyncMeta ¶
func (p *Plugin) NeedSyncMeta(_ *configuration.ColocationStrategy, oldNode, newNode *corev1.Node) (bool, string)
func (*Plugin) Prepare ¶
func (p *Plugin) Prepare(_ *configuration.ColocationStrategy, node *corev1.Node, nr *framework.NodeResource) error
Click to show internal directories.
Click to hide internal directories.