mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

Complete refactor to new grpc control plane and only http proxy for carts #4

Merged
mats merged 75 commits from refactor/http-proxy into main 2025-10-14 22:31:28 +02:00
Conversation 0 Commits 75 Files Changed 88 +7 -1
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit c9701803d1 - Show all commits

8
pkg/actor/disk_storage.go
View File

@@ -53,6 +53,8 @@ func (s *DiskStorage[V]) SaveLoop(duration time.Duration) {
} }
func (s *DiskStorage[V]) save() { func (s *DiskStorage[V]) save() {
carts := 0
lines := 0
s.queue.Range(func(key, value any) bool { s.queue.Range(func(key, value any) bool {
id := key.(uint64) id := key.(uint64)
path := s.logPath(id) path := s.logPath(id)
@@ -68,12 +70,16 @@ func (s *DiskStorage[V]) save() {
if err := s.Append(fh, msg.Message, msg.TimeStamp); err != nil { if err := s.Append(fh, msg.Message, msg.TimeStamp); err != nil {
log.Printf("failed to append event to log file: %v", err) log.Printf("failed to append event to log file: %v", err)
} }
lines++
} }
} }
carts++
s.queue.Delete(id) s.queue.Delete(id)
return true 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 { func (s *DiskStorage[V]) logPath(id uint64) string {