- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for newNode (0.11 sec)
-
pkg/controller/tainteviction/taint_eviction_test.go
newNode: addTaintsToNode(testutil.NewNode("node1"), "testTaint1", "taint1", []int{1}), expectPatch: true, expectDelete: true, }, { description: "new pod2 created on tainted Node", pods: []corev1.Pod{ *testutil.NewPod("pod1", "node1"), }, prevPod: nil, newPod: testutil.NewPod("pod2", "node1"), oldNode: testutil.NewNode("node1"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
} func nodeLabelsChanged(newNode *v1.Node, oldNode *v1.Node) bool { return !equality.Semantic.DeepEqual(oldNode.GetLabels(), newNode.GetLabels()) } func nodeTaintsChanged(newNode *v1.Node, oldNode *v1.Node) bool { return !equality.Semantic.DeepEqual(newNode.Spec.Taints, oldNode.Spec.Taints) } func nodeConditionsChanged(newNode *v1.Node, oldNode *v1.Node) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
patchedPodNames sets.Set[string] enablePodDisruptionConditions bool }{ { name: "nodes present in lister", initialInformerNodes: []*v1.Node{ testutil.NewNode("existing1"), testutil.NewNode("existing2"), }, delay: 2 * quarantineTime, pods: []*v1.Pod{ makePod("a", "existing1", v1.PodRunning), makePod("b", "existing2", v1.PodFailed),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
func (tc *Controller) NodeUpdated(oldNode *v1.Node, newNode *v1.Node) { nodeName := "" oldTaints := []v1.Taint{} if oldNode != nil { nodeName = oldNode.Name oldTaints = getNoExecuteTaints(oldNode.Spec.Taints) } newTaints := []v1.Taint{} if newNode != nil { nodeName = newNode.Name newTaints = getNoExecuteTaints(newNode.Spec.Taints) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
newPod1 := controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1") attachDetachRecoveryTestCase(t, []*v1.Pod{newPod1}, []*v1.Pod{}) newPod1 = controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1") attachDetachRecoveryTestCase(t, []*v1.Pod{}, []*v1.Pod{newPod1}) newPod1 = controllervolumetesting.NewPodWithVolume("newpod-1", "volumeName2", "mynode-1")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/controller/testutil/test_utils.go
return &FakeRecorder{ source: v1.EventSource{Component: "nodeControllerTest"}, Events: []*v1.Event{}, clock: testingclock.NewFakeClock(time.Now()), } } // NewNode is a helper function for creating Nodes for testing. func NewNode(name string) *v1.Node { return &v1.Node{ ObjectMeta: metav1.ObjectMeta{Name: name}, Status: v1.NodeStatus{ Capacity: v1.ResourceList{
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/volume/csi/nodeinfomanager/nodeinfomanager.go
if err != nil { return err } node := originalNode.DeepCopy() needUpdate := false for _, update := range updateFuncs { newNode, updated, err := update(node) if err != nil { return err } node = newNode needUpdate = needUpdate || updated } if needUpdate { // PatchNodeStatus can update both node's status and labels or annotations
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
tensorflow/compiler/jit/xla_cluster_util.cc
for (int i = 0; i < graph->num_node_ids(); ++i) { // We rely on the node IDs in the cycle detection graph being consecutive // integers starting from 0. CHECK_EQ(i, cycles->NewNode()); } // Compute the loop structure of the graph. std::vector<ControlFlowInfo> control_flow_info; TF_RETURN_IF_ERROR(BuildControlFlowInfo(graph, &control_flow_info));
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 29 08:39:39 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
newNode := &node{ identity: identityFromEvent(event, accessor), dependents: make(map[*node]struct{}), owners: accessor.GetOwnerReferences(), deletingDependents: beingDeleted(accessor) && hasDeleteDependentsFinalizer(accessor), beingDeleted: beingDeleted(accessor), } gb.insertNode(logger, newNode)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
testing/smoke-test/src/smokeTest/groovy/org/gradle/smoketests/AbstractSmokeTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 08:14:32 UTC 2024 - 13.3K bytes - Viewed (0)