- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 49 for newNode (0.17 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/scheduler/framework/plugins/podtopologyspread/plugin_test.go
pod *v1.Pod oldNode, newNode *v1.Node expectedHint framework.QueueingHint expectedErr bool }{ { name: "node updates label which matches topologyKey", pod: st.MakePod().Name("p").SpreadConstraint(1, "zone", v1.DoNotSchedule, fooSelector, nil, nil, nil, nil). Obj(), oldNode: st.MakeNode().Name("node-a").Label("zone", "zone1").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 17 06:30:53 UTC 2023 - 13K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
name string newNode *v1.Node oldNode *v1.Node wantEvents []framework.ClusterEvent }{ { name: "no specific changed applied", newNode: st.MakeNode().Unschedulable(false).Obj(), oldNode: st.MakeNode().Unschedulable(false).Obj(), wantEvents: nil, }, { name: "only node spec unavailable changed", newNode: st.MakeNode().Unschedulable(false).Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K 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) -
platforms/core-execution/snapshots/src/test/groovy/org/gradle/internal/snapshot/AbstractIncompleteFileSystemNodeTest.groovy
def snapshot = Mock(MetadataSnapshot) def newNode = mockChild() when: def resultRoot = initialRoot.store(searchedPath, CASE_SENSITIVE, snapshot, diffListener) then: isSameNodeType(resultRoot) resultRoot.children == childrenWithSelectedChildReplacedBy(newNode) addedNodes == [newNode] removedNodes == [selectedChild]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:34:50 UTC 2023 - 13.3K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/poset.go
po.upush(undoSetChl, i1, i1l) } } } // newnode allocates a new node bound to SSA value n. // If n is nil, this is an extra node (= only used internally). func (po *poset) newnode(n *Value) uint32 { i := po.lastidx + 1 po.lastidx++ po.nodes = append(po.nodes, posetNode{}) if n != nil { if po.values[n.ID] != 0 { panic("newnode for Value already inserted") } po.values[n.ID] = i
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 04 17:23:05 UTC 2023 - 37.2K bytes - Viewed (0) -
pkg/controller/controller_utils.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
} func (cache *cacheImpl) UpdateNode(logger klog.Logger, oldNode, newNode *v1.Node) *framework.NodeInfo { cache.mu.Lock() defer cache.mu.Unlock() n, ok := cache.nodes[newNode.Name] if !ok { n = newNodeInfoListItem(framework.NewNodeInfo()) cache.nodes[newNode.Name] = n cache.nodeTree.addNode(logger, newNode) } else { cache.removeNodeImageStates(n.info.Node()) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0)