publish libp2p resource manager metrics (#1795)

go.mod

@@ -3,6 +3,7 @@ module github.com/filecoin-project/bacalhau
 go 1.19
 
 require (
+	contrib.go.opencensus.io/exporter/prometheus v0.4.0
 	github.com/BTBurke/k8sresource v1.2.0
 	github.com/MakeNowJust/heredoc/v2 v2.0.1
 	github.com/Masterminds/semver v1.5.0
@@ -74,6 +75,7 @@ require (
 	github.com/tidwall/sjson v1.2.5
 	github.com/vincent-petithory/dataurl v1.0.0
 	github.com/xeipuuv/gojsonschema v1.2.0
+	go.opencensus.io v0.24.0
 	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.37.0
 	go.opentelemetry.io/otel v1.11.2
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.11.2
@@ -97,7 +99,6 @@ require (
 
 require (
 	bazil.org/fuse v0.0.0-20200407214033-5883e5a4b512 // indirect
-	contrib.go.opencensus.io/exporter/prometheus v0.4.0 // indirect
 	github.com/AndreasBriese/bbloom v0.0.0-20190825152654-46b345b51c96 // indirect
 	github.com/Azure/go-ansiterm v0.0.0-20210617225240-d185dfc1b5a1 // indirect
 	github.com/KyleBanks/depth v1.2.1 // indirect
@@ -315,7 +316,6 @@ require (
 	github.com/whyrusleeping/timecache v0.0.0-20160911033111-cfcb2f1abfee // indirect
 	github.com/xeipuuv/gojsonpointer v0.0.0-20180127040702-4e3ac2762d5f // indirect
 	github.com/xeipuuv/gojsonreference v0.0.0-20180127040603-bd5ef7bd5415 // indirect
-	go.opencensus.io v0.24.0 // indirect
 	go.opentelemetry.io/otel/exporters/jaeger v1.7.0 // indirect
 	go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.11.2 // indirect
 	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.7.0 // indirect

pkg/libp2p/rcmgr/defaults.go

@@ -1,10 +1,14 @@
 package rcmgr
 
 import (
+	ocprom "contrib.go.opencensus.io/exporter/prometheus"
 	"github.com/filecoin-project/bacalhau/pkg/transport/bprotocol"
 	"github.com/libp2p/go-libp2p"
 	libp2p_rcmgr "github.com/libp2p/go-libp2p/p2p/host/resource-manager"
 	"github.com/libp2p/go-libp2p/p2p/host/resource-manager/obs"
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/rs/zerolog/log"
+	"go.opencensus.io/stats/view"
 )
 
 func SetDefaultServiceLimits(config *libp2p_rcmgr.ScalingLimitConfig) {
@@ -47,6 +51,19 @@ var DefaultResourceManager = func(cfg *libp2p.Config) error {
 	libp2p.SetDefaultServiceLimits(&limits)
 	SetDefaultServiceLimits(&limits)
 
+	// Hook up the trace reporter metrics. This will expose all opencensus
+	// stats via the default prometheus registry. See https://opencensus.io/exporters/supported-exporters/go/prometheus/ for other options.
+	err := view.Register(obs.DefaultViews...)
+	if err != nil {
+		log.Warn().Err(err).Msg("failed to register resource manager metrics")
+	}
+	_, err = ocprom.NewExporter(ocprom.Options{
+		Registry: prometheus.DefaultRegisterer.(*prometheus.Registry),
+	})
+	if err != nil {
+		log.Warn().Err(err).Msg("failed to register resource manager metric exporter")
+	}
+
 	str, err := obs.NewStatsTraceReporter()
 	if err != nil {
 		return err