feat(client): add support for custom HTTP headers

api/v1beta1/grafana_types.go

@@ -119,6 +119,17 @@ type GrafanaClient struct {
 	// TLS Configuration used to talk with the grafana instance.
 	// +optional
 	TLS *TLSConfig `json:"tls,omitempty"`
+	// Optional list of Header configuration objects that specify headers key and their value.
+	// +optional
+	Headers *[]Header `json:"headers,omitempty"`
+}
+
+// Header specifies http.Header key and value
+type Header struct {
+	// Header name
+	Key string `json:"key,omitempty"`
+	// Header value
+	Value string `json:"value,omitempty"`
 }
 
 // GrafanaPreferences holds Grafana preferences API settings
@@ -138,8 +149,8 @@ type GrafanaStatus struct {
 	Version     string                 `json:"version,omitempty"`
 }
 
-//+kubebuilder:object:root=true
-//+kubebuilder:subresource:status
+// +kubebuilder:object:root=true
+// +kubebuilder:subresource:status
 
 // Grafana is the Schema for the grafanas API
 // +kubebuilder:printcolumn:name="Version",type="string",JSONPath=".status.version",description=""
@@ -154,7 +165,7 @@ type Grafana struct {
 	Status            GrafanaStatus `json:"status,omitempty"`
 }
 
-//+kubebuilder:object:root=true
+// +kubebuilder:object:root=true
 
 // GrafanaList contains a list of Grafana
 type GrafanaList struct {

config/crd/bases/grafana.integreatly.org_grafanas.yaml

@@ -58,6 +58,20 @@ spec:
                 description: Client defines how the grafana-operator talks to the
                   grafana instance.
                 properties:
+                  headers:
+                    description: Optional list of Header configuration objects that
+                      specify headers key and their value.
+                    items:
+                      description: Header specifies http.Header key and value
+                      properties:
+                        key:
+                          description: Header name
+                          type: string
+                        value:
+                          description: Header value
+                          type: string
+                      type: object
+                    type: array
                   preferIngress:
                     description: If the operator should send it's request through
                       the grafana instances ingress object instead of through the

controllers/client/grafana_client.go

@@ -141,6 +141,9 @@ func NewGeneratedGrafanaClient(ctx context.Context, c client.Client, grafana *v1
 	}
 
 	transport := NewInstrumentedRoundTripper(grafana.Name, metrics.GrafanaApiRequests, grafana.IsExternal(), tlsConfig)
+	if grafana.Spec.Client.Headers != nil {
+		transport.(*instrumentedRoundTripper).addHeaders(extractClientHeaders(grafana))
+	}
 
 	client := &http.Client{
 		Transport: transport,
@@ -161,7 +164,21 @@ func NewGeneratedGrafanaClient(ctx context.Context, c client.Client, grafana *v1
 	if credentials.username != "" {
 		cfg.BasicAuth = url.UserPassword(credentials.username, credentials.password)
 	}
+
 	cl := genapi.NewHTTPClientWithConfig(nil, cfg)
 
 	return cl, nil
 }
+
+func extractClientHeaders(grafana *v1beta1.Grafana) map[string]string {
+	if grafana.Spec.Client.Headers == nil {
+		return nil
+	}
+
+	headers := make(map[string]string, len(*grafana.Spec.Client.Headers))
+	for _, h := range *grafana.Spec.Client.Headers {
+		headers[h.Key] = h.Value
+	}
+
+	return headers
+}

controllers/client/http_client.go

@@ -26,8 +26,13 @@ func NewHTTPClient(ctx context.Context, c client.Client, grafana *v1beta1.Grafan
 		return nil, err
 	}
 
+	transport := NewInstrumentedRoundTripper(grafana.Name, metrics.GrafanaApiRequests, grafana.IsExternal(), tlsConfig)
+	if grafana.Spec.Client.Headers != nil {
+		transport.(*instrumentedRoundTripper).addHeaders(extractClientHeaders(grafana))
+	}
+
 	return &http.Client{
-		Transport: NewInstrumentedRoundTripper(grafana.Name, metrics.GrafanaApiRequests, grafana.IsExternal(), tlsConfig),
+		Transport: transport,
 		Timeout:   time.Second * timeout,
 	}, nil
 }

controllers/client/round_tripper.go

@@ -13,6 +13,7 @@ type instrumentedRoundTripper struct {
 	relatedResource string
 	wrapped         http.RoundTripper
 	metric          *prometheus.CounterVec
+	headers         map[string]string
 }
 
 func NewInstrumentedRoundTripper(relatedResource string, metric *prometheus.CounterVec, useProxy bool, tlsConfig *tls.Config) http.RoundTripper {
@@ -33,11 +34,17 @@ func NewInstrumentedRoundTripper(relatedResource string, metric *prometheus.Coun
 		relatedResource: relatedResource,
 		wrapped:         transport,
 		metric:          metric,
+		headers:         map[string]string{"user-agent": "grafana-operator/" + embeds.Version},
 	}
 }
 
 func (in *instrumentedRoundTripper) RoundTrip(r *http.Request) (*http.Response, error) {
-	r.Header.Add("user-agent", "grafana-operator/"+embeds.Version)
+	if in.headers != nil {
+		for k, v := range in.headers {
+			r.Header.Add(k, v)
+		}
+	}
+
 	resp, err := in.wrapped.RoundTrip(r)
 	if resp != nil {
 		in.metric.WithLabelValues(
@@ -48,3 +55,14 @@ func (in *instrumentedRoundTripper) RoundTrip(r *http.Request) (*http.Response,
 	}
 	return resp, err
 }
+
+func (in *instrumentedRoundTripper) addHeaders(headers map[string]string) {
+	if in.headers == nil {
+		in.headers = headers
+		return
+	}
+
+	for k, v := range headers {
+		in.headers[k] = v
+	}
+}

controllers/grafana_controller.go

@@ -56,14 +56,14 @@ type GrafanaReconciler struct {
 	IsOpenShift bool
 }
 
-//+kubebuilder:rbac:groups=grafana.integreatly.org,resources=grafanas,verbs=get;list;watch;create;update;patch;delete
-//+kubebuilder:rbac:groups=grafana.integreatly.org,resources=grafanas/status,verbs=get;update;patch
-//+kubebuilder:rbac:groups=grafana.integreatly.org,resources=grafanas/finalizers,verbs=update
-//+kubebuilder:rbac:groups=route.openshift.io,resources=routes;routes/custom-host,verbs=get;list;create;update;delete;watch
-//+kubebuilder:rbac:groups=apps,resources=deployments,verbs=get;list;watch;create;update;patch;delete
-//+kubebuilder:rbac:groups="",resources=events,verbs=get;list;watch;create;patch
-//+kubebuilder:rbac:groups="",resources=configmaps;secrets;serviceaccounts;services;persistentvolumeclaims,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=grafana.integreatly.org,resources=grafanas,verbs=get;list;watch;create;update;patch;delete
+// +kubebuilder:rbac:groups=grafana.integreatly.org,resources=grafanas/status,verbs=get;update;patch
+// +kubebuilder:rbac:groups=grafana.integreatly.org,resources=grafanas/finalizers,verbs=update
+// +kubebuilder:rbac:groups=route.openshift.io,resources=routes;routes/custom-host,verbs=get;list;create;update;delete;watch
+// +kubebuilder:rbac:groups=apps,resources=deployments,verbs=get;list;watch;create;update;patch;delete
+// +kubebuilder:rbac:groups="",resources=events,verbs=get;list;watch;create;patch
+// +kubebuilder:rbac:groups="",resources=configmaps;secrets;serviceaccounts;services;persistentvolumeclaims,verbs=get;list;watch;create;update;patch;delete
+// +kubebuilder:rbac:groups=networking.k8s.io,resources=ingresses,verbs=get;list;watch;create;update;patch;delete
 
 func (r *GrafanaReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error) {
 	controllerLog := log.FromContext(ctx).WithName("GrafanaReconciler")

deploy/helm/grafana-operator/crds/grafana.integreatly.org_grafanas.yaml

@@ -58,6 +58,20 @@ spec:
                 description: Client defines how the grafana-operator talks to the
                   grafana instance.
                 properties:
+                  headers:
+                    description: Optional list of Header configuration objects that
+                      specify headers key and their value.
+                    items:
+                      description: Header specifies http.Header key and value
+                      properties:
+                        key:
+                          description: Header name
+                          type: string
+                        value:
+                          description: Header value
+                          type: string
+                      type: object
+                    type: array
                   preferIngress:
                     description: If the operator should send it's request through
                       the grafana instances ingress object instead of through the

deploy/kustomize/base/crds.yaml

@@ -1882,6 +1882,20 @@ spec:
                 description: Client defines how the grafana-operator talks to the
                   grafana instance.
                 properties:
+                  headers:
+                    description: Optional list of Header configuration objects that
+                      specify headers key and their value.
+                    items:
+                      description: Header specifies http.Header key and value
+                      properties:
+                        key:
+                          description: Header name
+                          type: string
+                        value:
+                          description: Header value
+                          type: string
+                      type: object
+                    type: array
                   preferIngress:
                     description: If the operator should send it's request through
                       the grafana instances ingress object instead of through the

docs/docs/api.md

@@ -3785,6 +3785,13 @@ Client defines how the grafana-operator talks to the grafana instance.
         </tr>
     </thead>
     <tbody><tr>
+        <td><b><a href="#grafanaspecclientheadersindex">headers</a></b></td>
+        <td>[]object</td>
+        <td>
+          Optional list of Header configuration objects that specify headers key and their value.<br/>
+        </td>
+        <td>false</td>
+      </tr><tr>
         <td><b>preferIngress</b></td>
         <td>boolean</td>
         <td>
@@ -3811,6 +3818,40 @@ Client defines how the grafana-operator talks to the grafana instance.
 </table>
 
 
+### Grafana.spec.client.headers[index]
+<sup><sup>[↩ Parent](#grafanaspecclient)</sup></sup>
+
+
+
+Header specifies http.Header key and value
+
+<table>
+    <thead>
+        <tr>
+            <th>Name</th>
+            <th>Type</th>
+            <th>Description</th>
+            <th>Required</th>
+        </tr>
+    </thead>
+    <tbody><tr>
+        <td><b>key</b></td>
+        <td>string</td>
+        <td>
+          Header name<br/>
+        </td>
+        <td>false</td>
+      </tr><tr>
+        <td><b>value</b></td>
+        <td>string</td>
+        <td>
+          Header value<br/>
+        </td>
+        <td>false</td>
+      </tr></tbody>
+</table>
+
+
 ### Grafana.spec.client.tls
 <sup><sup>[↩ Parent](#grafanaspecclient)</sup></sup>