Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for TaintExists (0.56 sec)

  1. cmd/kubeadm/app/phases/markcontrolplane/markcontrolplane.go

    	})
    }
    
    func taintExists(taint v1.Taint, taints []v1.Taint) bool {
    	for _, t := range taints {
    		if t == taint {
    			return true
    		}
    	}
    
    	return false
    }
    
    func markControlPlaneNode(n *v1.Node, taints []v1.Taint) {
    	for _, label := range labelsToAdd {
    		n.ObjectMeta.Labels[label] = ""
    	}
    
    	for _, nt := range n.Spec.Taints {
    		if !taintExists(nt, taints) {
    			taints = append(taints, nt)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jan 13 15:45:54 UTC 2022
    - 2K bytes
    - Viewed (0)
  2. pkg/util/taints/taints.go

    	}
    
    	if !updated {
    		newTaints = append(newTaints, *taint)
    	}
    
    	newNode.Spec.Taints = newTaints
    	return newNode, true, nil
    }
    
    // TaintExists checks if the given taint exists in list of taints. Returns true if exists false otherwise.
    func TaintExists(taints []v1.Taint, taintToFind *v1.Taint) bool {
    	for _, taint := range taints {
    		if taint.MatchTaint(taintToFind) {
    			return true
    		}
    	}
    	return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 16 09:23:35 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  3. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    		return
    	}
    	if !taintutils.TaintExists(node0.Spec.Taints, UnreachableTaintTemplate) {
    		t.Errorf("Can't find taint %v in %v", originalTaint, node0.Spec.Taints)
    	}
    	node2, err := fakeNodeHandler.Get(ctx, "node2", metav1.GetOptions{})
    	if err != nil {
    		t.Errorf("Can't get current node2...")
    		return
    	}
    	if !taintutils.TaintExists(node2.Spec.Taints, NotReadyTaintTemplate) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
  4. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    	nc.evictorLock.Lock()
    	defer nc.evictorLock.Unlock()
    	if status == v1.ConditionFalse {
    		if !taintutils.TaintExists(node.Spec.Taints, NotReadyTaintTemplate) {
    			nc.zoneNoExecuteTainter[nodetopology.GetZoneKey(node)].Remove(node.Name)
    		}
    	}
    
    	if status == v1.ConditionUnknown {
    		if !taintutils.TaintExists(node.Spec.Taints, UnreachableTaintTemplate) {
    			nc.zoneNoExecuteTainter[nodetopology.GetZoneKey(node)].Remove(node.Name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  5. pkg/util/taints/taints_test.go

    			name:           "different effect",
    			taintToFind:    &v1.Taint{Key: "foo_1", Value: "bar_1", Effect: v1.TaintEffectNoSchedule},
    			expectedResult: false,
    		},
    	}
    
    	for _, c := range cases {
    		result := TaintExists(testingTaints, c.taintToFind)
    
    		if result != c.expectedResult {
    			t.Errorf("[%s] unexpected results: %v", c.name, result)
    			continue
    		}
    	}
    }
    
    func TestTaintKeyExists(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 16 09:23:35 UTC 2022
    - 22.6K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_node_status.go

    		Effect: v1.TaintEffectNoSchedule,
    	}
    
    	// Taint node with TaintNodeUnschedulable when initializing
    	// node to avoid race condition; refer to #63897 for more detail.
    	if node.Spec.Unschedulable &&
    		!taintutil.TaintExists(nodeTaints, &unschedulableTaint) {
    		nodeTaints = append(nodeTaints, unschedulableTaint)
    	}
    
    	if kl.externalCloudProvider {
    		taint := v1.Taint{
    			Key:    cloudproviderapi.TaintExternalCloudProvider,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  7. pkg/controller/controller_utils.go

    	if len(taints) == 0 {
    		return nil
    	}
    	// Short circuit for limiting amount of API calls.
    	if node != nil {
    		match := false
    		for _, taint := range taints {
    			if taintutils.TaintExists(node.Spec.Taints, taint) {
    				match = true
    				break
    			}
    		}
    		if !match {
    			return nil
    		}
    	}
    
    	firstTry := true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_node_status_test.go

    	got := gotNode.(*v1.Node)
    	unschedulableTaint := &v1.Taint{
    		Key:    v1.TaintNodeUnschedulable,
    		Effect: v1.TaintEffectNoSchedule,
    	}
    
    	require.Equal(t,
    		true,
    		taintutil.TaintExists(got.Spec.Taints, unschedulableTaint),
    		"test unschedulable taint for TaintNodesByCondition")
    }
    
    func TestNodeStatusHasChanged(t *testing.T) {
    	fakeNow := metav1.Date(2015, 1, 1, 12, 0, 0, 0, time.UTC)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 08 19:23:19 UTC 2024
    - 115.8K bytes
    - Viewed (0)
Back to top