Replace deplecated function in otelgrpc for go (#1284)

open-telemetry · Dec 1, 2023 · 8124353 · 8124353
1 parent 18942fb
commit 8124353
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 8 deletions.
diff --git a/src/checkoutservice/main.go b/src/checkoutservice/main.go
@@ -181,8 +181,7 @@ func main() {
  }
 
  var srv = grpc.NewServer(
- grpc.UnaryInterceptor(otelgrpc.UnaryServerInterceptor()),
- grpc.StreamInterceptor(otelgrpc.StreamServerInterceptor()),
+ grpc.StatsHandler(otelgrpc.NewServerHandler()),
  )
  pb.RegisterCheckoutServiceServer(srv, svc)
  healthpb.RegisterHealthServer(srv, svc)
@@ -343,8 +342,7 @@ func (cs *checkoutService) prepareOrderItemsAndShippingQuoteFromCart(ctx context
 func createClient(ctx context.Context, svcAddr string) (*grpc.ClientConn, error) {
  return grpc.DialContext(ctx, svcAddr,
  grpc.WithTransportCredentials(insecure.NewCredentials()),
- grpc.WithUnaryInterceptor(otelgrpc.UnaryClientInterceptor()),
- grpc.WithStreamInterceptor(otelgrpc.StreamClientInterceptor()),
+ grpc.WithStatsHandler(otelgrpc.NewClientHandler()),
  )
 }
 

diff --git a/src/productcatalogservice/main.go b/src/productcatalogservice/main.go
@@ -141,8 +141,7 @@ func main() {
  }
 
  srv := grpc.NewServer(
- grpc.UnaryInterceptor(otelgrpc.UnaryServerInterceptor()),
- grpc.StreamInterceptor(otelgrpc.StreamServerInterceptor()),
+ grpc.StatsHandler(otelgrpc.NewServerHandler()),
  )
 
  reflection.Register(srv)
@@ -278,7 +277,6 @@ func (p *productCatalog) checkProductFailure(ctx context.Context, id string) boo
 func createClient(ctx context.Context, svcAddr string) (*grpc.ClientConn, error) {
  return grpc.DialContext(ctx, svcAddr,
  grpc.WithTransportCredentials(insecure.NewCredentials()),
- grpc.WithUnaryInterceptor(otelgrpc.UnaryClientInterceptor()),
- grpc.WithStreamInterceptor(otelgrpc.StreamClientInterceptor()),
+ grpc.WithStatsHandler(otelgrpc.NewClientHandler()),
  )
 }