From c9701803d13f597e50572da74fd487e53e180ed0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mats=20T=C3=B6rnberg?= Date: Mon, 13 Oct 2025 20:22:51 +0200 Subject: [PATCH] less logs --- pkg/actor/disk_storage.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/pkg/actor/disk_storage.go b/pkg/actor/disk_storage.go index f82fbdd..2b71093 100644 --- a/pkg/actor/disk_storage.go +++ b/pkg/actor/disk_storage.go @@ -53,6 +53,8 @@ func (s *DiskStorage[V]) SaveLoop(duration time.Duration) { } func (s *DiskStorage[V]) save() { + carts := 0 + lines := 0 s.queue.Range(func(key, value any) bool { id := key.(uint64) path := s.logPath(id) @@ -68,12 +70,16 @@ func (s *DiskStorage[V]) save() { if err := s.Append(fh, msg.Message, msg.TimeStamp); err != nil { log.Printf("failed to append event to log file: %v", err) } + lines++ } } + carts++ s.queue.Delete(id) return true }) - log.Print("Appended carts to disk") + if lines > 0 { + log.Printf("Appended %d carts and %d lines to disk", carts, lines) + } } func (s *DiskStorage[V]) logPath(id uint64) string {