From fd7ea8daf6fee8b84e5d32c173555ae036f13f20 Mon Sep 17 00:00:00 2001 From: "insanity@loafle.com" Date: Wed, 17 May 2017 12:55:08 +0900 Subject: [PATCH] collector --- collector.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/collector.go b/collector.go index fbbbb12..196eb28 100644 --- a/collector.go +++ b/collector.go @@ -9,7 +9,6 @@ import ( "log" "strconv" "sync" - "time" ) var ( @@ -65,7 +64,6 @@ func (c *Collector) stop() { func (c *Collector) collect(id string) { go func() { conf := c.cm.GetSensorById(id) - log.Printf("COLLECT %s - [ID: %s] [Crawler : %s]", time.Now(), conf.Id, conf.Crawler.Name) conn, err := crm.GetInstance().GetClient(conf.Crawler.Container) if err != nil { log.Println(err) @@ -77,13 +75,11 @@ func (c *Collector) collect(id string) { in.Id = id in.Name = grpc.Crawlers(grpc.Crawlers_value[conf.Crawler.Name]) - out, err := dc.Get(context.Background(), in) - if err != nil { - log.Println(err) + log.Printf("Cannot collect [ID: %s] [Crawler : %s] - [Err : %s]\n", conf.Id, conf.Crawler.Name, err) } - log.Println("collector get result : ", out) + log.Printf("COLLECTED. [ID: %s] [Crawler : %s] [Result : %s]\n", conf.Id, conf.Crawler.Name, out.GetData() ) c.dataCh <- out }() }