fixes jaegertracing#1568 jaegertracing#2225

added function getIngressClass which set default or nginx ingress class to jaeger define ingress for providing loadbalancer IP.

Signed-off-by: Gaurav Singh <gauravsinghbr@hotmail.com>

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,8 +1,12 @@
 package ingress
 
 import (
+	"context"
 	"fmt"
 
+	"k8s.io/client-go/kubernetes"
+	"k8s.io/client-go/rest"
+
 	networkingv1 "k8s.io/api/networking/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
@@ -52,6 +56,11 @@ func (i *QueryIngress) Get() *networkingv1.Ingress {
 
 	if i.jaeger.Spec.Ingress.IngressClassName != nil {
 		spec.IngressClassName = i.jaeger.Spec.Ingress.IngressClassName
+	} else {
+		ingressClass, err := getIngressClass()
+		if !err {
+			spec.IngressClassName = &ingressClass
+		}
 	}
 
 	return &networkingv1.Ingress{
@@ -150,3 +159,39 @@ func getRule(host string, path string, pathType *networkingv1.PathType, backend
 	}
 	return rule
 }
+
+func getIngressClass() (string, bool) {
+	ingressClass := ""
+	nginxIngressAvailable := false
+	config, err := rest.InClusterConfig()
+	if err != nil {
+		return "", true
+	}
+	clientSet, err := kubernetes.NewForConfig(config)
+	if err != nil {
+		return "", true
+	}
+	ingressList, err := clientSet.NetworkingV1().IngressClasses().List(context.Background(), metav1.ListOptions{})
+	if err != nil {
+		return "", true
+	}
+	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, false
+	} else if nginxIngressAvailable {
+		return "nginx", false
+	}
+	return "", true
+}