From 9db5b3808a155a7269cdeb9cea618a7f55a5a675 Mon Sep 17 00:00:00 2001 From: Danny Date: Fri, 1 Jun 2018 12:12:15 +0200 Subject: [PATCH] return number of processed pageview from aggregator.Run --- pkg/aggregator/aggregator.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/pkg/aggregator/aggregator.go b/pkg/aggregator/aggregator.go index dd2869c..c9e63cc 100644 --- a/pkg/aggregator/aggregator.go +++ b/pkg/aggregator/aggregator.go @@ -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 -func (agg *aggregator) Run() { +func (agg *aggregator) Run() int { // Get unprocessed pageviews pageviews, err := agg.database.GetProcessablePageviews() if err != nil && err != datastore.ErrNoResults { log.Error(err) - return + return 0 } // Do we have anything to process? - if len(pageviews) == 0 { - return + n := len(pageviews) + if n == 0 { + return 0 } results := agg.Process(pageviews) @@ -62,6 +63,8 @@ func (agg *aggregator) Run() { if err != nil { log.Error(err) } + + return n } // Process processes the given pageviews and returns the (aggregated) results per metric per day