Skip to content

Commit

Permalink
optimize grpc client
Browse files Browse the repository at this point in the history
  • Loading branch information
mehrdadrad committed Dec 17, 2020
1 parent 8f38abe commit a48493c
Showing 1 changed file with 11 additions and 6 deletions.
17 changes: 11 additions & 6 deletions grpc.go
Expand Up @@ -115,26 +115,31 @@ func grpcClient(req *request) {

c := pb.NewTCPProbeClient(conn)

labels := map[string]string{}
json.Unmarshal([]byte(req.cmd.labels), &labels)

for _, target := range req.cmd.args {
labels := map[string]string{}
json.Unmarshal([]byte(req.cmd.labels), &labels)

pt := &pb.Target{
Addr: target,
Interval: req.cmd.interval,
Labels: labels,
}
if req.cmd.cmd != "del" {
resp, err = c.Add(ctx, pt)

} else {
switch req.cmd.cmd {
case "add":
resp, err = c.Add(ctx, pt)
case "del":
resp, err = c.Delete(ctx, pt)
default:
log.Printf("%s doesn't support", req.cmd.cmd)
return
}

if err != nil {
log.Println(err)
} else {
log.Printf("message: %s, code: %d", resp.Message, resp.Code)
log.Printf("%s - %s", resp.Message, target)
}
}
}
Expand Down

0 comments on commit a48493c

Please sign in to comment.