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

shippingsercice: export traces to stackdriver

Browse source 
Signed-off-by: Ahmet Alp Balkan <ahmetb@google.com>
This commit is contained in:
Ahmet Alp Balkan 2018-07-11 19:55:36 -07:00
parent 6065e871a9
commit 1799f36dc6
2 changed files with 16 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/shippingservice/Dockerfile
View file

@ -7,7 +7,9 @@ WORKDIR /src/microservices-demo/shippingservice
RUN go get -d golang.org/x/net/context \
google.golang.org/grpc \
google.golang.org/grpc/reflection \
go.opencensus.io/plugin/ocgrpc
go.opencensus.io/exporter/stackdriver \
go.opencensus.io/plugin/ocgrpc \
go.opencensus.io/trace
COPY . .
# get other dependencies

15
src/shippingservice/main.go
View file

@ -6,7 +6,9 @@ import (
"net"
"os"
"go.opencensus.io/exporter/stackdriver"
"go.opencensus.io/plugin/ocgrpc"
"go.opencensus.io/trace"
"golang.org/x/net/context"
"google.golang.org/grpc"
"google.golang.org/grpc/reflection"
@ -15,7 +17,7 @@ import (
)
const (
default_port = "50051"
defaultPort = "50051"
)
// server controls RPC service responses.
@ -61,12 +63,21 @@ func (s *server) ShipOrder(ctx context.Context, in *pb.ShipOrderRequest) (*pb.Sh
}
func main() {
port := default_port
port := defaultPort
if value, ok := os.LookupEnv("APP_PORT"); ok {
port = value
}
port = fmt.Sprintf(":%s", port)
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)
log.Println("registered stackdriver tracing")
}
lis, err := net.Listen("tcp", port)
if err != nil {
log.Fatalf("failed to listen: %v", err)