Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for originalNode (0.27 sec)

  1. 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)
  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/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)
  5. 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)
  6. pkg/controller/testutil/test_utils.go

    	originalObjJS, err := json.Marshal(nodeCopy)
    	if err != nil {
    		klog.FromContext(ctx).Error(nil, "Failed to marshal", "node", klog.KObj(&nodeCopy))
    		return nil, nil
    	}
    	var originalNode v1.Node
    	if err = json.Unmarshal(originalObjJS, &originalNode); err != nil {
    		klog.FromContext(ctx).Error(err, "Failed to unmarshal original object")
    		return nil, nil
    	}
    
    	var patchedObjJS []byte
    	switch pt {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  7. pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go

    				Kind:       nodeKind.Kind,
    				Name:       "node1",
    			},
    		},
    	}
    }
    
    func applyNodeStatusPatch(originalNode *v1.Node, patch []byte) (*v1.Node, error) {
    	original, err := json.Marshal(originalNode)
    	if err != nil {
    		return nil, fmt.Errorf("failed to marshal original node %#v: %v", originalNode, err)
    	}
    	updated, err := strategicpatch.StrategicMergePatch(original, patch, v1.Node{})
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 17 02:02:59 UTC 2022
    - 34.3K bytes
    - Viewed (0)
  8. pkg/volume/csi/nodeinfomanager/nodeinfomanager.go

    	if kubeClient == nil {
    		return fmt.Errorf("error getting kube client")
    	}
    
    	nodeClient := kubeClient.CoreV1().Nodes()
    	originalNode, err := nodeClient.Get(context.TODO(), string(nim.nodeName), metav1.GetOptions{})
    	if err != nil {
    		return err
    	}
    	node := originalNode.DeepCopy()
    
    	needUpdate := false
    	for _, update := range updateFuncs {
    		newNode, updated, err := update(node)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet_node_status_test.go

    		tagList = append(tagList, "registry.k8s.io:v"+strconv.Itoa(count))
    	}
    	return tagList
    }
    
    func applyNodeStatusPatch(originalNode *v1.Node, patch []byte) (*v1.Node, error) {
    	original, err := json.Marshal(originalNode)
    	if err != nil {
    		return nil, fmt.Errorf("failed to marshal original node %#v: %v", originalNode, err)
    	}
    	updated, err := strategicpatch.StrategicMergePatch(original, patch, v1.Node{})
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  10. 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)
Back to top