- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for TaintExists (0.56 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)