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

fix: retention policy calculation

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

8
internal/persistence/database.go
View File

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