chore(exporter): report status of rocketpoolExporter (#908)

* report status of rocketpoolExporter * add metric for exporter_rocketpoolExporter task-duration BEDS-90
gobitfly · Oct 2, 2024 · d83133d · d83133d
1 parent 42a8588
commit d83133d
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/backend/pkg/exporter/modules/rocketpool.go b/backend/pkg/exporter/modules/rocketpool.go
@@ -13,6 +13,8 @@ import (
 
 	"github.com/gobitfly/beaconchain/pkg/commons/db"
 	"github.com/gobitfly/beaconchain/pkg/commons/log"
+	"github.com/gobitfly/beaconchain/pkg/commons/metrics"
+	"github.com/gobitfly/beaconchain/pkg/commons/services"
 	"github.com/gobitfly/beaconchain/pkg/commons/utils"
 	"github.com/pkg/errors"
 
@@ -195,6 +197,10 @@ func (rp *RocketpoolExporter) Run() error {
 			continue
 		}
 
+		services.ReportStatus("rocketpoolExporter", "Running", nil)
+
+		metrics.TaskDuration.WithLabelValues("exporter_rocketpoolExporter").Observe(time.Since(t0).Seconds())
+
 		log.InfoWithFields(log.Fields{"duration": time.Since(t0)}, "exported rocketpool-data")
 		count++
 		<-t.C