fix logging

stellar · Jul 26, 2024 · 7ae9b3f · 7ae9b3f
1 parent 6a49102
commit 7ae9b3f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/services/horizon/internal/db2/history/main.go b/services/horizon/internal/db2/history/main.go
@@ -972,9 +972,9 @@ type tableObjectFieldPair struct {
 }
 
 type LookupTableReapResult struct {
-	Offset      int64         `json:"offset"`
-	RowsDeleted int64         `json:"rowsDeleted"`
-	Duration    time.Duration `json:"duration"`
+	Offset      int64
+	RowsDeleted int64
+	Duration    time.Duration
 }
 
 // ReapLookupTables removes rows from lookup tables like history_claimable_balances

diff --git a/services/horizon/internal/ingest/main.go b/services/horizon/internal/ingest/main.go
@@ -857,7 +857,9 @@ func (s *system) maybeReapLookupTables(lastIngestedLedger uint32) {
 	reapLog := log
 	for table, result := range results {
 		totalDeleted += result.RowsDeleted
-		reapLog = reapLog.WithField(table, result)
+		reapLog = reapLog.WithField(table+"_offset", result.Offset)
+		reapLog = reapLog.WithField(table+"_duration", result.Duration)
+		reapLog = reapLog.WithField(table+"_rows_deleted", result.RowsDeleted)
 		s.Metrics().RowsReapedByLookupTable.With(prometheus.Labels{"table": table}).Observe(float64(result.RowsDeleted))
 		s.Metrics().ReapDurationByLookupTable.With(prometheus.Labels{"table": table}).Observe(result.Duration.Seconds())
 	}