Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for updatedNodes (0.25 sec)

  1. pkg/controller/testutil/test_utils.go

    		return nil, nil
    	}
    
    	var updatedNode v1.Node
    	if err = json.Unmarshal(patchedObjJS, &updatedNode); err != nil {
    		klog.FromContext(ctx).Error(err, "Failed to unmarshal patched object")
    		return nil, nil
    	}
    
    	if updatedNodeIndex < 0 {
    		m.UpdatedNodes = append(m.UpdatedNodes, &updatedNode)
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  2. pkg/controller/controller_utils_test.go

    				AsyncCalls: []func(*testutil.FakeNodeHandler){func(m *testutil.FakeNodeHandler) {
    					if len(m.UpdatedNodes) == 0 {
    						m.UpdatedNodes = append(m.UpdatedNodes, &v1.Node{
    							ObjectMeta: metav1.ObjectMeta{
    								Name:            "node1",
    								ResourceVersion: "2",
    							},
    							Spec: v1.NodeSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/cache/cache_test.go

    	}
    	// Create a few nodes as updated versions of the above nodes
    	var updatedNodes []*v1.Node
    	for _, n := range nodes {
    		updatedNode := n.DeepCopy()
    		updatedNode.Status.Allocatable = v1.ResourceList{
    			v1.ResourceCPU:    resource.MustParse("2000m"),
    			v1.ResourceMemory: resource.MustParse("500m"),
    		}
    		updatedNodes = append(updatedNodes, updatedNode)
    	}
    
    	// Create a few pods for tests.
    	var pods []*v1.Pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 63.8K bytes
    - Viewed (0)
  4. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    		}
    		if len(item.fakeNodeHandler.UpdatedNodes) > 0 && !apiequality.Semantic.DeepEqual(item.expectedNodes, item.fakeNodeHandler.UpdatedNodes) {
    			t.Errorf("Case[%d] unexpected nodes: %s", i, cmp.Diff(item.expectedNodes[0], item.fakeNodeHandler.UpdatedNodes[0]))
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  5. pkg/controller/nodeipam/ipam/range_allocator_test.go

    			// nothing further expected
    			return
    		}
    		for _, updatedNode := range tc.fakeNodeHandler.GetUpdatedNodesCopy() {
    			if len(updatedNode.Spec.PodCIDRs) == 0 {
    				continue // not assigned yet
    			}
    			//match
    			for podCIDRIdx, expectedPodCIDR := range tc.expectedAllocatedCIDR {
    				if updatedNode.Spec.PodCIDRs[podCIDRIdx] != expectedPodCIDR {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 10:06:15 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_node_status_test.go

    				updatedNode.Status.Conditions[i].LastHeartbeatTime = metav1.Time{}
    				updatedNode.Status.Conditions[i].LastTransitionTime = metav1.Time{}
    			}
    
    			// Version skew workaround. See: https://github.com/kubernetes/kubernetes/issues/16961
    			assert.Equal(t, v1.NodeReady, updatedNode.Status.Conditions[len(updatedNode.Status.Conditions)-1].Type,
    				"NotReady should be last")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
  7. platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/IsolatedProjectsToolingApiGradleProjectIntegrationTest.groovy

            originalUpdatedModel.children.path == [":a", ":b"]
            originalUpdatedModel.children.all[0].tasks.name.contains("something")
    
    
            when:
            executer.withArguments(ENABLE_CLI)
            def updatedModel = fetchModel(GradleProject)
    
            then:
            fixture.assertStateUpdated {
                fileChanged("a/build.gradle")
                modelsCreated(":", GradleProject, IsolatedGradleProjectInternal)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_node_status.go

    	}
    	kl.lastStatusReportTime = kl.clock.Now()
    	kl.setLastObservedNodeAddresses(updatedNode.Status.Addresses)
    
    	readyIdx, readyCondition := nodeutil.GetNodeCondition(&updatedNode.Status, v1.NodeReady)
    	if readyIdx >= 0 && readyCondition.Status == v1.ConditionTrue {
    		kl.nodeStartupLatencyTracker.RecordNodeReady()
    	}
    
    	return updatedNode, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  9. cmd/kube-proxy/app/server_linux_test.go

    		},
    	}
    	node := &v1.Node{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:            nodeName,
    			ResourceVersion: "1",
    		},
    	}
    	updatedNode := node.DeepCopy()
    	updatedNode.Spec.PodCIDRs = expected
    	updatedNode.Spec.PodCIDR = expected[0]
    
    	// start with the new node
    	client := clientsetfake.NewSimpleClientset()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  10. platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/isolated/IsolatedProjectsToolingApiIdeaProjectIntegrationTest.groovy

            and:
            originalUpdatedModel.javaLanguageSettings.languageLevel == JavaVersion.VERSION_11
    
            when:
            executer.withArguments(ENABLE_CLI)
            def updatedModel = fetchModel(IdeaProject)
    
            then:
            fixture.assertStateUpdated {
                fileChanged("a/build.gradle")
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Jun 08 11:29:25 UTC 2024
    - 20.9K bytes
    - Viewed (0)
Back to top