kevin/tacitus
Archived
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add aggregator to watcher

Browse Source
This commit is contained in:
Kevin Cotugno 2017-10-10 09:55:25 -07:00
parent fbd9d80b96
commit de2ea4ed9d
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/watcher/main.go
View File

@ -6,6 +6,8 @@ import (
"github.com/kcotugno/tacitus/ops" "github.com/kcotugno/tacitus/ops"
"github.com/kcotugno/tacitus/osutil" "github.com/kcotugno/tacitus/osutil"
"github.com/kcotugno/tacitus/postgres" "github.com/kcotugno/tacitus/postgres"
"time"
) )
func main() { func main() {
@ -35,6 +37,12 @@ func main() {
return return
} }
a := ops.Aggregator{}
a.Database = db
a.Logger = logger
a.Products = []string{"ETH-USD", "BTC-USD"}
a.Start(30 * time.Second)
v := validator{} v := validator{}
v.db = db v.db = db
v.logger = logger v.logger = logger

2
ops/aggregator.go
View File

@ -83,6 +83,8 @@ func (a *Aggregator) aggregate(product string, interval time.Duration) {
if err != nil { if err != nil {
a.Logger.Info(`aggregator: database error="%v"`, err) a.Logger.Info(`aggregator: database error="%v"`, err)
} }
a.Logger.Info(`aggregator: DONE product="%v" interval="%v"`, product, interval)
} }
func (a *Aggregator) Stop() { func (a *Aggregator) Stop() {