- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for updatedNodes (0.26 sec)
-
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) -
pkg/controller/controller_utils_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
st.MakePod().Name("p3").Namespace("ns4").Annotation("annot2", "val2").Annotation("annot3", "val3").NominatedNodeName("node1").Obj(), } var updatedPods = make([]*v1.Pod, len(pods)) updatedPods[0] = pods[0].DeepCopy() updatedPods[1] = pods[1].DeepCopy() updatedPods[3] = pods[3].DeepCopy() tests := []struct { name string podsToAdd []*v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)