node: support ignore by terway label

Signed-off-by: l1b0k <[email protected]>

pkg/controller/node/predict.go

@@ -23,6 +23,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/predicate"
 
 	"github.com/AliyunContainerService/terway/pkg/utils"
+	"github.com/AliyunContainerService/terway/types"
 )
 
 type predicateForNodeEvent struct {
@@ -59,6 +60,10 @@ func predicateNode(o client.Object) bool {
 		return false
 	}
 
+	if types.IgnoredByTerway(node.Labels) {
+		return false
+	}
+
 	return isECSNode(node)
 }
 

pkg/controller/node/predict_test.go

@@ -98,6 +98,20 @@ func Test_predicateNode(t *testing.T) {
 			},
 			want: true,
 		},
+		{
+			name: "normal node but has exclude rule",
+			args: args{
+				o: &corev1.Node{
+					ObjectMeta: metav1.ObjectMeta{
+						Labels: map[string]string{
+							"topology.kubernetes.io/region":   "cn-hangzhou",
+							"k8s.aliyun.com/ignore-by-terway": "true",
+						},
+					},
+				},
+			},
+			want: false,
+		},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {