From c4547698878583e6e166deb4652cc6a48598af45 Mon Sep 17 00:00:00 2001
From: Hector Sanjuan <code@hector.link>
Date: Thu, 23 Jun 2022 11:58:35 +0200
Subject: [PATCH] Informer/disk: record issued metric weights as prometheus
 metric.

---
 informer/disk/disk.go   | 5 +++++
 observations/metrics.go | 8 ++++++++
 2 files changed, 13 insertions(+)

diff --git a/informer/disk/disk.go b/informer/disk/disk.go
index e50e5b45..cd941a4c 100644
--- a/informer/disk/disk.go
+++ b/informer/disk/disk.go
@@ -8,10 +8,12 @@ import (
 	"sync"
 
 	"github.com/ipfs-cluster/ipfs-cluster/api"
+	"github.com/ipfs-cluster/ipfs-cluster/observations"
 
 	logging "github.com/ipfs/go-log/v2"
 	rpc "github.com/libp2p/go-libp2p-gorpc"
 
+	"go.opencensus.io/stats"
 	"go.opencensus.io/trace"
 )
 
@@ -152,5 +154,8 @@ func (disk *Informer) GetMetrics(ctx context.Context) []api.Metric {
 	}
 
 	m.SetTTL(disk.config.MetricTTL)
+
+	stats.Record(ctx, observations.InformerDisk.M(m.Weight))
+
 	return []api.Metric{m}
 }
diff --git a/observations/metrics.go b/observations/metrics.go
index 59667b07..adf7d39f 100644
--- a/observations/metrics.go
+++ b/observations/metrics.go
@@ -48,6 +48,8 @@ var (
 
 	BlocksAdded      = stats.Int64("blocks/added", "Total number of blocks added", stats.UnitDimensionless)
 	BlocksAddedError = stats.Int64("blocks/put_errors", "Total number of block/put errors", stats.UnitDimensionless)
+
+	InformerDisk = stats.Int64("informer/disk", "The metric value weight issued by disk informer", stats.UnitDimensionless)
 )
 
 // views, which is just the aggregation of the metrics
@@ -114,6 +116,11 @@ var (
 		Aggregation: view.Sum(),
 	}
 
+	InformerDiskView = &view.View{
+		Measure:     InformerDisk,
+		Aggregation: view.LastValue(),
+	}
+
 	DefaultViews = []*view.View{
 		PinsView,
 		PinsQueuedView,
@@ -126,6 +133,7 @@ var (
 		BlocksAddedSizeView,
 		BlocksAddedView,
 		BlocksAddedErrorView,
+		InformerDiskView,
 	}
 )