first commit

chain/cache.go

@@ -20,6 +20,7 @@ func newCache(maxSize int) *cache {
 
 func (c *cache) GetOrLoad(key interface{}, load func() (interface{}, error)) (interface{}, error) {
 	if value, ok := c.Get(key); ok {
+		metricBlockRepositoryCounter().AddWithLabel(1, map[string]string{"type": "read", "target": "cache"})
 		return value, nil
 	}
 	value, err := load()

chain/chain.go

@@ -241,6 +241,7 @@ func (c *Chain) GetTransaction(id thor.Bytes32) (*tx.Transaction, *TxMeta, error
 	if err != nil {
 		return nil, nil, err
 	}
+	metricTransactionRepositoryCounter().AddWithLabel(1, map[string]string{"type": "read"})
 	return tx, txMeta, nil
 }
 
@@ -256,6 +257,7 @@ func (c *Chain) GetTransactionReceipt(txID thor.Bytes32) (*tx.Receipt, error) {
 	if err != nil {
 		return nil, err
 	}
+	metricReceiptRepositoryCounter().AddWithLabel(1, map[string]string{"type": "read"})
 	return receipt, nil
 }
 

chain/metrics.go

@@ -9,4 +9,7 @@ import "github.com/vechain/thor/v2/metrics"
 
 var (
 	metricCacheHitMiss = metrics.LazyLoadCounterVec("repo_cache_hit_miss_count", []string{"type", "event"})
+	metricBlockRepositoryCounter = metrics.LazyLoadCounterVec("block_repository_count", []string{"type", "target"})
+	metricTransactionRepositoryCounter = metrics.LazyLoadCounterVec("transaction_repository_count", []string{"type", "target"})
+	metricReceiptRepositoryCounter = metrics.LazyLoadCounterVec("receipt_repository_count", []string{"type", "target"})
 )

chain/persist.go

@@ -90,5 +90,6 @@ func loadBlockSummary(r kv.Getter, id thor.Bytes32) (*BlockSummary, error) {
 	if err := loadRLP(r, id[:], &summary); err != nil {
 		return nil, err
 	}
+	metricBlockRepositoryCounter().AddWithLabel(1, map[string]string{"type": "read", "target": "db"})
 	return &summary, nil
 }

chain/repository.go

@@ -187,6 +187,7 @@ func (r *Repository) saveBlock(block *block.Block, receipts tx.Receipts, conflic
 			}
 			r.caches.receipts.Add(string(keyBuf), receipt)
 		}
+		metricReceiptRepositoryCounter().AddWithLabel(int64(len(receipts)), map[string]string{"type": "write", "target": "db"})
 	}
 	if err := indexChainHead(headPutter, header); err != nil {
 		return nil, err

metrics/prometheus.go

@@ -204,7 +204,7 @@ func (o *prometheusMetrics) newHistogramMeter(name string, buckets []int64) Hist
 
 	err := prometheus.Register(meter)
 	if err != nil {
-		logger.Warn("unable to register metric", "err", err)
+		logger.Warn(fmt.Sprintf("unable to register metric %s", name), "err", err)
 	}
 
 	return &promHistogramMeter{
@@ -237,7 +237,7 @@ func (o *prometheusMetrics) newHistogramVecMeter(name string, labels []string, b
 
 	err := prometheus.Register(meter)
 	if err != nil {
-		logger.Warn("unable to register metric", "err", err)
+		logger.Warn(fmt.Sprintf("unable to register metric %s", name), "err", err)
 	}
 
 	return &promHistogramVecMeter{
@@ -263,7 +263,7 @@ func (o *prometheusMetrics) newCountMeter(name string) CountMeter {
 
 	err := prometheus.Register(meter)
 	if err != nil {
-		logger.Warn("unable to register metric", "err", err)
+		logger.Warn(fmt.Sprintf("unable to register metric %s", name), "err", err)
 	}
 	return &promCountMeter{
 		counter: meter,
@@ -281,7 +281,7 @@ func (o *prometheusMetrics) newCountVecMeter(name string, labels []string) Count
 
 	err := prometheus.Register(meter)
 	if err != nil {
-		logger.Warn("unable to register metric", "err", err)
+		logger.Warn(fmt.Sprintf("unable to register metric %s", name), "err", err)
 	}
 	return &promCountVecMeter{
 		counter: meter,
@@ -298,7 +298,7 @@ func (o *prometheusMetrics) newGaugeMeter(name string) GaugeMeter {
 
 	err := prometheus.Register(meter)
 	if err != nil {
-		logger.Warn("unable to register metric", "err", err)
+		logger.Warn(fmt.Sprintf("unable to register metric %s", name), "err", err)
 	}
 	return &promGaugeMeter{
 		gauge: meter,
@@ -316,7 +316,7 @@ func (o *prometheusMetrics) newGaugeVecMeter(name string, labels []string) Gauge
 
 	err := prometheus.Register(meter)
 	if err != nil {
-		logger.Warn("unable to register metric", "err", err)
+		logger.Warn(fmt.Sprintf("unable to register metric %s", name), "err", err)
 	}
 	return &promGaugeVecMeter{
 		gauge: meter,

state/metrics.go

@@ -0,0 +1,10 @@
+// Copyright (c) 2024 The VeChainThor developers
+//
+// Distributed under the GNU Lesser General Public License v3.0 software license, see the accompanying
+// file LICENSE or <https://www.gnu.org/licenses/lgpl-3.0.html>
+
+package state
+
+import "github.com/vechain/thor/v2/metrics"
+
+var metricAccountCounter = metrics.LazyLoadCounterVec("account_state_count", []string{"type", "target"})