add operator metrics

Dockerfile

@@ -1,5 +1,5 @@
 # Build the manager binary
-FROM golang:1.20 as builder
+FROM golang:1.22 as builder
 ARG TARGETOS
 ARG TARGETARCH
 

config/manager/manager.yaml

@@ -67,6 +67,10 @@ spec:
             - -zap-devel
           image: ghcr.io/benthosdev/benthos-captain:latest
           name: manager
+          ports:
+            - containerPort: 8080
+              name: metrics
+              protocol: TCP
           securityContext:
             allowPrivilegeEscalation: false
             capabilities:

config/rbac/auth_proxy_service.yaml

@@ -13,9 +13,9 @@ metadata:
   namespace: system
 spec:
   ports:
-  - name: https
-    port: 8443
-    protocol: TCP
-    targetPort: https
+    - name: https
+      port: 8443
+      protocol: TCP
+      targetPort: https
   selector:
     control-plane: controller-manager

internal/controller/metrics/metrics.go

@@ -0,0 +1,24 @@
+package metrics
+
+import (
+	"github.com/prometheus/client_golang/prometheus"
+	"sigs.k8s.io/controller-runtime/pkg/metrics"
+)
+
+var (
+	PipelineReconciles = prometheus.NewCounterVec(prometheus.CounterOpts{
+		Namespace: "benthos_captain",
+		Name:      "reconciles",
+		Help:      "reconciles per Benthos pipeline",
+	}, []string{"pipeline"})
+
+	PipelineFailedReconciles = prometheus.NewCounterVec(prometheus.CounterOpts{
+		Namespace: "benthos_captain",
+		Name:      "failed_reconciles",
+		Help:      "failed reconciles per Benthos pipeline",
+	}, []string{"pipeline"})
+)
+
+func init() {
+	metrics.Registry.MustRegister(PipelineReconciles, PipelineFailedReconciles)
+}

internal/controller/pipeline_controller.go

@@ -21,6 +21,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/reconcile"
 
 	captainv1 "github.com/benthosdev/benthos-captain/api/v1alpha1"
+	"github.com/benthosdev/benthos-captain/internal/controller/metrics"
 	"github.com/benthosdev/benthos-captain/internal/pkg/resource"
 )
 
@@ -72,6 +73,8 @@ func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
 		return reconcile.Result{}, err
 	}
 
+	metrics.PipelineReconciles.WithLabelValues(pipeline.Name).Inc()
+
 	scope := &PipelineScope{
 		Log:      &log,
 		Ctx:      ctx,
@@ -258,6 +261,7 @@ func (r *PipelineReconciler) createOrPatchDeployment(scope *PipelineScope) (ctrl
 		return nil
 	})
 	if err != nil {
+		metrics.PipelineFailedReconciles.WithLabelValues(name).Inc()
 		return reconcile.Result{}, errors.Wrapf(err, "Failed to reconcile deployment %s", name)
 	}
 	scope.Log.Info("Succesfully reconciled deployment", "name", name, "operation", op)

internal/pkg/resource/resource.go

@@ -7,7 +7,7 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
-const DefaultImage = "jeffail/benthos:4.22"
+const DefaultImage = "jeffail/benthos:4.27"
 
 func NewDeployment(name string, namespace string, scope captainv1.PipelineSpec) *appsv1.Deployment {
 	labels := map[string]string{