this repo has no description
feat: fixup checkpoint and trim log messages
+8
-4
+8
-4
pkg/mostliked/handler.go
+8
-4
pkg/mostliked/handler.go
···
43
43
for {
44
44
select {
45
45
case <-ticker.C:
46
-
log.Println("trimming posts")
46
+
log.Println("starting to trim old posts")
47
47
if err := queries.TrimPosts(ctx); err != nil {
48
-
log.Println("error trimming posts")
48
+
log.Printf("error trimming posts: %v\n", err)
49
49
}
50
50
}
51
51
}
···
201
201
switch {
202
202
case err != nil:
203
203
log.Printf("failed checkpoint: %v\n", err)
204
-
default:
205
-
log.Printf("checkpoint: %+v\n", results)
204
+
case results.Blocked == 1:
205
+
log.Printf("checkpoint: blocked\n")
206
+
case results.Pages == results.Transferred:
207
+
log.Printf("checkpoint: %d pages transferred\n", results.Transferred)
208
+
case results.Pages != results.Transferred:
209
+
log.Printf("checkpoint: %d pages, %d transferred\n", results.Pages, results.Transferred)
206
210
}
207
211
208
212
txOpen = false