helper

Documentation

Index

• func EstimateContainerCPUUsage(ci *types.ContainerInfo, metaReader metacache.MetaReader, reclaimEnable bool) (float64, error)
• func EstimateContainerMemoryUsage(ci *types.ContainerInfo, metaReader metacache.MetaReader, reclaimEnable bool) (float64, error)
• func EstimateUtilBasedCapacity(options UtilBasedCapacityOptions, ...) (float64, error)
• func GetAvailableNUMAsAndReclaimedCores(conf *config.Configuration, metaReader metacache.MetaReader, ...) (machine.CPUSet, []*types.ContainerInfo, error)
• func IsValidQosLevel(qoslevel string) bool
• func PodEnableReclaim(ctx context.Context, metaServer *metaserver.MetaServer, podUID string, ...) (bool, error)
• func PodIsDaemonSet(pod *v1.Pod) bool
• func PodPerformanceScore(ctx context.Context, metaServer *metaserver.MetaServer, podUID string) (float64, error)
• type PIDController
  • func NewPIDController(variableName string, params types.FirstOrderPIDParams) *PIDController
  • func (c *PIDController) Adjust(controlKnob, target, current float64) float64
  • func (c *PIDController) SetEssentials(resourceEssentials types.ResourceEssentials)
• type UtilBasedCapacityOptions

Functions

func EstimateContainerCPUUsage

func EstimateContainerCPUUsage(ci *types.ContainerInfo, metaReader metacache.MetaReader, reclaimEnable bool) (float64, error)

EstimateContainerCPUUsage estimates non-reclaimed container cpu usage. Use cpu request if metrics are missing or reclaimEnable is false.

func EstimateContainerMemoryUsage

func EstimateContainerMemoryUsage(ci *types.ContainerInfo, metaReader metacache.MetaReader, reclaimEnable bool) (float64, error)

EstimateContainerMemoryUsage estimates non-reclaimed container memory usage. Use memory request if metrics are missing or reclaimEnable is false.

func EstimateUtilBasedCapacity

func EstimateUtilBasedCapacity(options UtilBasedCapacityOptions, resourceSupply,
	currentUtilization, lastCapacityResult float64,
) (float64, error)

EstimateUtilBasedCapacity capacity by taking into account the difference between the current and target resource utilization of the workload pool

func GetAvailableNUMAsAndReclaimedCores

func GetAvailableNUMAsAndReclaimedCores(conf *config.Configuration, metaReader metacache.MetaReader, metaServer *metaserver.MetaServer) (machine.CPUSet, []*types.ContainerInfo, error)

func IsValidQosLevel

func IsValidQosLevel(qoslevel string) bool

func PodEnableReclaim

func PodEnableReclaim(ctx context.Context, metaServer *metaserver.MetaServer,
	podUID string, nodeEnableReclaim bool,
) (bool, error)

PodEnableReclaim checks whether the pod can be reclaimed, if node does not enable reclaim, it will return false directly, if node enable reclaim, it will check whether the pod is degraded or baseline.

func PodIsDaemonSet

func PodIsDaemonSet(pod *v1.Pod) bool

func PodPerformanceScore

func PodPerformanceScore(ctx context.Context, metaServer *metaserver.MetaServer, podUID string) (float64, error)

Types

type PIDController

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

func NewPIDController

func NewPIDController(variableName string, params types.FirstOrderPIDParams) *PIDController

func (*PIDController) Adjust

func (c *PIDController) Adjust(controlKnob, target, current float64) float64

func (*PIDController) SetEssentials

func (c *PIDController) SetEssentials(resourceEssentials types.ResourceEssentials)

type UtilBasedCapacityOptions

type UtilBasedCapacityOptions struct {
	TargetUtilization float64
	MaxUtilization    float64
	MaxOversoldRate   float64
	MaxCapacity       float64
}

UtilBasedCapacityOptions are options for estimate util based resource capacity