Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 141c0e5100 | |||
| 9f3de791f9 |
+7
-2
@@ -146,7 +146,12 @@ func (s S) collectGarbage(ctx context.Context) error {
|
||||
c := time.NewTicker(time.Hour)
|
||||
defer c.Stop()
|
||||
|
||||
for range c.C {
|
||||
for {
|
||||
select {
|
||||
case <-c.C:
|
||||
case <-ctx.Done():
|
||||
return nil
|
||||
}
|
||||
if _, err := s.ExecContext(ctx, `
|
||||
DELETE FROM "pinger_pings"
|
||||
WHERE
|
||||
@@ -155,7 +160,7 @@ func (s S) collectGarbage(ctx context.Context) error {
|
||||
ms < 100
|
||||
OR ok
|
||||
)
|
||||
`, time.Now().Add(-1*12*time.Hour).Unix()); err != nil {
|
||||
`, time.Now().Add(-1*30*24*time.Hour).Unix()); err != nil {
|
||||
log.Println("!", err)
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user