Add link to openshift console

pkg/consolelink/main.go

@@ -0,0 +1,66 @@
+package consolelink
+
+import (
+	"fmt"
+
+	consolev1 "github.com/openshift/api/console/v1"
+	routev1 "github.com/openshift/api/route/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+
+	v1 "github.com/jaegertracing/jaeger-operator/pkg/apis/jaegertracing/v1"
+)
+
+// RouteAnnotation used to annotate the link with the route name
+var RouteAnnotation = "consolelink.jaegertracing.io/route"
+
+// Get returns an ConsoleLink specification for the current instance
+func Get(jaeger *v1.Jaeger, route *routev1.Route) *consolev1.ConsoleLink {
+	// If ingress is not enable there is no reason for create a console link
+	if jaeger.Spec.Ingress.Enabled != nil && *jaeger.Spec.Ingress.Enabled == false {
+		return nil
+	}
+
+	return &consolev1.ConsoleLink{
+		ObjectMeta: metav1.ObjectMeta{
+			Name:      jaeger.Namespace + ".jaeger-consolelink-" + jaeger.Name,
+			Namespace: jaeger.Namespace,
+			Labels: map[string]string{
+				"app.kubernetes.io/instance":   jaeger.Name,
+				"app.kubernetes.io/managed-by": "jaeger-operator",
+			},
+			Annotations: map[string]string{
+				RouteAnnotation: route.Name,
+			},
+		},
+		Spec: consolev1.ConsoleLinkSpec{
+			Location: consolev1.NamespaceDashboard,
+			Link: consolev1.Link{
+				Text: "Jaeger [" + jaeger.Name + "]",
+			},
+			NamespaceDashboard: &consolev1.NamespaceDashboardSpec{
+				Namespaces: []string{
+					jaeger.Namespace,
+				},
+			},
+		},
+	}
+}
+
+// UpdateHref returns an ConsoleLink with the href value derived from the route
+func UpdateHref(routes []routev1.Route, links []consolev1.ConsoleLink) []consolev1.ConsoleLink {
+	var updated []consolev1.ConsoleLink
+	mapRoutes := make(map[string]string)
+	for _, route := range routes {
+		mapRoutes[route.Name] = route.Spec.Host
+	}
+	for _, cl := range links {
+		routeName := cl.Annotations[RouteAnnotation]
+		// Only append it if we can found the route
+		if host, ok := mapRoutes[routeName]; ok {
+			cl.Spec.Href = fmt.Sprintf("https://%s", host)
+			updated = append(updated, cl)
+		}
+		//TODO: log if not found the route associated with the link
+	}
+	return updated
+}

pkg/consolelink/main_test.go

@@ -0,0 +1,58 @@
+package consolelink
+
+import (
+	"testing"
+
+	consolev1 "github.com/openshift/api/console/v1"
+	corev1 "github.com/openshift/api/route/v1"
+	"github.com/stretchr/testify/assert"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/types"
+
+	v1 "github.com/jaegertracing/jaeger-operator/pkg/apis/jaegertracing/v1"
+)
+
+func TestConsoleLinkGet(t *testing.T) {
+	jaegerName := "TestConsoleLinkJaeger"
+	jaegerNamespace := "TestNS"
+	routerNamer := "TestConsoleLinkRoute"
+
+	jaeger := v1.NewJaeger(types.NamespacedName{Name: jaegerName, Namespace: jaegerNamespace})
+	route := &corev1.Route{
+		TypeMeta: metav1.TypeMeta{
+			Kind:       "Route",
+			APIVersion: "route.openshift.io/v1",
+		},
+		ObjectMeta: metav1.ObjectMeta{
+			Name: routerNamer,
+		},
+	}
+
+	link := Get(jaeger, route)
+	assert.Equal(t, jaeger.Namespace+".jaeger-consolelink-"+jaeger.Name, link.Name)
+	assert.Contains(t, link.Annotations, RouteAnnotation)
+	assert.Equal(t, routerNamer, link.Annotations[RouteAnnotation])
+}
+
+func TestUpdateHref(t *testing.T) {
+	jaegerName := "TestConsoleLinkJaeger"
+	jaegerNamespace := "TestNS"
+	routerNamer := "TestConsoleLinkRoute"
+	jaeger := v1.NewJaeger(types.NamespacedName{Name: jaegerName, Namespace: jaegerNamespace})
+	route := corev1.Route{
+		TypeMeta: metav1.TypeMeta{
+			Kind:       "Route",
+			APIVersion: "route.openshift.io/v1",
+		},
+		ObjectMeta: metav1.ObjectMeta{
+			Name: routerNamer,
+		},
+	}
+
+	link := Get(jaeger, &route)
+	assert.Equal(t, link.Spec.Href, "")
+	route.Spec.Host = "namespace.somehostname"
+	newLinks := UpdateHref([]corev1.Route{route}, []consolev1.ConsoleLink{*link})
+	assert.Equal(t, "https://"+route.Spec.Host, newLinks[0].Spec.Href)
+
+}

pkg/controller/controller.go

@@ -1,6 +1,7 @@
 package controller
 
 import (
+	consolev1 "github.com/openshift/api/console/v1"
 	routev1 "github.com/openshift/api/route/v1"
 	"sigs.k8s.io/controller-runtime/pkg/manager"
 
@@ -17,6 +18,10 @@ func AddToManager(m manager.Manager) error {
 		return err
 	}
 
+	if err := consolev1.Install(m.GetScheme()); err != nil {
+		return err
+	}
+
 	// Registry just the ImageStream - adding osimagev1.AddToScheme(..) causes
 	// the SecretList to be registered again, which resulted in
 	// https://github.com/kubernetes-sigs/controller-runtime/issues/362

pkg/controller/jaeger/consolelink.go

@@ -0,0 +1,65 @@
+package jaeger
+
+import (
+	"context"
+
+	osconsolev1 "github.com/openshift/api/console/v1"
+	log "github.com/sirupsen/logrus"
+	"go.opentelemetry.io/otel/global"
+	"sigs.k8s.io/controller-runtime/pkg/client"
+
+	v1 "github.com/jaegertracing/jaeger-operator/pkg/apis/jaegertracing/v1"
+	"github.com/jaegertracing/jaeger-operator/pkg/inventory"
+	"github.com/jaegertracing/jaeger-operator/pkg/tracing"
+)
+
+func (r *ReconcileJaeger) applyConsoleLinks(ctx context.Context, jaeger v1.Jaeger, desired []osconsolev1.ConsoleLink) error {
+	tracer := global.TraceProvider().GetTracer(v1.ReconciliationTracer)
+	ctx, span := tracer.Start(ctx, "applyConsoleLinks")
+	defer span.End()
+
+	opts := []client.ListOption{
+		client.InNamespace(jaeger.Namespace),
+		client.MatchingLabels(map[string]string{
+			"app.kubernetes.io/instance":   jaeger.Name,
+			"app.kubernetes.io/managed-by": "jaeger-operator",
+		}),
+	}
+	list := &osconsolev1.ConsoleLinkList{}
+	if err := r.rClient.List(ctx, list, opts...); err != nil {
+		return tracing.HandleError(err, span)
+	}
+
+	inv := inventory.ForConsoleLinks(list.Items, desired)
+	for _, d := range inv.Create {
+		jaeger.Logger().WithFields(log.Fields{
+			"consoleLink": d.Name,
+			"namespace":   d.Namespace,
+		}).Debug("creating console link")
+		if err := r.client.Create(ctx, &d); err != nil {
+			return tracing.HandleError(err, span)
+		}
+	}
+
+	for _, d := range inv.Update {
+		jaeger.Logger().WithFields(log.Fields{
+			"consoleLink": d.Name,
+			"namespace":   d.Namespace,
+		}).Debug("updating console link")
+		if err := r.client.Update(ctx, &d); err != nil {
+			return tracing.HandleError(err, span)
+		}
+	}
+
+	for _, d := range inv.Delete {
+		jaeger.Logger().WithFields(log.Fields{
+			"consoleLink": d.Name,
+			"namespace":   d.Namespace,
+		}).Debug("deleting console link")
+		if err := r.client.Delete(ctx, &d); err != nil {
+			return tracing.HandleError(err, span)
+		}
+	}
+
+	return nil
+}