qos

func AlignOOMPriority ¶ added in v0.4.0

func AlignOOMPriority(qosLevel string, userSpecifiedScore *int) (oomPriorityScore int)

func AnnotationsGetNUMAIDs ¶ added in v0.5.43

func AnnotationsGetNUMAIDs(annotations map[string]string, numaNodes []int, key string) (machine.BitMask, error)

AnnotationsGetNUMAIDs gets the specific NUMA IDs that the pod should be allocated to in the form of a bitmask. It takes in the machine NUMA nodes as a parameter and makes sure that the NUMA IDs are valid.

func AnnotationsGetNUMANumber ¶ added in v0.5.43

func AnnotationsGetNUMANumber(annotations map[string]string, maxNumaNumber int, key string) (int, error)

AnnotationsGetNUMANumber gets the number of NUMA nodes that the pod should be allocated to.

func AnnotationsIndicateAlignBySocket ¶ added in v0.5.43

func AnnotationsIndicateAlignBySocket(annotations map[string]string) bool

AnnotationsIndicateAlignBySocket returns true if the given annotations indicate that the pod should be aligned by socket.

func AnnotationsIndicateDistributeEvenlyAcrossNuma ¶ added in v0.5.43

func AnnotationsIndicateDistributeEvenlyAcrossNuma(annotations map[string]string) bool

AnnotationsIndicateDistributeEvenlyAcrossNuma returns true if the given annotations indicate that the pod's cpu request should be evenly distributed across NUMA nodes.

func AnnotationsIndicateFullPCPUsPairing ¶ added in v0.5.43

func AnnotationsIndicateFullPCPUsPairing(annotations map[string]string) bool

AnnotationsIndicateFullPCPUsPairing returns true if the given annotations indicate that the pod should be allocated to full physical cores only.

func AnnotationsIndicateNUMABinding ¶ added in v0.2.0

func AnnotationsIndicateNUMABinding(annotations map[string]string) bool

func AnnotationsIndicateNUMAExclusive ¶ added in v0.2.0

func AnnotationsIndicateNUMAExclusive(annotations map[string]string) bool

func AnnotationsIndicateNUMANotShare ¶ added in v0.5.32

func AnnotationsIndicateNUMANotShare(annotations map[string]string) bool

func AnnotationsIndicateSharedCores ¶ added in v0.5.48

func AnnotationsIndicateSharedCores(annotations map[string]string) bool

func GetActualNUMABindingResult ¶ added in v0.5.16

func GetActualNUMABindingResult(qosConf *generic.QoSConfiguration, pod *v1.Pod) (int, error)

GetActualNUMABindingResult parse the user specified numa binding result from pod annotation if the annotation is not found, return -1

func GetOOMPriority ¶ added in v0.4.0

func GetOOMPriority(qosConf *generic.QoSConfiguration, pod *v1.Pod) (priority *int, invalid bool)

GetOOMPriority parse the user specified oom priority from memory enhancement annotation

func GetPodCPUBurstPercentFromCPUEnhancement ¶ added in v0.5.39

func GetPodCPUBurstPercentFromCPUEnhancement(qosConf *generic.QoSConfiguration, pod *v1.Pod) (float64, bool, error)

GetPodCPUBurstPercentFromCPUEnhancement parses cpu burst percent for the given pod by parsing the cpu enhancement keys.

func GetPodCPUBurstPolicyFromCPUEnhancement ¶ added in v0.5.39

func GetPodCPUBurstPolicyFromCPUEnhancement(qosConf *generic.QoSConfiguration, pod *v1.Pod) string

GetPodCPUBurstPolicyFromCPUEnhancement gets the cpu burst policy for the given pod by parsing the cpu enhancement keys. All reclaimed cores pods should not have cpu burst enabled.

func GetPodCPUSuppressionToleranceRate ¶

func GetPodCPUSuppressionToleranceRate(qosConf *generic.QoSConfiguration, pod *v1.Pod) (float64, error)

GetPodCPUSuppressionToleranceRate parses cpu suppression tolerance rate for the given pod, and cpu suppression is only supported for reclaim pods. if the given is not nominated with cpu suppression, return max to indicate that it can be suppressed for any degree.

func GetPodNetClassID ¶ added in v0.2.0

func GetPodNetClassID(podAnnotations map[string]string, podLevelNetClassAnnoKey string) (bool, uint32, error)

GetPodNetClassID parses net class id for the given pod. if the given pod doesn't specify a class id, the first value returned will be false

func GetRSSOverUseEvictThreshold ¶ added in v0.2.0

func GetRSSOverUseEvictThreshold(qosConf *generic.QoSConfiguration, pod *v1.Pod) (threshold *float64, invalid bool)

GetRSSOverUseEvictThreshold parse the user specified threshold and checks if it's valid

func IsPodNumaBinding ¶

func IsPodNumaBinding(qosConf *generic.QoSConfiguration, pod *v1.Pod) bool

IsPodNumaBinding checks whether the pod needs numa-binding

func IsPodNumaExclusive ¶ added in v0.3.0

func IsPodNumaExclusive(qosConf *generic.QoSConfiguration, pod *v1.Pod) bool

IsPodNumaExclusive checks whether the pod needs numa-exclusive

func ParseMemoryEnhancement ¶ added in v0.3.0

func ParseMemoryEnhancement(qosConf *generic.QoSConfiguration, pod *v1.Pod) map[string]string