vbatts/microservices-demo
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

shippingservice: move initTrace() to a func

Browse source 
Signed-off-by: Ahmet Alp Balkan <ahmetb@google.com>
This commit is contained in:
Ahmet Alp Balkan 2018-07-12 14:56:51 -07:00
parent 062b325c1e
commit 5a32ddf0ff
1 changed files with 13 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
src/shippingservice/main.go
View file

@ -69,15 +69,7 @@ func main() {
} }
port = fmt.Sprintf(":%s", port) port = fmt.Sprintf(":%s", port)
exporter, err := stackdriver.NewExporter(stackdriver.Options{}) initTrace()
if err != nil {
log.Printf("failed to initialize stackdriver exporter: %+v", err)
log.Println("skipping uploading traces to stackdriver")
} else {
trace.RegisterExporter(exporter)
trace.ApplyConfig(trace.Config{DefaultSampler: trace.AlwaysSample()})
log.Println("registered stackdriver tracing")
}
lis, err := net.Listen("tcp", port) lis, err := net.Listen("tcp", port)
if err != nil { if err != nil {
@ -93,3 +85,15 @@ func main() {
log.Fatalf("failed to serve: %v", err) log.Fatalf("failed to serve: %v", err)
} }
} }
func initTrace() {
exporter, err := stackdriver.NewExporter(stackdriver.Options{})
if err != nil {
log.Printf("failed to initialize stackdriver exporter: %+v", err)
log.Println("skipping uploading traces to stackdriver")
} else {
trace.RegisterExporter(exporter)
trace.ApplyConfig(trace.Config{DefaultSampler: trace.AlwaysSample()})
log.Println("registered stackdriver tracing")
}
}