chore: Replace deprecated grpc.Dial calls

Signed-off-by: Philipp Schuler <philipp.schuler@command-b.de>

Author: philicious

protocol/pubsub/v2/internal/connection_test.go

@@ -18,6 +18,7 @@ import (
 	"github.com/google/go-cmp/cmp"
 	"google.golang.org/api/option"
 	"google.golang.org/grpc"
+	"google.golang.org/grpc/credentials/insecure"
 	"google.golang.org/protobuf/types/known/durationpb"
 )
 
@@ -47,9 +48,9 @@ func (pc *testPubsubClient) New(ctx context.Context, projectID string, failureMa
 	var err error
 	var conn *grpc.ClientConn
 	if len(failureMap) == 0 {
-		conn, err = grpc.Dial(pc.srv.Addr, grpc.WithInsecure())
+		conn, err = grpc.NewClient(pc.srv.Addr, grpc.WithTransportCredentials(insecure.NewCredentials()))
 	} else {
-		conn, err = grpc.Dial(pc.srv.Addr, grpc.WithInsecure(), grpc.WithUnaryInterceptor(makeFailureIntercept(failureMap)))
+		conn, err = grpc.NewClient(pc.srv.Addr, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithUnaryInterceptor(makeFailureIntercept(failureMap)))
 
 	}
 	if err != nil {

protocol/pubsub/v2/protocol_test.go

@@ -24,7 +24,7 @@ type testPubsubClient struct {
 
 func (pc *testPubsubClient) NewWithAttributesInterceptor(ctx context.Context, projectID, orderingKey string) (*pubsub.Client, error) {
 	pc.srv = pstest.NewServer()
-	conn, err := grpc.Dial(pc.srv.Addr, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithUnaryInterceptor(customAttributesInterceptor(map[string]string{
+	conn, err := grpc.NewClient(pc.srv.Addr, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithUnaryInterceptor(customAttributesInterceptor(map[string]string{
 		"Content-Type":        "text/json",
 		"ce-dataschema":       "http://example.com/schema",
 		"ce-exbinary":         "AAECAw==",
@@ -50,7 +50,7 @@ func (pc *testPubsubClient) NewWithAttributesInterceptor(ctx context.Context, pr
 
 func (pc *testPubsubClient) NewWithOrderInterceptor(ctx context.Context, projectID, orderingKey string) (*pubsub.Client, error) {
 	pc.srv = pstest.NewServer()
-	conn, err := grpc.Dial(pc.srv.Addr, grpc.WithInsecure(), grpc.WithUnaryInterceptor(orderingKeyInterceptor(orderingKey)))
+	conn, err := grpc.NewClient(pc.srv.Addr, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithUnaryInterceptor(orderingKeyInterceptor(orderingKey)))
 	if err != nil {
 		return nil, err
 	}