Merge pull request #236 from thirdweb-dev/07-09-track_number_of_clickhouse_insert_operations

track number of clickhouse insert operations

Author: iuwqyir

internal/metrics/metrics.go

@@ -155,6 +155,11 @@ var (
 
 // ClickHouse Insert Row Count Metrics
 var (
+	ClickHouseMainStorageInsertOperations = promauto.NewCounter(prometheus.CounterOpts{
+		Name: "clickhouse_main_storage_insert_operations",
+		Help: "The total number of insert operations into ClickHouse main storage",
+	})
+
 	ClickHouseMainStorageRowsInserted = promauto.NewCounter(prometheus.CounterOpts{
 		Name: "clickhouse_main_storage_rows_inserted_total",
 		Help: "The total number of rows inserted into ClickHouse main storage",

internal/storage/clickhouse.go

@@ -1358,9 +1358,10 @@ func (c *ClickHouseConnector) InsertBlockData(data []common.BlockData) error {
 		metrics.ClickHouseTransactionsInserted.Add(float64(txsCount))
 		metrics.ClickHouseLogsInserted.Add(float64(logsCount))
 		metrics.ClickHouseTracesInserted.Add(float64(tracesCount))
+		metrics.ClickHouseMainStorageRowsInserted.Add(float64(end - i))
+		metrics.ClickHouseMainStorageInsertOperations.Inc()
 	}
 
-	metrics.ClickHouseMainStorageRowsInserted.Add(float64(len(data)))
 	return nil
 }