Add scheduled transaction metrics

Author: devbugging

engine/execution/computation/computer/computer.go

@@ -650,6 +650,21 @@ func (e *blockComputer) executeProcessCallback(
 		return nil, 0, err
 	}
 
+	if len(callbackTxs) > 0 {
+		// calculate total gas limits for execute callback transactions
+		var totalExecuteGasLimits uint64
+		for _, tx := range callbackTxs {
+			totalExecuteGasLimits += tx.GasLimit
+		}
+
+		// report metrics for callbacks executed
+		e.metrics.ExecutionCallbacksExecuted(
+			len(callbackTxs),
+			txn.Output().ComputationUsed,
+			totalExecuteGasLimits,
+		)
+	}
+
 	return callbackTxs, txnIndex, nil
 }
 

module/metrics.go

@@ -1027,6 +1027,9 @@ type ExecutionMetrics interface {
 	// ExecutionScriptExecuted reports the time and memory spent on executing an script
 	ExecutionScriptExecuted(dur time.Duration, compUsed, memoryUsed, memoryEstimate uint64)
 
+	// ExecutionCallbacksExecuted reports the number of callbacks executed, gas used by process transaction, and total gas limits for execute transactions
+	ExecutionCallbacksExecuted(callbackCount int, processGasUsed, executeGasLimits uint64)
+
 	// ExecutionCollectionRequestSent reports when a request for a collection is sent to a collection node
 	ExecutionCollectionRequestSent()
 

module/metrics/execution.go

@@ -98,6 +98,9 @@ type ExecutionCollector struct {
 	evmTransactionGasUsed                   prometheus.Histogram
 	evmBlockTxCount                         prometheus.Histogram
 	evmBlockGasUsed                         prometheus.Histogram
+	callbacksExecutedCount                  prometheus.Histogram
+	callbacksProcessGasUsed                 prometheus.Histogram
+	callbacksExecuteGasLimits               prometheus.Histogram
 }
 
 func NewExecutionCollector(tracer module.Tracer) *ExecutionCollector {
@@ -793,6 +796,30 @@ func NewExecutionCollector(tracer module.Tracer) *ExecutionCollector {
 			Name:      "evm_block_total_supply",
 			Help:      "the total amount of flow deposited to EVM (in FLOW)",
 		}),
+
+		callbacksExecutedCount: promauto.NewHistogram(prometheus.HistogramOpts{
+			Namespace: namespaceExecution,
+			Subsystem: subsystemRuntime,
+			Name:      "callbacks_executed_count",
+			Help:      "the number of callbacks executed",
+			Buckets:   prometheus.ExponentialBuckets(1, 2, 8),
+		}),
+
+		callbacksProcessGasUsed: promauto.NewHistogram(prometheus.HistogramOpts{
+			Namespace: namespaceExecution,
+			Subsystem: subsystemRuntime,
+			Name:      "callbacks_process_gas_used",
+			Help:      "the gas used by the process callback transaction",
+			Buckets:   prometheus.ExponentialBuckets(10_000, 2, 12),
+		}),
+
+		callbacksExecuteGasLimits: promauto.NewHistogram(prometheus.HistogramOpts{
+			Namespace: namespaceExecution,
+			Subsystem: subsystemRuntime,
+			Name:      "callbacks_execute_gas_limits",
+			Help:      "the total gas limits for execute callback transactions",
+			Buckets:   prometheus.ExponentialBuckets(10_000, 2, 12),
+		}),
 	}
 
 	return ec
@@ -883,6 +910,13 @@ func (ec *ExecutionCollector) ExecutionScriptExecuted(dur time.Duration, compUse
 	ec.scriptMemoryDifference.Observe(float64(memoryEstimated) - float64(memoryUsed))
 }
 
+// ExecutionCallbacksExecuted reports callback execution metrics
+func (ec *ExecutionCollector) ExecutionCallbacksExecuted(callbackCount int, processGasUsed, executeGasLimits uint64) {
+	ec.callbacksExecutedCount.Observe(float64(callbackCount))
+	ec.callbacksProcessGasUsed.Observe(float64(processGasUsed))
+	ec.callbacksExecuteGasLimits.Observe(float64(executeGasLimits))
+}
+
 // ExecutionStateStorageDiskTotal reports the total storage size of the execution state on disk in bytes
 func (ec *ExecutionCollector) ExecutionStateStorageDiskTotal(bytes int64) {
 	ec.stateStorageDiskTotal.Set(float64(bytes))

module/metrics/noop.go

@@ -181,6 +181,7 @@ func (nc *NoopCollector) ExecutionTransactionExecuted(_ time.Duration, _ module.
 }
 func (nc *NoopCollector) ExecutionChunkDataPackGenerated(_, _ int)                              {}
 func (nc *NoopCollector) ExecutionScriptExecuted(dur time.Duration, compUsed, _, _ uint64)      {}
+func (nc *NoopCollector) ExecutionCallbacksExecuted(int, uint64, uint64)                        {}
 func (nc *NoopCollector) ForestApproxMemorySize(bytes uint64)                                   {}
 func (nc *NoopCollector) ForestNumberOfTrees(number uint64)                                     {}
 func (nc *NoopCollector) LatestTrieRegCount(number uint64)                                      {}