WIP

plugins/prometheus/analysis_server.go

-package prometheus

plugins/prometheus/autopeering.go

@@ -14,7 +14,7 @@ var (
 	avgDistance                   prometheus.Gauge
 )
 
-func init() {
+func registerAutopeeringMetrics() {
 	neighborDropCount = prometheus.NewGauge(prometheus.GaugeOpts{
 		Name: "neighbor_drop_count",
 		Help: "Autopeering neighbor drop count.",

plugins/prometheus/clients_info.go

+package prometheus
+
+import (
+	"github.com/prometheus/client_golang/prometheus"
+)
+
+var (
+	clientsInfo *prometheus.GaugeVec
+)
+
+func registerClientsMetrics() {
+	clientsInfo = prometheus.NewGaugeVec(
+		prometheus.GaugeOpts{
+			Name: "clients_info",
+			Help: "Clients info.",
+		},
+		[]string{"info"},
+		// []string{"OS", "ARCH", "NUM_CPU", "CPU_USAGE", "MEM_USAGE"},
+	)
+
+	// registry.MustRegister(clientsInfo)
+
+	// collectClientsInfo()
+
+	// clientsInfo.WithLabelValues(banner.AppName, banner.AppVersion).Set(1)
+}
+
+func collectClientsInfo() {
+	// for ID, info := range metrics.ClientsMetrics() {
+	// 	clientsInfo.WithLabelValues()
+	// }
+
+}

plugins/prometheus/data.go

@@ -13,7 +13,7 @@ var (
 	dataSizes *prometheus.GaugeVec
 )
 
-func init() {
+func registerDataMetrics() {
 	dataSizes = prometheus.NewGaugeVec(
 		prometheus.GaugeOpts{
 			Name: "iota_data_sizes_bytes",

plugins/prometheus/fpc.go

@@ -6,17 +6,17 @@ import (
 )
 
 var (
-	activeConflicts      prometheus.Gauge
+	activeConflicts    prometheus.Gauge
 	finalizedConflicts prometheus.Gauge
-	failedConflicts prometheus.Gauge
-	avgRoundToFin prometheus.Gauge
-	queryRx prometheus.Gauge
-	queryOpRx prometheus.Gauge
-	queryReplyNotRx prometheus.Gauge
-	queryOpReplyNotRx prometheus.Gauge
+	failedConflicts    prometheus.Gauge
+	avgRoundToFin      prometheus.Gauge
+	queryRx            prometheus.Gauge
+	queryOpRx          prometheus.Gauge
+	queryReplyNotRx    prometheus.Gauge
+	queryOpReplyNotRx  prometheus.Gauge
 )
 
-func init() {
+func registerFPCMetrics() {
 	activeConflicts = prometheus.NewGauge(prometheus.GaugeOpts{
 		Name: "fpc_active_conflicts",
 		Help: "number of currently active conflicts",
@@ -72,4 +72,3 @@ func collectFPCMetrics() {
 	queryReplyNotRx.Set(float64(metrics.FPCQueryReplyErrors()))
 	queryOpReplyNotRx.Set(float64(metrics.FPCOpinionQueryReplyErrors()))
 }
-

plugins/prometheus/info.go

@@ -11,7 +11,7 @@ var (
 	sync    prometheus.Gauge
 )
 
-func init() {
+func registerInfoMetrics() {
 	infoApp = prometheus.NewGaugeVec(
 		prometheus.GaugeOpts{
 			Name: "iota_info_app",
@@ -26,6 +26,9 @@ func init() {
 		Help: "Node sync status.",
 	})
 
+	registry.MustRegister(infoApp)
+	registry.MustRegister(sync)
+
 	addCollect(collectInfoMetrics)
 }
 

plugins/prometheus/metrics.go

+package prometheus
+
+import (
+	"github.com/iotaledger/goshimmer/plugins/config"
+	"github.com/iotaledger/goshimmer/plugins/metrics"
+)
+
+func init() {
+	if config.Node.GetBool(metrics.CfgMetricsLocal) {
+		registerAutopeeringMetrics()
+		registerDataMetrics()
+		registerFPCMetrics()
+		registerInfoMetrics()
+		registerNetworkMetrics()
+		registerProcessMetrics()
+		registerTangleMetrics()
+	}
+
+	if config.Node.GetBool(metrics.CfgMetricsGlobal) {
+		registerClientsMetrics()
+	}
+}

plugins/prometheus/network.go

@@ -16,7 +16,7 @@ var (
 	autopeeringOutboundBytes prometheus.Gauge
 )
 
-func init() {
+func registerNetworkMetrics() {
 	fpcInboundBytes = prometheus.NewGauge(prometheus.GaugeOpts{
 		Name: "fpc_inbound_bytes",
 		Help: "FPC RX network traffic [bytes].",

plugins/prometheus/process.go

@@ -10,7 +10,7 @@ var (
 	memUsageBytes prometheus.Gauge
 )
 
-func init() {
+func registerProcessMetrics() {
 	cpuUsage = prometheus.NewGauge(prometheus.GaugeOpts{
 		Name: "cpu_usage",
 		Help: "CPU (System) usage.",

plugins/prometheus/tangle.go

@@ -7,17 +7,17 @@ import (
 )
 
 var (
-	messagesPerSecond prometheus.Gauge
+	messagesPerSecond          prometheus.Gauge
 	messagePerSecondPerPayload *prometheus.GaugeVec
-	messageTips prometheus.Gauge
-	messageCount *prometheus.GaugeVec
-	messageTotalCount prometheus.Gauge
+	messageTips                prometheus.Gauge
+	messageCount               *prometheus.GaugeVec
+	messageTotalCount          prometheus.Gauge
 
 	transactionsPerSecond prometheus.Gauge
-	valueTips prometheus.Gauge
+	valueTips             prometheus.Gauge
 )
 
-func init() {
+func registerTangleMetrics() {
 	messagesPerSecond = prometheus.NewGauge(prometheus.GaugeOpts{
 		Name: "tangle_messages_per_second",
 		Help: "Number of messages per second.",