feat: metrics for aggregator payed gass diff

Author: MarcosNicolau

aggregator/internal/pkg/aggregator.go

@@ -90,6 +90,15 @@ type Aggregator struct {
 func NewAggregator(aggregatorConfig config.AggregatorConfig) (*Aggregator, error) {
 	newBatchChan := make(chan *servicemanager.ContractAlignedLayerServiceManagerNewBatchV3)
 
+	logger := aggregatorConfig.BaseConfig.Logger
+
+	// Metrics
+	reg := prometheus.NewRegistry()
+	aggregatorMetrics := metrics.NewMetrics(aggregatorConfig.Aggregator.MetricsIpPortAddress, reg, logger)
+
+	// Telemetry
+	aggregatorTelemetry := NewTelemetry(aggregatorConfig.Aggregator.TelemetryIpPortAddress, logger)
+
 	avsReader, err := chainio.NewAvsReaderFromConfig(aggregatorConfig.BaseConfig, aggregatorConfig.EcdsaConfig)
 	if err != nil {
 		return nil, err
@@ -100,7 +109,7 @@ func NewAggregator(aggregatorConfig config.AggregatorConfig) (*Aggregator, error
 		return nil, err
 	}
 
-	avsWriter, err := chainio.NewAvsWriterFromConfig(aggregatorConfig.BaseConfig, aggregatorConfig.EcdsaConfig)
+	avsWriter, err := chainio.NewAvsWriterFromConfig(aggregatorConfig.BaseConfig, aggregatorConfig.EcdsaConfig, aggregatorMetrics)
 	if err != nil {
 		return nil, err
 	}
@@ -121,7 +130,6 @@ func NewAggregator(aggregatorConfig config.AggregatorConfig) (*Aggregator, error
 
 	aggregatorPrivateKey := aggregatorConfig.EcdsaConfig.PrivateKey
 
-	logger := aggregatorConfig.BaseConfig.Logger
 	clients, err := sdkclients.BuildAll(chainioConfig, aggregatorPrivateKey, logger)
 	if err != nil {
 		logger.Errorf("Cannot create sdk clients", "err", err)
@@ -147,13 +155,6 @@ func NewAggregator(aggregatorConfig config.AggregatorConfig) (*Aggregator, error
 	avsRegistryService := avsregistry.NewAvsRegistryServiceChainCaller(avsReader.ChainReader, operatorPubkeysService, logger)
 	blsAggregationService := blsagg.NewBlsAggregatorService(avsRegistryService, hashFunction, logger)
 
-	// Metrics
-	reg := prometheus.NewRegistry()
-	aggregatorMetrics := metrics.NewMetrics(aggregatorConfig.Aggregator.MetricsIpPortAddress, reg, logger)
-
-	// Telemetry
-	aggregatorTelemetry := NewTelemetry(aggregatorConfig.Aggregator.TelemetryIpPortAddress, logger)
-
 	nextBatchIndex := uint32(0)
 
 	aggregator := Aggregator{

metrics/metrics.go

@@ -13,11 +13,13 @@ import (
 )
 
 type Metrics struct {
-	ipPortAddress              string
-	logger                     logging.Logger
-	numAggregatedResponses     prometheus.Counter
-	numAggregatorReceivedTasks prometheus.Counter
-	numOperatorTaskResponses   prometheus.Counter
+	ipPortAddress               string
+	logger                      logging.Logger
+	numAggregatedResponses      prometheus.Counter
+	numAggregatorReceivedTasks  prometheus.Counter
+	numOperatorTaskResponses    prometheus.Counter
+	accumulatedGasPriceSpent    prometheus.Gauge
+	numAccumulatedGasPriceSpent prometheus.Counter
 }
 
 const alignedNamespace = "aligned"
@@ -41,6 +43,16 @@ func NewMetrics(ipPortAddress string, reg prometheus.Registerer, logger logging.
 			Name:      "aggregator_received_tasks",
 			Help:      "Number of tasks received by the Service Manager",
 		}),
+		accumulatedGasPriceSpent: promauto.With(reg).NewGauge(prometheus.GaugeOpts{
+			Namespace: alignedNamespace,
+			Name:      "aggregator_accumulated_gas_price_payed",
+			Help:      "Number of tasks received by the Service Manager",
+		}),
+		numAccumulatedGasPriceSpent: promauto.With(reg).NewCounter(prometheus.CounterOpts{
+			Namespace: alignedNamespace,
+			Name:      "aggregator_number_accumulated_gas_price_payed",
+			Help:      "Number of tasks received by the Service Manager",
+		}),
 	}
 }
 
@@ -86,3 +98,11 @@ func (m *Metrics) IncAggregatedResponses() {
 func (m *Metrics) IncOperatorTaskResponses() {
 	m.numOperatorTaskResponses.Inc()
 }
+
+func (m *Metrics) IncAggregatorAccumResponse() {
+	m.numAccumulatedGasPriceSpent.Inc()
+}
+
+func (m *Metrics) AddAccumulatedGasPayedAggregator(value float64) {
+	m.accumulatedGasPriceSpent.Add(value)
+}