Add metric to count the number of rate-limited transactions per EOA

Author: m-Peter

metrics/collector.go

@@ -82,6 +82,11 @@ var transactionsDroppedCounter = prometheus.NewCounter(prometheus.CounterOpts{
 	Help: "Total number of EVM transactions dropped due to service errors",
 })
 
+var eoaRateLimitedTransactions = prometheus.NewCounterVec(prometheus.CounterOpts{
+	Name: prefixedName("eoa_rate_limited_transactions"),
+	Help: "Total number of rate limited transactions by EOA",
+}, []string{"address"})
+
 var metrics = []prometheus.Collector{
 	apiErrors,
 	serverPanicsCounters,
@@ -97,6 +102,7 @@ var metrics = []prometheus.Collector{
 	blockIngestionTime,
 	requestRateLimitedCounters,
 	transactionsDroppedCounter,
+	eoaRateLimitedTransactions,
 }
 
 type Collector interface {
@@ -113,6 +119,7 @@ type Collector interface {
 	BlockIngestionTime(blockCreation time.Time)
 	RequestRateLimited(method string)
 	TransactionsDropped(count int)
+	EOARateLimited(address string)
 }
 
 var _ Collector = &DefaultCollector{}
@@ -133,6 +140,7 @@ type DefaultCollector struct {
 	blockIngestionTime         prometheus.Histogram
 	requestRateLimitedCounters *prometheus.CounterVec
 	transactionsDroppedCounter prometheus.Counter
+	eoaRateLimitedTransactions *prometheus.CounterVec
 }
 
 func NewCollector(logger zerolog.Logger) Collector {
@@ -156,6 +164,7 @@ func NewCollector(logger zerolog.Logger) Collector {
 		blockIngestionTime:         blockIngestionTime,
 		requestRateLimitedCounters: requestRateLimitedCounters,
 		transactionsDroppedCounter: transactionsDroppedCounter,
+		eoaRateLimitedTransactions: eoaRateLimitedTransactions,
 	}
 }
 
@@ -234,6 +243,12 @@ func (c *DefaultCollector) TransactionsDropped(count int) {
 	c.transactionsDroppedCounter.Add(float64(count))
 }
 
+func (c *DefaultCollector) EOARateLimited(address string) {
+	c.eoaRateLimitedTransactions.
+		With(prometheus.Labels{"address": address}).
+		Inc()
+}
+
 func prefixedName(name string) string {
 	return fmt.Sprintf("evm_gateway_%s", name)
 }

metrics/nop.go

@@ -25,3 +25,4 @@ func (c *nopCollector) GasEstimationIterations(count int)          {}
 func (c *nopCollector) BlockIngestionTime(blockCreation time.Time) {}
 func (c *nopCollector) RequestRateLimited(method string)           {}
 func (c *nopCollector) TransactionsDropped(count int)              {}
+func (c *nopCollector) EOARateLimited(address string)              {}

services/requester/requester.go

@@ -219,7 +219,7 @@ func (e *EVM) SendRawTransaction(ctx context.Context, data []byte) (common.Hash,
 			return common.Hash{}, fmt.Errorf("failed to check rate limit: %w", err)
 		}
 		if !ok {
-			e.collector.RequestRateLimited("SendRawTransaction")
+			e.collector.EOARateLimited(from.Hex())
 			return common.Hash{}, errs.ErrRateLimit
 		}
 	}