Merge pull request #897 from SiaFoundation/nate/fix-metrics-panic

Fix missing syncer metrics

Author: n8mgr

api/prometheus.go

@@ -298,6 +298,14 @@ func (m Metrics) PrometheusMetric() []prometheus.Metric {
 			Name:  "hostd_metrics_data_rhp_egress",
 			Value: float64(m.Data.RHP.Egress),
 		},
+		{
+			Name:  "hostd_metrics_data_syncer_ingress",
+			Value: float64(m.Data.Syncer.Ingress),
+		},
+		{
+			Name:  "hostd_metrics_data_syncer_egress",
+			Value: float64(m.Data.Syncer.Egress),
+		},
 		{
 			Name:  "hostd_metrics_wallet_balance",
 			Value: m.Wallet.Balance.Siacoins(),

host/metrics/types.go

@@ -31,11 +31,12 @@ type (
 
 	// DataMetrics is a collection of metrics related to data usage.
 	DataMetrics struct {
-		RHP RHPData `json:"rhp"`
+		RHP    Data `json:"rhp"`
+		Syncer Data `json:"syncer"`
 	}
 
-	// RHPData is a collection of data metrics related to the RHP.
-	RHPData struct {
+	// Data is a collection of data metrics related to the RHP and Syncer.
+	Data struct {
 		// Ingress returns the number of bytes received by the host.
 		Ingress uint64 `json:"ingress"`
 		// Egress returns the number of bytes sent by the host.

persist/sqlite/metrics.go

@@ -424,6 +424,10 @@ func mustParseMetricValue(stat string, buf []byte, m *metrics.Metrics) {
 		m.Data.RHP.Ingress = mustScanUint64(buf)
 	case metricDataRHPEgress:
 		m.Data.RHP.Egress = mustScanUint64(buf)
+	case metricDataSyncerEgress:
+		m.Data.Syncer.Egress = mustScanUint64(buf)
+	case metricDataSyncerIngress:
+		m.Data.Syncer.Ingress = mustScanUint64(buf)
 	// potential revenue
 	case metricPotentialRPCRevenue:
 		m.Revenue.Potential.RPC = mustScanCurrency(buf)