staged stream sync v1.0

go.mod

@@ -166,6 +166,7 @@ require (
 	github.com/libp2p/go-cidranger v1.1.0 // indirect
 	github.com/libp2p/go-flow-metrics v0.1.0 // indirect
 	github.com/libp2p/go-libp2p-asn-util v0.2.0 // indirect
+	github.com/libp2p/go-libp2p-core v0.20.1 // indirect
 	github.com/libp2p/go-libp2p-kbucket v0.5.0 // indirect
 	github.com/libp2p/go-libp2p-record v0.2.0 // indirect
 	github.com/libp2p/go-msgio v0.2.0 // indirect

hmy/downloader/metric.go

@@ -23,7 +23,7 @@ var (
 	consensusTriggeredDownloadCounterVec = prometheus.NewCounterVec(
 		prometheus.CounterOpts{
 			Namespace: "hmy",
-			Subsystem: "downloader",
+			Subsystem: "StreamSync",
 			Name:      "consensus_trigger",
 			Help:      "number of times consensus triggered download task",
 		},
@@ -33,7 +33,7 @@ var (
 	longRangeSyncedBlockCounterVec = prometheus.NewCounterVec(
 		prometheus.CounterOpts{
 			Namespace: "hmy",
-			Subsystem: "downloader",
+			Subsystem: "StreamSync",
 			Name:      "num_blocks_synced_long_range",
 			Help:      "number of blocks synced in long range sync",
 		},
@@ -43,7 +43,7 @@ var (
 	longRangeFailInsertedBlockCounterVec = prometheus.NewCounterVec(
 		prometheus.CounterOpts{
 			Namespace: "hmy",
-			Subsystem: "downloader",
+			Subsystem: "StreamSync",
 			Name:      "num_blocks_failed_long_range",
 			Help:      "number of blocks failed to insert into change in long range sync",
 		},
@@ -53,7 +53,7 @@ var (
 	numShortRangeCounterVec = prometheus.NewCounterVec(
 		prometheus.CounterOpts{
 			Namespace: "hmy",
-			Subsystem: "downloader",
+			Subsystem: "StreamSync",
 			Name:      "num_short_range",
 			Help:      "number of short range sync is triggered",
 		},
@@ -63,7 +63,7 @@ var (
 	numFailedDownloadCounterVec = prometheus.NewCounterVec(
 		prometheus.CounterOpts{
 			Namespace: "hmy",
-			Subsystem: "downloader",
+			Subsystem: "StreamSync",
 			Name:      "failed_download",
 			Help:      "number of downloading is failed",
 		},
@@ -73,7 +73,7 @@ var (
 	numBlocksInsertedShortRangeHistogramVec = prometheus.NewHistogramVec(
 		prometheus.HistogramOpts{
 			Namespace: "hmy",
-			Subsystem: "downloader",
+			Subsystem: "StreamSync",
 			Name:      "num_blocks_inserted_short_range",
 			Help:      "number of blocks inserted for each short range sync",
 			// Buckets: 0, 1, 2, 4, +INF (capped at 10)
@@ -85,7 +85,7 @@ var (
 	numBlocksInsertedBeaconHelperCounter = prometheus.NewCounter(
 		prometheus.CounterOpts{
 			Namespace: "hmy",
-			Subsystem: "downloader",
+			Subsystem: "StreamSync",
 			Name:      "num_blocks_inserted_beacon_helper",
 			Help:      "number of blocks inserted from beacon helper",
 		},