ui.go

package configmap

import (
	"fmt"

	"github.com/sirupsen/logrus"
	"k8s.io/api/core/v1"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

	"github.com/jaegertracing/jaeger-operator/pkg/apis/io/v1alpha1"
)

// UIConfig represents a UI configmap
type UIConfig struct {
	jaeger *v1alpha1.Jaeger
}

// NewUIConfig builds a new UIConfig struct based on the given spec
func NewUIConfig(jaeger *v1alpha1.Jaeger) *UIConfig {
	return &UIConfig{jaeger: jaeger}
}

// Get returns a configmap specification for the current instance
func (u *UIConfig) Get() *v1.ConfigMap {
	// Check for empty map
	if u.jaeger.Spec.UI.Options.IsEmpty() {
		return nil
	}

	json, err := u.jaeger.Spec.UI.Options.MarshalJSON()
	if err != nil {
		return nil
	}

	logrus.Debug("Assembling the UI configmap")
	trueVar := true
	data := map[string]string{
		"ui": string(json),
	}

	return &v1.ConfigMap{
		TypeMeta: metav1.TypeMeta{
			APIVersion: "v1",
			Kind:       "ConfigMap",
		},
		ObjectMeta: metav1.ObjectMeta{
			Name:      fmt.Sprintf("%s-ui-configuration", u.jaeger.Name),
			Namespace: u.jaeger.Namespace,
			OwnerReferences: []metav1.OwnerReference{
				metav1.OwnerReference{
					APIVersion: u.jaeger.APIVersion,
					Kind:       u.jaeger.Kind,
					Name:       u.jaeger.Name,
					UID:        u.jaeger.UID,
					Controller: &trueVar,
				},
			},
		},
		Data: data,
	}
}

// Update will modify the supplied common spec and options to include
// support for the UI configmap if appropriate
func Update(jaeger *v1alpha1.Jaeger, commonSpec *v1alpha1.JaegerCommonSpec, options *[]string) {
	// Check for empty map
	if jaeger.Spec.UI.Options.IsEmpty() {
		return
	}

	volume := v1.Volume{
		Name: fmt.Sprintf("%s-ui-configuration-volume", jaeger.Name),
		VolumeSource: v1.VolumeSource{
			ConfigMap: &v1.ConfigMapVolumeSource{
				LocalObjectReference: v1.LocalObjectReference{
					Name: fmt.Sprintf("%s-ui-configuration", jaeger.Name),
				},
				Items: []v1.KeyToPath{
					v1.KeyToPath{
						Key:  "ui",
						Path: "ui.json",
					},
				},
			},
		},
	}
	volumeMount := v1.VolumeMount{
		Name:      fmt.Sprintf("%s-ui-configuration-volume", jaeger.Name),
		MountPath: "/etc/config",
		ReadOnly:  true,
	}
	commonSpec.Volumes = append(commonSpec.Volumes, volume)
	commonSpec.VolumeMounts = append(commonSpec.VolumeMounts, volumeMount)
	*options = append(*options, "--query.ui-config=/etc/config/ui.json")
}