- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for GetPodQOS (0.53 sec)
-
pkg/apis/core/helper/qos/qos.go
func isSupportedQoSComputeResource(name core.ResourceName) bool { return supportedQoSComputeResources.Has(string(name)) } // GetPodQOS returns the QoS class of a pod persisted in the PodStatus.QOSClass field. // If PodStatus.QOSClass is empty, it returns value of ComputePodQOS() which evaluates pod's QoS class. func GetPodQOS(pod *core.Pod) core.PodQOSClass { if pod.Status.QOSClass != "" { return pod.Status.QOSClass } return ComputePodQOS(pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 04:01:46 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/apis/core/v1/helper/qos/qos.go
func isSupportedQoSComputeResource(name v1.ResourceName) bool { return supportedQoSComputeResources.Has(string(name)) } // GetPodQOS returns the QoS class of a pod persisted in the PodStatus.QOSClass field. // If PodStatus.QOSClass is empty, it returns value of ComputePodQOS() which evaluates pod's QoS class. func GetPodQOS(pod *v1.Pod) v1.PodQOSClass { if pod.Status.QOSClass != "" { return pod.Status.QOSClass } return ComputePodQOS(pod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 04:01:46 UTC 2023 - 3.5K bytes - Viewed (0) -
pkg/kubelet/qos/policy.go
if types.IsNodeCriticalPod(pod) { // Only node critical pod should be the last to get killed. return guaranteedOOMScoreAdj } switch v1qos.GetPodQOS(pod) { case v1.PodQOSGuaranteed: // Guaranteed containers should be the last to get killed. return guaranteedOOMScoreAdj case v1.PodQOSBestEffort: return besteffortOOMScoreAdj }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 10 14:49:26 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/kubelet/cm/qos_container_manager_linux.go
pods := m.activePods() burstablePodCPURequest := int64(0) reuseReqs := make(v1.ResourceList, 4) for i := range pods { pod := pods[i] qosClass := v1qos.GetPodQOS(pod) if qosClass != v1.PodQOSBurstable { // we only care about the burstable qos tier continue } req := resource.PodRequests(pod, resource.PodResourcesOptions{Reuse: reuseReqs})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/cm/helpers_linux.go
// quota is not capped when cfs quota is disabled if !enforceCPULimits { cpuQuota = int64(-1) } // determine the qos class qosClass := v1qos.GetPodQOS(pod) // build the result result := &ResourceConfig{} if qosClass == v1.PodQOSGuaranteed { result.CPUShares = &cpuShares result.CPUQuota = &cpuQuota result.CPUPeriod = &cpuPeriod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 11:52:28 UTC 2023 - 9.8K bytes - Viewed (0) -
plugin/pkg/admission/podtolerationrestriction/admission.go
// fall back to cluster's default tolerations. if ts == nil { ts = p.pluginConfig.Default } extraTolerations = ts } if qoshelper.GetPodQOS(pod) != api.PodQOSBestEffort { extraTolerations = append(extraTolerations, api.Toleration{ Key: corev1.TaintNodeMemoryPressure, Operator: api.TolerationOpExists, Effect: api.TaintEffectNoSchedule, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 29 20:07:59 UTC 2020 - 8.3K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
} return nil } // Allocate call is idempotent func (p *staticPolicy) Allocate(s state.State, pod *v1.Pod, container *v1.Container) (rerr error) { // allocate the memory only for guaranteed pods if v1qos.GetPodQOS(pod) != v1.PodQOSGuaranteed { return nil } podUID := string(pod.UID) klog.InfoS("Allocate", "pod", klog.KObj(pod), "containerName", container.Name) // container belongs in an exclusively allocated pool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
pkg/kubelet/preemption/preemption.go
func sortPodsByQOS(preemptor *v1.Pod, pods []*v1.Pod) (bestEffort, burstable, guaranteed []*v1.Pod) { for _, pod := range pods { if kubetypes.Preemptable(preemptor, pod) { switch v1qos.GetPodQOS(pod) { case v1.PodQOSBestEffort: bestEffort = append(bestEffort, pod) case v1.PodQOSBurstable: burstable = append(burstable, pod) case v1.PodQOSGuaranteed: guaranteed = append(guaranteed, pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/kubelet/cm/pod_container_manager_linux.go
} // GetPodContainerName returns the CgroupName identifier, and its literal cgroupfs form on the host. func (m *podContainerManagerImpl) GetPodContainerName(pod *v1.Pod) (CgroupName, string) { podQOS := v1qos.GetPodQOS(pod) // Get the parent QOS container name var parentContainer CgroupName switch podQOS { case v1.PodQOSGuaranteed: parentContainer = m.qosContainersInfo.Guaranteed case v1.PodQOSBurstable:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 16:38:36 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_linux.go
return &swapConfigurationHelper{machineInfo: machineInfo} } func (m swapConfigurationHelper) ConfigureLimitedSwap(lcr *runtimeapi.LinuxContainerResources, pod *v1.Pod, container *v1.Container) { podQos := kubeapiqos.GetPodQOS(pod) containerDoesNotRequestMemory := container.Resources.Requests.Memory().IsZero() && container.Resources.Limits.Memory().IsZero()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 17.2K bytes - Viewed (0)