diff --git a/internal/metrics/metrics.go b/internal/metrics/metrics.go index 4fc258b..2eea3a8 100644 --- a/internal/metrics/metrics.go +++ b/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", diff --git a/internal/storage/clickhouse.go b/internal/storage/clickhouse.go index 5cffefa..ef16a10 100644 --- a/internal/storage/clickhouse.go +++ b/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 }