Add input_bytes counter

op-batcher/metrics/metrics.go

@@ -64,6 +64,7 @@ type Metrics struct {
 	ChannelClosedReason     prometheus.Gauge
 	ChannelNumFrames        prometheus.Gauge
 	ChannelComprRatio       prometheus.Histogram
+	ChannelInputBytesTotal  prometheus.Counter
 	ChannelOutputBytesTotal prometheus.Counter
 
 	BatcherTxEvs opmetrics.EventVec
@@ -145,6 +146,11 @@ func NewMetrics(procName string) *Metrics {
 			Help:      "Compression ratios of closed channel.",
 			Buckets:   append([]float64{0.1, 0.2}, prometheus.LinearBuckets(0.3, 0.05, 14)...),
 		}),
+		ChannelInputBytesTotal: factory.NewCounter(prometheus.CounterOpts{
+			Namespace: ns,
+			Name:      "input_bytes_total",
+			Help:      "Total number of bytes to a channel.",
+		}),
 		ChannelOutputBytesTotal: factory.NewCounter(prometheus.CounterOpts{
 			Namespace: ns,
 			Name:      "output_bytes_total",
@@ -225,7 +231,7 @@ func (m *Metrics) RecordChannelClosed(id derive.ChannelID, numPendingBlocks int,
 	m.ChannelNumFrames.Set(float64(numFrames))
 	m.ChannelInputBytes.WithLabelValues(StageClosed).Set(float64(inputBytes))
 	m.ChannelOutputBytes.Set(float64(outputComprBytes))
-
+	m.ChannelInputBytesTotal.Add(float64(inputBytes))
 	m.ChannelOutputBytesTotal.Add(float64(outputComprBytes))
 
 	var comprRatio float64