logos-messaging/storenode-messages-counter
1
0
Fork 0
mirror of https://github.com/logos-messaging/storenode-messages-counter.git synced 2026-01-04 07:03:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: log rows affected

Browse Source
This commit is contained in:
Richard Ramos 2024-05-28 14:29:04 -04:00
parent 4aa52a26b2
commit d811bf72b2
No known key found for this signature in database
GPG Key ID: 1CE87DB518195760
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
internal/persistence/database.go
View File

@ -138,19 +138,31 @@ func (d *DBStore) Start(ctx context.Context, timesource timesource.Timesource) e
}
func (d *DBStore) cleanOlderRecords(ctx context.Context) error {
d.log.Debug("cleaning older records...")
deleteFrom := time.Now().Add(d.retentionPolicy).UnixNano()
_, err := d.db.ExecContext(ctx, "DELETE FROM missingMessages WHERE storedAt < $1", deleteFrom)
d.log.Info("cleaning older records...", zap.Int64("from", deleteFrom))
r, err := d.db.ExecContext(ctx, "DELETE FROM missingMessages WHERE storedAt < $1", deleteFrom)
if err != nil {
return err
}
_, err = d.db.ExecContext(ctx, "DELETE FROM storeNodeUnavailable WHERE requestTime < $1", deleteFrom)
rowsAffected, err := r.RowsAffected()
if err != nil {
return err
}
d.log.Info("deleted missing messages from log", zap.Int64("rowsAffected", rowsAffected))
r, err = d.db.ExecContext(ctx, "DELETE FROM storeNodeUnavailable WHERE requestTime < $1", deleteFrom)
if err != nil {
return err
}
rowsAffected, err = r.RowsAffected()
if err != nil {
return err
}
d.log.Info("deleted storenode unavailability from log", zap.Int64("rowsAffected", rowsAffected))
d.log.Debug("older records removed")