Proposal/Feature add flag --skip-empty-annotation to honor only annotated resources.

cli/ingress-controller/flags.go

@@ -59,9 +59,10 @@ type cliConfig struct {
 	KongCustomEntitiesSecret string
 
 	// Resource filtering
-	WatchNamespace string
-	IngressClass   string
-	ElectionID     string
+	WatchNamespace              string
+	SkipClasslessIngressV1beta1 bool
+	IngressClass                string
+	ElectionID                  string
 
 	// Ingress Status publish resource
 	PublishService         string
@@ -175,6 +176,8 @@ mode of Kong. Takes the form of namespace/name.`)
 	// Resource filtering
 	flags.String("watch-namespace", apiv1.NamespaceAll,
 		`Namespace to watch for Ingress. Default is to watch all namespaces`)
+	flags.Bool("skip-classless-ingress-v1beta1", false,
+		`Skip non annotated Ingresses and Kong CRDs.`)
 	flags.String("ingress-class", annotations.DefaultIngressClass,
 		`Name of the ingress class to route through this controller.`)
 	flags.String("election-id", "ingress-controller-leader",
@@ -320,6 +323,7 @@ func parseFlags() (cliConfig, error) {
 
 	// Resource filtering
 	config.WatchNamespace = viper.GetString("watch-namespace")
+	config.SkipClasslessIngressV1beta1 = viper.GetBool("skip-classless-ingress-v1beta1")
 	config.IngressClass = viper.GetString("ingress-class")
 	config.ElectionID = viper.GetString("election-id")
 

cli/ingress-controller/main.go

@@ -286,8 +286,10 @@ func main() {
 	var synced []cache.InformerSynced
 	updateChannel := channels.NewRingChannel(1024)
 	reh := controller.ResourceEventHandler{
-		UpdateCh:           updateChannel,
-		IsValidIngresClass: annotations.IngressClassValidatorFunc(cliConfig.IngressClass),
+		UpdateCh: updateChannel,
+		IsValidIngresClass: annotations.IngressClassValidatorFunc(
+			cliConfig.IngressClass,
+			cliConfig.SkipClasslessIngressV1beta1),
 	}
 	var informers []cache.SharedIndexInformer
 	var cacheStores store.CacheStores
@@ -366,7 +368,7 @@ func main() {
 		runtime.HandleError(fmt.Errorf("Timed out waiting for caches to sync"))
 	}
 
-	store := store.New(cacheStores, cliConfig.IngressClass)
+	store := store.New(cacheStores, cliConfig.IngressClass, cliConfig.SkipClasslessIngressV1beta1)
 	kong, err := controller.NewKongController(&controllerConfig, updateChannel,
 		store)
 	if err != nil {

cli/ingress-controller/main_test.go

@@ -76,7 +76,7 @@ func TestHandleSigterm(t *testing.T) {
 			KubeClient: kubeClient,
 		},
 		channels.NewRingChannel(1024),
-		store.New(store.CacheStores{}, conf.IngressClass),
+		store.New(store.CacheStores{}, conf.IngressClass, conf.SkipClasslessIngressV1beta1),
 	)
 
 	exitCh := make(chan int, 1)

internal/ingress/annotations/annotations.go

@@ -49,15 +49,15 @@ const (
 	DefaultIngressClass = "kong"
 )
 
-func validIngress(ingressAnnotationValue, ingressClass string) bool {
+func validIngress(ingressAnnotationValue, ingressClass string, skipClasslessIngress bool) bool {
 	// we have 2 valid combinations
 	// 1 - ingress with default class | blank annotation on ingress
 	// 2 - ingress with specific class | same annotation on ingress
 	//
 	// and 2 invalid combinations
 	// 3 - ingress with default class | fixed annotation on ingress
 	// 4 - ingress with specific class | different annotation on ingress
-	if ingressAnnotationValue == "" && ingressClass == DefaultIngressClass {
+	if ingressAnnotationValue == "" && !skipClasslessIngress && ingressClass == DefaultIngressClass {
 		return true
 	}
 	return ingressAnnotationValue == ingressClass
@@ -66,22 +66,22 @@ func validIngress(ingressAnnotationValue, ingressClass string) bool {
 // IngressClassValidatorFunc returns a function which can validate if an Object
 // belongs to an the ingressClass or not.
 func IngressClassValidatorFunc(
-	ingressClass string) func(obj metav1.Object) bool {
+	ingressClass string, skipClasslessIngress bool) func(obj metav1.Object) bool {
 
 	return func(obj metav1.Object) bool {
 		ingress := obj.GetAnnotations()[ingressClassKey]
-		return validIngress(ingress, ingressClass)
+		return validIngress(ingress, ingressClass, skipClasslessIngress)
 	}
 }
 
 // IngressClassValidatorFuncFromObjectMeta returns a function which
 // can validate if an ObjectMeta belongs to an the ingressClass or not.
 func IngressClassValidatorFuncFromObjectMeta(
-	ingressClass string) func(obj *metav1.ObjectMeta) bool {
+	ingressClass string, skipClasslessIngress bool) func(obj *metav1.ObjectMeta) bool {
 
 	return func(obj *metav1.ObjectMeta) bool {
 		ingress := obj.GetAnnotations()[ingressClassKey]
-		return validIngress(ingress, ingressClass)
+		return validIngress(ingress, ingressClass, skipClasslessIngress)
 	}
 }
 

internal/ingress/annotations/annotations_test.go

@@ -27,16 +27,21 @@ import (
 
 func TestIngressClassValidatorFunc(t *testing.T) {
 	tests := []struct {
-		ingress    string
-		controller string
-		isValid    bool
+		ingress              string
+		skipClasslessIngress bool
+		controller           string
+		isValid              bool
 	}{
-		{"", "", true},
-		{"", "kong", true},
-		{"kong", "kong", true},
-		{"custom", "custom", true},
-		{"", "killer", false},
-		{"custom", "kong", false},
+		{"", false, "", true},
+		{"", false, "kong", true},
+		{"", true, "kong", false},
+		{"kong", false, "kong", true},
+		{"kong", true, "kong", true},
+		{"custom", false, "custom", true},
+		{"", false, "killer", false},
+		{"custom", false, "kong", false},
+		{"custom", true, "kong", false},
+		{"", true, "custom", false},
 	}
 
 	ing := &extensions.Ingress{
@@ -50,7 +55,7 @@ func TestIngressClassValidatorFunc(t *testing.T) {
 	ing.SetAnnotations(data)
 	for _, test := range tests {
 		ing.Annotations[ingressClassKey] = test.ingress
-		f := IngressClassValidatorFunc(test.controller)
+		f := IngressClassValidatorFunc(test.controller, test.skipClasslessIngress)
 		b := f(&ing.ObjectMeta)
 		if b != test.isValid {
 			t.Errorf("test %v - expected %v but %v was returned", test, test.isValid, b)

internal/ingress/store/fake_store.go

@@ -140,7 +140,7 @@ func NewFakeStore(
 
 			KnativeIngress: knativeIngressStore,
 		},
-		isValidIngresClass: annotations.IngressClassValidatorFuncFromObjectMeta("kong"),
+		isValidIngresClass: annotations.IngressClassValidatorFuncFromObjectMeta("kong", false),
 	}
 	return s, nil
 }

internal/ingress/store/store.go

@@ -82,6 +82,8 @@ type Store struct {
 
 	ingressClass string
 
+	skipClasslessIngress bool
+
 	isValidIngresClass func(objectMeta *metav1.ObjectMeta) bool
 }
 
@@ -104,11 +106,12 @@ type CacheStores struct {
 }
 
 // New creates a new object store to be used in the ingress controller
-func New(cs CacheStores, ingressClass string) Storer {
+func New(cs CacheStores, ingressClass string, skipClasslessIngress bool) Storer {
 	return Store{
-		stores:             cs,
-		ingressClass:       ingressClass,
-		isValidIngresClass: annotations.IngressClassValidatorFuncFromObjectMeta(ingressClass),
+		stores:               cs,
+		ingressClass:         ingressClass,
+		skipClasslessIngress: skipClasslessIngress,
+		isValidIngresClass:   annotations.IngressClassValidatorFuncFromObjectMeta(ingressClass, skipClasslessIngress),
 	}
 }