diff options
author | 2023-09-24 16:32:09 -0700 | |
---|---|---|
committer | 2023-09-24 22:37:33 -0700 | |
commit | c0e954f19d707fef8ef8271636ec661634a4c4c7 (patch) | |
tree | 5aa052a048f470e233a454e5ad9071eed1fa37c0 /internal/cli/cleanup_tasks.go | |
parent | 54cb8fa0286e4a2f1a81c32b5a89722d93b30bf7 (diff) | |
download | v2-c0e954f19d707fef8ef8271636ec661634a4c4c7.tar.gz v2-c0e954f19d707fef8ef8271636ec661634a4c4c7.tar.zst v2-c0e954f19d707fef8ef8271636ec661634a4c4c7.zip |
Implement structured logging using log/slog package
Diffstat (limited to 'internal/cli/cleanup_tasks.go')
-rw-r--r-- | internal/cli/cleanup_tasks.go | 19 |
1 files changed, 13 insertions, 6 deletions
diff --git a/internal/cli/cleanup_tasks.go b/internal/cli/cleanup_tasks.go index f7e791e7..adeb280b 100644 --- a/internal/cli/cleanup_tasks.go +++ b/internal/cli/cleanup_tasks.go @@ -4,10 +4,10 @@ package cli // import "miniflux.app/v2/internal/cli" import ( + "log/slog" "time" "miniflux.app/v2/internal/config" - "miniflux.app/v2/internal/logger" "miniflux.app/v2/internal/metric" "miniflux.app/v2/internal/model" "miniflux.app/v2/internal/storage" @@ -16,13 +16,18 @@ import ( func runCleanupTasks(store *storage.Storage) { nbSessions := store.CleanOldSessions(config.Opts.CleanupRemoveSessionsDays()) nbUserSessions := store.CleanOldUserSessions(config.Opts.CleanupRemoveSessionsDays()) - logger.Info("[Sessions] Removed %d application sessions and %d user sessions", nbSessions, nbUserSessions) + slog.Info("Sessions cleanup completed", + slog.Int64("application_sessions_removed", nbSessions), + slog.Int64("user_sessions_removed", nbUserSessions), + ) startTime := time.Now() if rowsAffected, err := store.ArchiveEntries(model.EntryStatusRead, config.Opts.CleanupArchiveReadDays(), config.Opts.CleanupArchiveBatchSize()); err != nil { - logger.Error("[ArchiveReadEntries] %v", err) + slog.Error("Unable to archive read entries", slog.Any("error", err)) } else { - logger.Info("[ArchiveReadEntries] %d entries changed", rowsAffected) + slog.Info("Archiving read entries completed", + slog.Int64("read_entries_archived", rowsAffected), + ) if config.Opts.HasMetricsCollector() { metric.ArchiveEntriesDuration.WithLabelValues(model.EntryStatusRead).Observe(time.Since(startTime).Seconds()) @@ -31,9 +36,11 @@ func runCleanupTasks(store *storage.Storage) { startTime = time.Now() if rowsAffected, err := store.ArchiveEntries(model.EntryStatusUnread, config.Opts.CleanupArchiveUnreadDays(), config.Opts.CleanupArchiveBatchSize()); err != nil { - logger.Error("[ArchiveUnreadEntries] %v", err) + slog.Error("Unable to archive unread entries", slog.Any("error", err)) } else { - logger.Info("[ArchiveUnreadEntries] %d entries changed", rowsAffected) + slog.Info("Archiving unread entries completed", + slog.Int64("unread_entries_archived", rowsAffected), + ) if config.Opts.HasMetricsCollector() { metric.ArchiveEntriesDuration.WithLabelValues(model.EntryStatusUnread).Observe(time.Since(startTime).Seconds()) |