Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PodConditionSharedByKubelet (0.33 sec)

  1. pkg/kubelet/types/pod_status.go

    		if conditionType == v1.PodReadyToStartContainers {
    			return true
    		}
    	}
    	return false
    }
    
    // PodConditionSharedByKubelet returns if the pod condition type is shared by kubelet
    func PodConditionSharedByKubelet(conditionType v1.PodConditionType) bool {
    	if utilfeature.DefaultFeatureGate.Enabled(features.PodDisruptionConditions) {
    		if conditionType == v1.DisruptionTarget {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 12 15:18:11 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  2. pkg/kubelet/types/pod_status_test.go

    		v1.DisruptionTarget,
    	}
    
    	for _, tc := range trueCases {
    		if !PodConditionSharedByKubelet(tc) {
    			t.Errorf("Expect %q to be condition shared by kubelet.", tc)
    		}
    	}
    
    	falseCases := []v1.PodConditionType{
    		v1.PodConditionType("abcd"),
    		v1.PodConditionType(v1.PodReasonUnschedulable),
    	}
    
    	for _, tc := range falseCases {
    		if PodConditionSharedByKubelet(tc) {
    			t.Errorf("Expect %q NOT to be condition shared by kubelet.", tc)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  3. pkg/kubelet/status/status_manager.go

    	oldCopy := oldStatus.DeepCopy()
    	for _, c := range status.Conditions {
    		// both owned and shared conditions are used for kubelet status equality
    		if kubetypes.PodConditionByKubelet(c.Type) || kubetypes.PodConditionSharedByKubelet(c.Type) {
    			_, oc := podutil.GetPodCondition(oldCopy, c.Type)
    			if oc == nil || oc.Status != c.Status || oc.Message != c.Message || oc.Reason != c.Reason {
    				return false
    			}
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 44.3K bytes
    - Viewed (0)
Back to top