Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AvoidOverloadedHostsCPUStep ¶
type AvoidOverloadedHostsCPUStep struct {
// BaseStep is a helper struct that provides common functionality for all steps.
scheduling.BaseStep[api.PipelineRequest, AvoidOverloadedHostsCPUStepOpts]
}
Step to avoid high cpu hosts by downvoting them.
func (*AvoidOverloadedHostsCPUStep) GetName ¶
func (s *AvoidOverloadedHostsCPUStep) GetName() string
Get the name of this step, used for identification in config, logs, metrics, etc.
func (*AvoidOverloadedHostsCPUStep) Run ¶
func (s *AvoidOverloadedHostsCPUStep) Run(traceLog *slog.Logger, request api.PipelineRequest) (*scheduling.StepResult, error)
Downvote hosts that have high cpu load.
type AvoidOverloadedHostsCPUStepOpts ¶
type AvoidOverloadedHostsCPUStepOpts struct {
AvgCPUUsageLowerBound float64 `json:"avgCPUUsageLowerBound"` // -> mapped to ActivationLowerBound
AvgCPUUsageUpperBound float64 `json:"avgCPUUsageUpperBound"` // -> mapped to ActivationUpperBound
AvgCPUUsageActivationLowerBound float64 `json:"avgCPUUsageActivationLowerBound"`
AvgCPUUsageActivationUpperBound float64 `json:"avgCPUUsageActivationUpperBound"`
MaxCPUUsageLowerBound float64 `json:"maxCPUUsageLowerBound"` // -> mapped to ActivationLowerBound
MaxCPUUsageUpperBound float64 `json:"maxCPUUsageUpperBound"` // -> mapped to ActivationUpperBound
MaxCPUUsageActivationLowerBound float64 `json:"maxCPUUsageActivationLowerBound"`
MaxCPUUsageActivationUpperBound float64 `json:"maxCPUUsageActivationUpperBound"`
}
Options for the scheduling step, given through the step config in the service yaml file. Use the options contained in this struct to configure the bounds for min-max scaling.
func (AvoidOverloadedHostsCPUStepOpts) Validate ¶
func (o AvoidOverloadedHostsCPUStepOpts) Validate() error
type AvoidOverloadedHostsMemoryStep ¶
type AvoidOverloadedHostsMemoryStep struct {
// BaseStep is a helper struct that provides common functionality for all steps.
scheduling.BaseStep[api.PipelineRequest, AvoidOverloadedHostsMemoryStepOpts]
}
Step to avoid high cpu hosts by downvoting them.
func (*AvoidOverloadedHostsMemoryStep) GetName ¶
func (s *AvoidOverloadedHostsMemoryStep) GetName() string
Get the name of this step, used for identification in config, logs, metrics, etc.
func (*AvoidOverloadedHostsMemoryStep) Run ¶
func (s *AvoidOverloadedHostsMemoryStep) Run(traceLog *slog.Logger, request api.PipelineRequest) (*scheduling.StepResult, error)
Downvote hosts that have high cpu load.
type AvoidOverloadedHostsMemoryStepOpts ¶
type AvoidOverloadedHostsMemoryStepOpts struct {
AvgMemoryUsageLowerBound float64 `json:"avgMemoryUsageLowerBound"` // -> mapped to ActivationLowerBound
AvgMemoryUsageUpperBound float64 `json:"avgMemoryUsageUpperBound"` // -> mapped to ActivationUpperBound
AvgMemoryUsageActivationLowerBound float64 `json:"avgMemoryUsageActivationLowerBound"`
AvgMemoryUsageActivationUpperBound float64 `json:"avgMemoryUsageActivationUpperBound"`
MaxMemoryUsageLowerBound float64 `json:"maxMemoryUsageLowerBound"` // -> mapped to ActivationLowerBound
MaxMemoryUsageUpperBound float64 `json:"maxMemoryUsageUpperBound"` // -> mapped to ActivationUpperBound
MaxMemoryUsageActivationLowerBound float64 `json:"maxMemoryUsageActivationLowerBound"`
MaxMemoryUsageActivationUpperBound float64 `json:"maxMemoryUsageActivationUpperBound"`
}
Options for the scheduling step, given through the step config in the service yaml file. Use the options contained in this struct to configure the bounds for min-max scaling.
func (AvoidOverloadedHostsMemoryStepOpts) Validate ¶
func (o AvoidOverloadedHostsMemoryStepOpts) Validate() error