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

Merge branch 'master' of https://git.loafle.net/overflow/overflow_probe

Browse Source
This commit is contained in:
insanity@loafle.com 2017-08-04 12:11:54 +09:00
commit f0cd311ed0
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
crawler_manager/crawler_communicator.go
View File

@ -3,8 +3,8 @@ package crawler_manager
import ( import (
"context" "context"
g "git.loafle.net/overflow/overflow_probe/crawler/grpc" g "git.loafle.net/overflow/overflow_probe/crawler/grpc"
"google.golang.org/grpc"
log "github.com/cihub/seelog" log "github.com/cihub/seelog"
"google.golang.org/grpc"
"encoding/json" "encoding/json"
"git.loafle.net/overflow/overflow_probe/agent_api/config_manager" "git.loafle.net/overflow/overflow_probe/agent_api/config_manager"
@ -17,7 +17,7 @@ func callAdd(container *string, conf *config_manager.Config) bool {
conn, err := grpc.Dial(address+port, grpc.WithInsecure()) conn, err := grpc.Dial(address+port, grpc.WithInsecure())
if err != nil { if err != nil {
//log.Fatalf("did not connect: %v", err) //log.Fatalf("did not connect: %v", err)
log.Error( err) log.Error(err)
return false return false
} }
defer conn.Close() defer conn.Close()
@ -62,7 +62,7 @@ func callInitConfig(container *string, cl []*config_manager.Config) bool {
conn, err := grpc.Dial(address+port, grpc.WithInsecure()) conn, err := grpc.Dial(address+port, grpc.WithInsecure())
if err != nil { if err != nil {
//log.Fatalf("did not connect: %v", err) //log.Fatalf("did not connect: %v", err)
log.Error( err) log.Error(err)
return false return false
} }
defer conn.Close() defer conn.Close()
@ -148,7 +148,7 @@ func callRemove(container *string, conf *config_manager.Config) {
if err != nil { if err != nil {
//log.Fatalf("did not connect: %v", err) //log.Fatalf("did not connect: %v", err)
log.Error( err) log.Error(err)
} }
defer conn.Close() defer conn.Close()