overflow_backup_2018_0455/collector_go
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
insanity@loafle.com 2017-04-17 17:20:33 +09:00
commit 7b4cf8f2b9
1 changed files with 20 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
collector.go
View File

@ -12,7 +12,9 @@ import (
"path/filepath"
"strings"
"time"
//crm "loafle.com/overflow/crawler_manager_go"
crm "loafle.com/overflow/crawler_manager_go"
"context"
g "loafle.com/overflow/crawler_go/grpc"
)
const CONFIG_ROOT = "/config/container"
@ -48,24 +50,24 @@ func (c *Collector) collect(id string) {
log.Printf("COLLECT %s - [ID: %s] [Crawler : %s]", time.Now(), conf.Id, conf.Crawler.Name)
//conn, err := crm.GetClient(conf.Crawler.Container)
//if err != nil {
// log.Println(err)
//}
//defer conn.Close()
conn, err := crm.GetInstance().GetClient(conf.Crawler.Container)
if err != nil {
log.Println(err)
}
defer conn.Close()
//dc := g.NewDataClient(conn);
//in := &g.Input{}
//
//in.Id = id
//in.Name = g.Crawlers_HEALTH_MONGODB
//
//out, err := dc.Get(context.Background(), in)
//
//if err != nil {
// log.Println(err)
//}
//log.Println(out)
dc := g.NewDataClient(conn);
in := &g.Input{}
in.Id = id
in.Name = g.Crawlers(g.Crawlers_value[conf.Crawler.Name])
out, err := dc.Get(context.Background(), in)
if err != nil {
log.Println(err)
}
log.Println(out)
}
//func (c *Collector) AddSensor(path string) {