fixes #1568 #2225

config/rbac/role.yaml

@@ -221,6 +221,7 @@ rules:
 - apiGroups:
   - networking.k8s.io
   resources:
+  - ingressclasses
   - ingresses
   verbs:
   - create

controllers/jaegertracing/jaeger_controller.go

@@ -48,7 +48,7 @@ func NewReconciler(client client.Client, clientReader client.Reader, scheme *run
 // +kubebuilder:rbac:groups=apps,resources=deployments;daemonsets;replicasets;statefulsets,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=extensions,resources=ingresses,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=autoscaling,resources=horizontalpodautoscalers,verbs=get;list;watch;create;update;patch;delete
-// +kubebuilder:rbac:groups=networking.k8s.io,resources=ingresses,verbs=get;list;watch;create;update;patch;delete
+// +kubebuilder:rbac:groups=networking.k8s.io,resources=ingresses;ingressclasses,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=route.openshift.io,resources=routes,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=console.openshift.io,resources=consolelinks,verbs=get;list;watch;create;update;patch;delete
 // +kubebuilder:rbac:groups=batch,resources=jobs;cronjobs,verbs=get;list;watch;create;update;patch;delete

pkg/ingress/query.go

@@ -1,14 +1,16 @@
 package ingress
 
 import (
+	"context"
 	"fmt"
 
-	networkingv1 "k8s.io/api/networking/v1"
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-
 	v1 "github.com/jaegertracing/jaeger-operator/apis/v1"
 	"github.com/jaegertracing/jaeger-operator/pkg/service"
 	"github.com/jaegertracing/jaeger-operator/pkg/util"
+	networkingv1 "k8s.io/api/networking/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
 )
 
 // QueryIngress builds pods for jaegertracing/jaeger-query
@@ -52,6 +54,11 @@ func (i *QueryIngress) Get() *networkingv1.Ingress {
 
 	if i.jaeger.Spec.Ingress.IngressClassName != nil {
 		spec.IngressClassName = i.jaeger.Spec.Ingress.IngressClassName
+	} else {
+		ingressClass, err := getInClusterAvailableIngressClasses()
+		if err == nil {
+			spec.IngressClassName = &ingressClass
+		}
 	}
 
 	return &networkingv1.Ingress{
@@ -150,3 +157,39 @@ func getRule(host string, path string, pathType *networkingv1.PathType, backend
 	}
 	return rule
 }
+
+func getInClusterAvailableIngressClasses() (string, error) {
+	ingressClass := ""
+	nginxIngressAvailable := false
+	config, err := rest.InClusterConfig()
+	if err != nil {
+		return "", err
+	}
+	clientSet, err := kubernetes.NewForConfig(config)
+	if err != nil {
+		return "", err
+	}
+	ingressList, err := clientSet.NetworkingV1().IngressClasses().List(context.Background(), metav1.ListOptions{})
+	if err != nil {
+		return "", err
+	}
+	for _, ingress := range ingressList.Items {
+		if ingress.Name == "nginx" {
+			nginxIngressAvailable = true
+		}
+		for k, v := range ingress.Annotations {
+			if k == "ingressclass.kubernetes.io/is-default-class" {
+				if v == "true" {
+					ingressClass = ingress.Name
+					break
+				}
+			}
+		}
+	}
+	if len(ingressClass) > 0 {
+		return ingressClass, nil
+	} else if nginxIngressAvailable {
+		return "nginx", nil
+	}
+	return "", fmt.Errorf("no available ingress controller found")
+}

pkg/ingress/query_test.go

@@ -1,6 +1,10 @@
 package ingress
 
 import (
+	"context"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
 	"testing"
 
 	"github.com/stretchr/testify/assert"
@@ -288,6 +292,67 @@ func TestQueryIngressClass(t *testing.T) {
 	assert.NotNil(t, dep.Spec.IngressClassName)
 	assert.Equal(t, "nginx", *dep.Spec.IngressClassName)
 	assert.Nil(t, ingressNoClass.Get().Spec.IngressClassName)
+
+}
+
+func TestForDefaultIngressClass(t *testing.T) {
+	jaegerNoIngressNoClass := v1.NewJaeger(types.NamespacedName{Name: "TestQueryIngressNoClass"})
+
+	// for storing all ingress controller names installed inside cluster
+	AvailableIngressController := make(map[string]bool)
+
+	config, err := rest.InClusterConfig()
+	if err != nil {
+		t.Fatalf("%v", err)
+	}
+	clientSet, err := kubernetes.NewForConfig(config)
+	if err != nil {
+		t.Fatalf("%v", err)
+	}
+	ingressList, err := clientSet.NetworkingV1().IngressClasses().List(context.Background(), metav1.ListOptions{})
+	if err != nil {
+		t.Fatalf("%v", err)
+	}
+
+	// check for all available ingress controller installed in cluster
+	for _, ingress := range ingressList.Items {
+		AvailableIngressController[ingress.Name] = false
+		for k, v := range ingress.Annotations {
+			if k == "ingressclass.kubernetes.io/is-default-class" {
+				if v == "true" {
+					AvailableIngressController[ingress.Name] = true
+				}
+			}
+		}
+	}
+
+	getIngressClass, err := getInClusterAvailableIngressClasses()
+	if err != nil {
+		if len(AvailableIngressController) > 0 {
+			t.Fatalf("%v", err)
+		} else {
+			ingressNoClass := NewQueryIngress(jaegerNoIngressNoClass)
+			assert.Nil(t, ingressNoClass.Get().Spec.IngressClassName)
+		}
+	} else {
+		jaegerNoIngressNoClass.Spec.Ingress.IngressClassName = &getIngressClass
+	}
+
+	ingressNoClass := NewQueryIngress(jaegerNoIngressNoClass)
+
+	dep := ingressNoClass.Get()
+
+	defaultIngressClass := getDefaultIngressController(AvailableIngressController)
+	if len(defaultIngressClass) > 0 {
+		assert.Equal(t, defaultIngressClass, *dep.Spec.IngressClassName)
+	} else {
+		if _, ok := AvailableIngressController["nginx"]; ok {
+			assert.Equal(t, "nginx", *dep.Spec.IngressClassName)
+		} else {
+			ingressNoClass := NewQueryIngress(jaegerNoIngressNoClass)
+			assert.Nil(t, ingressNoClass.Get().Spec.IngressClassName)
+		}
+	}
 }
 
 func TestQueryIngressTLSHosts(t *testing.T) {
@@ -312,3 +377,12 @@ func TestQueryIngressTLSHosts(t *testing.T) {
 	assert.Equal(t, "test-host-2", dep.Spec.TLS[1].Hosts[0])
 	assert.Equal(t, "test-host-3", dep.Spec.TLS[1].Hosts[1])
 }
+
+func getDefaultIngressController(m map[string]bool) string {
+	for key, value := range m {
+		if value {
+			return key
+		}
+	}
+	return "" // return an empty string if no key has a true value
+}