Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for newNode (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pkg/controller/controller_utils.go

    		if err != nil {
    			return err
    		}
    
    		// Make a copy of the node and update the labels.
    		newNode := node.DeepCopy()
    		if newNode.Labels == nil {
    			newNode.Labels = make(map[string]string)
    		}
    		for key, value := range labelsToUpdate {
    			newNode.Labels[key] = value
    		}
    
    		oldData, err := json.Marshal(node)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  10. 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)
Back to top