Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for GetPodQOS (0.53 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top