Bump google.golang.org/grpc to v1.63.2 (#564)

Replace usages of grpc.Dial with grpc.NewClient
cloudfoundry · Apr 15, 2024 · 4a08f3b · 4a08f3b
1 parent b84f33a
commit 4a08f3b
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/src/integration_tests/agent_test.go b/src/integration_tests/agent_test.go
@@ -207,7 +207,7 @@ func agentClient(port int, testCerts *testhelper.TestCerts) loggregator_v2.Ingre
 		panic(err)
 	}
 
-	conn, err := grpc.Dial(addr, grpc.WithTransportCredentials(credentials.NewTLS(tlsConfig)))
+	conn, err := grpc.NewClient(addr, grpc.WithTransportCredentials(credentials.NewTLS(tlsConfig)))
 	if err != nil {
 		panic(err)
 	}

diff --git a/src/pkg/clientpool/v1/pusher_fetcher.go b/src/pkg/clientpool/v1/pusher_fetcher.go
@@ -44,7 +44,7 @@ func NewPusherFetcher(mc MetricClient, opts ...grpc.DialOption) *PusherFetcher {
 }
 
 func (p *PusherFetcher) Fetch(addr string) (io.Closer, plumbing.DopplerIngestor_PusherClient, error) {
-	conn, err := grpc.Dial(addr, p.opts...)
+	conn, err := grpc.NewClient(addr, p.opts...)
 	if err != nil {
 		return nil, nil, fmt.Errorf("error dialing ingestor stream to %s: %s", addr, err)
 	}

diff --git a/src/pkg/clientpool/v2/sender_fetcher.go b/src/pkg/clientpool/v2/sender_fetcher.go
@@ -44,7 +44,7 @@ func NewSenderFetcher(mc MetricClient, opts ...grpc.DialOption) *SenderFetcher {
 }
 
 func (p *SenderFetcher) Fetch(addr string) (io.Closer, loggregator_v2.Ingress_BatchSenderClient, error) {
-	conn, err := grpc.Dial(addr, p.opts...)
+	conn, err := grpc.NewClient(addr, p.opts...)
 	if err != nil {
 		return nil, nil, fmt.Errorf("error dialing ingestor stream to %s: %s", addr, err)
 	}

diff --git a/src/pkg/otelcolclient/otelcolclient.go b/src/pkg/otelcolclient/otelcolclient.go
@@ -33,7 +33,7 @@ type GRPCWriter struct {
 
 // NewGRPCWriter dials the provided gRPC address and returns a *GRPCWriter.
 func NewGRPCWriter(addr string, tlsConfig *tls.Config, l *log.Logger) (*GRPCWriter, error) {
-	cc, err := grpc.Dial(addr, grpc.WithTransportCredentials(credentials.NewTLS(tlsConfig)))
+	cc, err := grpc.NewClient(addr, grpc.WithTransportCredentials(credentials.NewTLS(tlsConfig)))
 	if err != nil {
 		return nil, err
 	}