Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for applyNodeStatusPatch (0.27 sec)

  1. pkg/kubelet/kubelet_node_status_test.go

    	for ; count > 0; count-- {
    		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)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  2. pkg/volume/csi/nodeinfomanager/nodeinfomanager_test.go

    			continue
    		}
    
    		actions := client.Actions()
    
    		var node *v1.Node
    		if action := hasPatchAction(actions); action != nil {
    			node, err = applyNodeStatusPatch(tc.existingNode, action.(clienttesting.PatchActionImpl).GetPatch())
    			assert.NoError(t, err)
    		} else {
    			node, err = client.CoreV1().Nodes().Get(context.TODO(), nodeName, metav1.GetOptions{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 17 02:02:59 UTC 2022
    - 34.3K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_test.go

    								var (
    									err          error
    									patchAction  = action.(core.PatchActionImpl)
    									patchContent = patchAction.GetPatch()
    								)
    								savedNode, err = applyNodeStatusPatch(test.existingNode, patchContent)
    								if err != nil {
    									t.Logf("node patching failed, %v", err)
    									return false, nil
    								}
    							}
    						}
    					} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
Back to top