Add func (o *ObservedORM ) DeleteExcessLogs

smartcontractkit · Aug 13, 2024 · da6a896 · da6a896
1 parent 5ece5d3
commit da6a896
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/core/chains/evm/logpoller/observability.go b/core/chains/evm/logpoller/observability.go
@@ -142,6 +142,12 @@ func (o *ObservedORM) DeleteExpiredLogs(ctx context.Context, limit int64) (int64
 	})
 }
 
+func (o *ObservedORM) DeleteExcessLogs(ctx context.Context, limit int64) (int64, error) {
+	return withObservedExecAndRowsAffected(o, "DeleteExcessLogs", del, func() (int64, error) {
+		return o.ORM.DeleteExcessLogs(ctx, limit)
+	})
+}
+
 func (o *ObservedORM) SelectBlockByNumber(ctx context.Context, n int64) (*LogPollerBlock, error) {
 	return withObservedQuery(o, "SelectBlockByNumber", func() (*LogPollerBlock, error) {
 		return o.ORM.SelectBlockByNumber(ctx, n)