Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 17 of 17 for GetPodQOS (0.17 sec)

  1. pkg/quota/v1/evaluator/core/pods.go

    	limits := resourcehelper.PodLimits(pod, opts)
    
    	result = quota.Add(result, podComputeUsageHelper(requests, limits))
    	return result, nil
    }
    
    func isBestEffort(pod *corev1.Pod) bool {
    	return qos.GetPodQOS(pod) == corev1.PodQOSBestEffort
    }
    
    func isTerminating(pod *corev1.Pod) bool {
    	if pod.Spec.ActiveDeadlineSeconds != nil && *pod.Spec.ActiveDeadlineSeconds >= int64(0) {
    		return true
    	}
    	return false
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 05 00:02:47 UTC 2023
    - 17.4K bytes
    - Viewed (0)
  2. pkg/kubelet/eviction/eviction_manager.go

    	nodeOnlyHasMemoryPressureCondition := hasNodeCondition(m.nodeConditions, v1.NodeMemoryPressure) && len(m.nodeConditions) == 1
    	if nodeOnlyHasMemoryPressureCondition {
    		notBestEffort := v1.PodQOSBestEffort != v1qos.GetPodQOS(attrs.Pod)
    		if notBestEffort {
    			return lifecycle.PodAdmitResult{Admit: true}
    		}
    
    		// When node has memory pressure, check BestEffort Pod's toleration:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 27 18:55:56 UTC 2024
    - 24.6K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/policy_static.go

    	klog.InfoS("AllocateCPUs", "result", result)
    	return result, nil
    }
    
    func (p *staticPolicy) guaranteedCPUs(pod *v1.Pod, container *v1.Container) int {
    	if v1qos.GetPodQOS(pod) != v1.PodQOSGuaranteed {
    		return 0
    	}
    	cpuQuantity := container.Resources.Requests[v1.ResourceCPU]
    	// In-place pod resize feature makes Container.Resources field mutable for CPU & memory.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 28.8K bytes
    - Viewed (0)
  4. pkg/registry/core/pod/strategy.go

    func (podStrategy) PrepareForCreate(ctx context.Context, obj runtime.Object) {
    	pod := obj.(*api.Pod)
    	pod.Status = api.PodStatus{
    		Phase:    api.PodPending,
    		QOSClass: qos.GetPodQOS(pod),
    	}
    
    	podutil.DropDisabledPodFields(pod, nil)
    
    	applySchedulingGatedCondition(pod)
    	mutatePodAffinity(pod)
    	applyAppArmorVersionSkew(ctx, pod)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 17:51:48 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_pods.go

    	}
    	if len(apiPodStatus.PodIPs) > 0 {
    		apiPodStatus.PodIP = apiPodStatus.PodIPs[0].IP
    	}
    
    	// set status for Pods created on versions of kube older than 1.6
    	apiPodStatus.QOSClass = v1qos.GetPodQOS(pod)
    
    	apiPodStatus.ContainerStatuses = kl.convertToAPIContainerStatuses(
    		pod, podStatus,
    		oldPodStatus.ContainerStatuses,
    		pod.Spec.Containers,
    		len(pod.Spec.InitContainers) > 0,
    		false,
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.29.md

      It reduces the number of kinds of cluster events the scheduler needs to subscribe/handle. ([#121571](https://github.com/kubernetes/kubernetes/pull/121571), [@sanposhiho](https://github.com/sanposhiho))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 03:42:38 UTC 2024
    - 324.5K bytes
    - Viewed (0)
  7. pkg/apis/core/validation/validation.go

    	// so far and save the cost of a deep copy.
    	if apiequality.Semantic.DeepEqual(newPod.Spec, oldPod.Spec) {
    		return allErrs
    	}
    
    	if qos.GetPodQOS(oldPod) != qos.ComputePodQOS(newPod) {
    		allErrs = append(allErrs, field.Invalid(fldPath, newPod.Status.QOSClass, "Pod QoS is immutable"))
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 349.5K bytes
    - Viewed (0)
Back to top