run the aggregator every minute since we only need the last pageview of every visitor for determining distinct realtime visitor count

pkg/api/collect.go

@@ -83,10 +83,10 @@ func NewCollectHandler() http.Handler {
 	})
 }
 
-// runs the aggregate func every 5 mins
+// runs the aggregate func every minute
 func aggregate() {
 	counter.Aggregate()
-	timeout := 5 * time.Minute
+	timeout := 1 * time.Minute
 
 	for {
 		select {

pkg/counter/counter.go

@@ -13,6 +13,7 @@ func Aggregate() error {
 	// Get unprocessed pageviews
 	pageviews, err := datastore.GetProcessablePageviews()
 	if err != nil && err != datastore.ErrNoResults {
+		log.Error(err)
 		return err
 	}