minimizepower

Documentation

Index

• Constants
• Variables
• func New(_ context.Context, obj runtime.Object, fh framework.Handle) (framework.Plugin, error)
• func PodCPURequestOrLimit(pod *corev1.Pod) (v float64)
• func PowerConsumptions2Scores(scores framework.NodeScoreList, baseScore int64, replaceMap map[int64]int64)
• type MinimizePower
  • func (*MinimizePower) Name() string
  • func (pl *MinimizePower) NormalizeScore(_ context.Context, _ *framework.CycleState, pod *corev1.Pod, ...) *framework.Status
  • func (pl *MinimizePower) PreFilter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod) (*framework.PreFilterResult, *framework.Status)
  • func (pl *MinimizePower) PreFilterExtensions() framework.PreFilterExtensions
  • func (pl *MinimizePower) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, ...) (int64, *framework.Status)
  • func (pl *MinimizePower) ScoreExtensions() framework.ScoreExtensions
• type MinimizePowerArgs
  • func (in *MinimizePowerArgs) DeepCopy() *MinimizePowerArgs
  • func (in *MinimizePowerArgs) DeepCopyInto(out *MinimizePowerArgs)
  • func (in *MinimizePowerArgs) DeepCopyObject() runtime.Object
  • func (args *MinimizePowerArgs) Default()
  • func (args *MinimizePowerArgs) Validate() error

Constants

const (
	ScoreError int64 = math.MaxInt64
	ScoreMax   int64 = math.MaxInt64 >> 1
)

const (
	DefaultMetricsCacheTTL            = 30 * time.Second
	DefaultPredictorCacheTTL          = 30 * time.Minute
	DefaultPodUsageAssumption float64 = 0.5
	DefaultCPUUsageFormat             = CPUUsageFormatRaw
)

const (
	CPUUsageFormatRaw     string = "Raw"
	CPUUsageFormatPercent string = "Percent"
)

Variables

var (
	Name = "MinimizePower"

	ReasonResourceRequest = "at least one container in the pod must have a requests.cpu or limits.cpu set"
)

var (
	SchemeGroupVersionV1Internal = schema.GroupVersion{Group: schedconfig.GroupName, Version: runtime.APIVersionInternal}
	SchemeGroupVersionV1B2       = schema.GroupVersion{Group: schedconfig.GroupName, Version: "v1beta2"}
	SchemeGroupVersionV1B3       = schema.GroupVersion{Group: schedconfig.GroupName, Version: "v1beta3"}
	SchemeGroupVersionV1         = schema.GroupVersion{Group: schedconfig.GroupName, Version: "v1"}
)

register all kubescheduler.config.k8s.io APIs

var (
	AddToScheme = localSchemeBuilder.AddToScheme
)

var (
	// ScoreBase is the base score for all nodes.
	// This is the lowest score except for special scores (will be replaced to 0,1,...,<ScoreBase)
	ScoreBase int64 = 20
)

var (
	// ScoreReplaceMap are scores that have special meanings.
	// NormalizeScore will replace them with the mapped values (should be less than ScoreBase).
	ScoreReplaceMap = map[int64]int64{
		ScoreError: 0,
		ScoreMax:   1,
	}
)

Functions

func New

func New(_ context.Context, obj runtime.Object, fh framework.Handle) (framework.Plugin, error)

New initializes a new plugin and returns it.

func PodCPURequestOrLimit

func PodCPURequestOrLimit(pod *corev1.Pod) (v float64)

func PowerConsumptions2Scores

func PowerConsumptions2Scores(scores framework.NodeScoreList, baseScore int64, replaceMap map[int64]int64)

Types

type MinimizePower

type MinimizePower struct {
	// contains filtered or unexported fields
}

func (*MinimizePower) Name

func (*MinimizePower) Name() string

Name returns name of the plugin. It is used in logs, etc.

func (*MinimizePower) NormalizeScore

func (pl *MinimizePower) NormalizeScore(_ context.Context, _ *framework.CycleState, pod *corev1.Pod, scores framework.NodeScoreList) *framework.Status

func (*MinimizePower) PreFilter

func (pl *MinimizePower) PreFilter(ctx context.Context, state *framework.CycleState, pod *corev1.Pod) (*framework.PreFilterResult, *framework.Status)

PreFilter rejects a pod if it does not have at least one container that has a CPU request or limit set.

func (*MinimizePower) PreFilterExtensions

func (pl *MinimizePower) PreFilterExtensions() framework.PreFilterExtensions

PreFilterExtensions returns nil as this plugin does not have PreFilterExtensions.

func (*MinimizePower) Score

func (pl *MinimizePower) Score(ctx context.Context, state *framework.CycleState, pod *corev1.Pod, nodeName string) (int64, *framework.Status)

Score returns how many watts will be increased by the given pod (lower is better).

This function never returns an error (as errors cause the pod to be rejected). If an error occurs, it is logged and the score is set to ScoreError(math.MaxInt64).

func (*MinimizePower) ScoreExtensions

func (pl *MinimizePower) ScoreExtensions() framework.ScoreExtensions

ScoreExtensions returns a ScoreExtensions interface.

type MinimizePowerArgs

type MinimizePowerArgs struct {
	metav1.TypeMeta `json:",inline"`

	MetricsCacheTTL   metav1.Duration `json:"metricsCacheTTL,omitempty"`
	PredictorCacheTTL metav1.Duration `json:"predictorCacheTTL,omitempty"`

	PodUsageAssumption float64 `json:"podUsageAssumption,omitempty"`

	CPUUsageFormat string `json:"cpuUsageFormat,omitempty"`
}

func (*MinimizePowerArgs) DeepCopy

func (in *MinimizePowerArgs) DeepCopy() *MinimizePowerArgs

func (*MinimizePowerArgs) DeepCopyInto

func (in *MinimizePowerArgs) DeepCopyInto(out *MinimizePowerArgs)

func (*MinimizePowerArgs) DeepCopyObject

func (in *MinimizePowerArgs) DeepCopyObject() runtime.Object

func (*MinimizePowerArgs) Default

func (args *MinimizePowerArgs) Default()

func (*MinimizePowerArgs) Validate

func (args *MinimizePowerArgs) Validate() error