Updated pirsch to support processing tracking data.

This commit is contained in:
Marvin Blum
2020-06-23 21:37:49 +02:00
committed by Marvin Blum
parent 188d8a3d40
commit 3322651bc0
2 changed files with 53 additions and 7 deletions

21
main.go
View File

@@ -83,7 +83,26 @@ func setupTracker() {
logbuch.Fatal("Error pinging database", logbuch.Fields{"err": err})
}
tracker = pirsch.NewTracker(pirsch.NewPostgresStore(db), nil)
store := pirsch.NewPostgresStore(db)
tracker = pirsch.NewTracker(store, nil)
processor := pirsch.NewProcessor(store)
processTrackingData(processor)
pirsch.RunAtMidnight(func() {
processTrackingData(processor)
})
}
func processTrackingData(processor *pirsch.Processor) {
logbuch.Info("Processing tracking data...")
defer func() {
if err := recover(); err != nil {
logbuch.Error("Error processing tracking data", logbuch.Fields{"err": err})
}
}()
processor.Process()
logbuch.Info("Done processing tracking data")
}
func serveAbout() http.HandlerFunc {