✨ New prometheus metrics to reflect cluster status

Author: Yannig

pkg/cluster/sync.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"reflect"
+	"github.com/prometheus/client_golang/prometheus"
 	"regexp"
 	"strings"
 	"time"
@@ -20,6 +21,20 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
 
+var(
+	pgStatus = prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "pg_sync_status",
+			Help: "Postgres sync status (1 = ok, 0 = error).",
+		},
+		[]string{"namespace", "clusterName"},
+	)
+)
+
+func init() {
+	prometheus.MustRegister(pgStatus)
+}
+
 // Sync syncs the cluster, making sure the actual Kubernetes objects correspond to what is defined in the manifest.
 // Unlike the update, sync does not error out if some objects do not exist and takes care of creating them.
 func (c *Cluster) Sync(newSpec *acidv1.Postgresql) error {
@@ -31,7 +46,10 @@ func (c *Cluster) Sync(newSpec *acidv1.Postgresql) error {
 	c.setSpec(newSpec)
 
 	defer func() {
+		labels := prometheus.Labels{"namespace":c.clusterName().Namespace,"clusterName":c.clusterName().Name}
+		pgStatus.With(labels).Set(1)
 		if err != nil {
+			pgStatus.With(labels).Set(0)
 			c.logger.Warningf("error while syncing cluster state: %v", err)
 			c.KubeClient.SetPostgresCRDStatus(c.clusterName(), acidv1.ClusterStatusSyncFailed)
 		} else if !c.Status.Running() {