status-im/fathom
2
0
Fork 0
mirror of https://github.com/status-im/fathom.git synced 2025-03-01 11:30:28 +00:00
Code Issues Projects Releases Wiki Activity

return number of processed pageview from aggregator.Run

Browse Source
This commit is contained in:
Danny 2018-06-01 12:12:15 +02:00
parent 76464854be
commit 9db5b3808a
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/aggregator/aggregator.go
View File

@ -20,17 +20,18 @@ func New(db datastore.Datastore) *aggregator {
} }
// Run processes the pageviews which are ready to be processed and adds them to daily aggregation // Run processes the pageviews which are ready to be processed and adds them to daily aggregation
func (agg *aggregator) Run() { func (agg *aggregator) Run() int {
// Get unprocessed pageviews // Get unprocessed pageviews
pageviews, err := agg.database.GetProcessablePageviews() pageviews, err := agg.database.GetProcessablePageviews()
if err != nil && err != datastore.ErrNoResults { if err != nil && err != datastore.ErrNoResults {
log.Error(err) log.Error(err)
return return 0
} }
// Do we have anything to process? // Do we have anything to process?
if len(pageviews) == 0 { n := len(pageviews)
return if n == 0 {
return 0
} }
results := agg.Process(pageviews) results := agg.Process(pageviews)
@ -62,6 +63,8 @@ func (agg *aggregator) Run() {
if err != nil { if err != nil {
log.Error(err) log.Error(err)
} }
return n
} }
// Process processes the given pageviews and returns the (aggregated) results per metric per day // Process processes the given pageviews and returns the (aggregated) results per metric per day