statediff/indexer/metrics.go

@@ -31,6 +31,8 @@ type indexerMetricsHandles struct {
 	transactions metrics.Counter
 	// The total number of processed receipts
 	receipts metrics.Counter
+	// The total number of processed logs
+	logs metrics.Counter
 	// The total number of access list entries processed
 	accessListEntries metrics.Counter
 	// Time spent waiting for free postgres tx
@@ -52,6 +54,7 @@ func RegisterIndexerMetrics(reg metrics.Registry) indexerMetricsHandles {
 		blocks:                    metrics.NewCounter(),
 		transactions:              metrics.NewCounter(),
 		receipts:                  metrics.NewCounter(),
+		logs:                      metrics.NewCounter(),
 		accessListEntries:         metrics.NewCounter(),
 		tFreePostgres:             metrics.NewTimer(),
 		tPostgresCommit:           metrics.NewTimer(),
@@ -64,6 +67,7 @@ func RegisterIndexerMetrics(reg metrics.Registry) indexerMetricsHandles {
 	reg.Register(metricName(subsys, "blocks"), ctx.blocks)
 	reg.Register(metricName(subsys, "transactions"), ctx.transactions)
 	reg.Register(metricName(subsys, "receipts"), ctx.receipts)
+	reg.Register(metricName(subsys, "logs"), ctx.logs)
 	reg.Register(metricName(subsys, "access_list_entries"), ctx.accessListEntries)
 	reg.Register(metricName(subsys, "t_free_postgres"), ctx.tFreePostgres)
 	reg.Register(metricName(subsys, "t_postgres_commit"), ctx.tPostgresCommit)

statediff/indexer/writer.go

@@ -30,7 +30,7 @@ var (
 	nullHash = common.HexToHash("0x0000000000000000000000000000000000000000000000000000000000000000")
 )
 
-// Handles processing and writing of indexed IPLD objects to Postgres
+// PostgresCIDWriter handles processing and writing of indexed IPLD objects to Postgres
 type PostgresCIDWriter struct {
 	db *postgres.DB
 }
@@ -112,8 +112,8 @@ func (in *PostgresCIDWriter) upsertLogCID(tx *sqlx.Tx, logs []*models.LogsModel,
 		if err != nil {
 			return fmt.Errorf("error upserting logs entry: %w", err)
 		}
+		indexerMetrics.logs.Inc(1)
 	}
-	// TODO: Add metrics for logs.
 	return nil
 }