From 7fa8414b9abdbeee39a018dc897064f6c7cb01d4 Mon Sep 17 00:00:00 2001 From: alanprot Date: Fri, 29 Nov 2024 12:11:44 -0800 Subject: [PATCH] Replacing deprecated methofs Signed-off-by: alanprot --- httpgrpc/server/server.go | 2 +- middleware/grpc_stats_test.go | 4 ++-- server/server_test.go | 6 +++--- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/httpgrpc/server/server.go b/httpgrpc/server/server.go index a54dd46f..2d82cb65 100644 --- a/httpgrpc/server/server.go +++ b/httpgrpc/server/server.go @@ -137,7 +137,7 @@ func NewClient(address string) (*Client, error) { ), } - conn, err := grpc.Dial(address, dialOptions...) + conn, err := grpc.NewClient(address, dialOptions...) if err != nil { return nil, err } diff --git a/middleware/grpc_stats_test.go b/middleware/grpc_stats_test.go index bb6fe573..00438f21 100644 --- a/middleware/grpc_stats_test.go +++ b/middleware/grpc_stats_test.go @@ -56,7 +56,7 @@ func TestGrpcStats(t *testing.T) { grpc_health_v1.RegisterHealthServer(serv, health.NewServer()) closed := false - conn, err := grpc.Dial(listener.Addr().String(), grpc.WithTransportCredentials(insecure.NewCredentials())) + conn, err := grpc.NewClient(listener.Addr().String(), grpc.WithTransportCredentials(insecure.NewCredentials())) require.NoError(t, err) defer func() { if !closed { @@ -149,7 +149,7 @@ func TestGrpcStatsStreaming(t *testing.T) { middleware_test.RegisterEchoServerServer(serv, &halfEcho{log: t.Log}) - conn, err := grpc.Dial(listener.Addr().String(), grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(10e6), grpc.MaxCallSendMsgSize(10e6))) + conn, err := grpc.NewClient(listener.Addr().String(), grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(10e6), grpc.MaxCallSendMsgSize(10e6))) require.NoError(t, err) defer func() { require.NoError(t, conn.Close()) diff --git a/server/server_test.go b/server/server_test.go index 437a0aa9..c3bae254 100644 --- a/server/server_test.go +++ b/server/server_test.go @@ -128,7 +128,7 @@ func TestDefaultAddresses(t *testing.T) { go server.Run() //nolint:errcheck defer server.Shutdown() - conn, err := grpc.Dial("localhost:9095", grpc.WithTransportCredentials(insecure.NewCredentials())) + conn, err := grpc.NewClient("localhost:9095", grpc.WithTransportCredentials(insecure.NewCredentials())) require.NoError(t, err) defer conn.Close() //nolint:errcheck @@ -169,7 +169,7 @@ func TestErrorInstrumentationMiddleware(t *testing.T) { go server.Run() //nolint:errcheck - conn, err := grpc.Dial("localhost:1234", grpc.WithTransportCredentials(insecure.NewCredentials())) + conn, err := grpc.NewClient("localhost:1234", grpc.WithTransportCredentials(insecure.NewCredentials())) require.NoError(t, err) defer conn.Close() //nolint:errcheck @@ -583,7 +583,7 @@ func TestTLSServer(t *testing.T) { expected := []byte("Hello World!") require.Equal(t, expected, body) - conn, err := grpc.Dial("localhost:9194", grpc.WithTransportCredentials(credentials.NewTLS(tlsConfig))) + conn, err := grpc.NewClient("localhost:9194", grpc.WithTransportCredentials(credentials.NewTLS(tlsConfig))) require.NoError(t, err) defer conn.Close() //nolint:errcheck