Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for originalPods (0.14 sec)

  1. pkg/controller/statefulset/stateful_set_control_test.go

    		}
    		sort.Sort(ascendingOrdinal(pods))
    		// pods 0, 1,2, 4,5 should be present(note 3 is missing)
    		if !reflect.DeepEqual(pods, append(originalPods[:3], originalPods[4:]...)) {
    			t.Fatalf("Expected pods %v, got pods %v", append(originalPods[:3], originalPods[4:]...), pods)
    		}
    
    		// create new pod 3
    		if _, err = ssc.UpdateStatefulSet(context.TODO(), set, pods); err != nil {
    			t.Fatal(err)
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/podtopologyspread/plugin.go

    	originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	if (modifiedPod != nil && !involvedInTopologySpreading(modifiedPod, pod)) || (originalPod != nil && !involvedInTopologySpreading(originalPod, pod)) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration.go

    	originalNode, modifiedNode, err := util.As[*v1.Node](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	wasUntolerated := true
    	if originalNode != nil {
    		_, wasUntolerated = v1helper.FindMatchingUntoleratedTaint(originalNode.Spec.Taints, pod.Spec.Tolerations, helper.DoNotScheduleTaintsFilterFunc())
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_node_status.go

    		return true
    	}
    
    	originalNode, err := kl.GetNode()
    	if err != nil {
    		klog.ErrorS(err, "Error getting the current node from lister")
    		return false
    	}
    
    	readyIdx, originalNodeReady := nodeutil.GetNodeCondition(&originalNode.Status, v1.NodeReady)
    	if readyIdx == -1 {
    		klog.ErrorS(nil, "Node does not have NodeReady condition", "originalNode", originalNode)
    		return false
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/interpodaffinity/plugin.go

    	originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    	if (modifiedPod != nil && modifiedPod.Spec.NodeName == "") || (originalPod != nil && originalPod.Spec.NodeName == "") {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 03:08:44 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/noderesources/fit.go

    	originalPod, modifiedPod, err := schedutil.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, err
    	}
    
    	if modifiedPod == nil {
    		if originalPod.Spec.NodeName == "" {
    			logger.V(5).Info("the deleted pod was unscheduled and it wouldn't make the unscheduled pod schedulable", "pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
    			return framework.QueueSkip, nil
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    	key, originalPod := testPropagateStore(ctx, t, store, &example.Pod{ObjectMeta: metav1.ObjectMeta{Name: "name", Namespace: "test-ns"}})
    
    	// First delete, so originalPod is outdated.
    	deletedPod := &example.Pod{}
    	if err := store.Delete(ctx, key, deletedPod, nil, storage.ValidateAllObjectFunc, originalPod); err != nil {
    		t.Errorf("Unexpected failure during deletion: %v", err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  8. pkg/controller/util/node/controller_utils.go

    			if !ok {
    				logger.Error(nil, "Received unexpected object", "object", originalObj)
    				return
    			}
    			originalNode, ok = deletedState.Obj.(*v1.Node)
    			if !ok {
    				logger.Error(nil, "DeletedFinalStateUnknown contained non-Node object", "object", deletedState.Obj)
    				return
    			}
    		}
    		node := originalNode.DeepCopy()
    		if err := f(node); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 23:39:52 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  9. subprojects/core/src/main/java/org/gradle/groovy/scripts/internal/GradleResolveVisitor.java

                    return;
                }
                if (interfacesToCompare != null && interfacesToCompare.length > 0) {
                    for (ClassNode intfToCompare : interfacesToCompare) {
                        if (originalNode == intfToCompare.redirect()) {
                            addError("Cycle detected: the type " + originalNode.getName() + " cannot implement itself", originalNode);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jan 26 14:58:23 UTC 2024
    - 67.6K bytes
    - Viewed (0)
  10. pkg/kube/inject/webhook.go

    // * originalPod: the pod before injection. If needed, we will apply some configurations from this pod on top of the final pod
    // * templatePod: the rendered injection template. This is needed only to see what containers we injected
    // * finalPod: the current result of injection, roughly equivalent to the merging of originalPod and templatePod
    // There are essentially three cases we cover here:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 17:59:39 UTC 2024
    - 42.2K bytes
    - Viewed (0)
Back to top