treewide: replace deprecated grpc.Dial with grpc.NewClient
Change-Id: I925912ca1ee01d547fd9c1813eb083a2cd9a590a
Reviewed-on: https://review.monogon.dev/c/monogon/+/3858
Reviewed-by: Jan Schär <jan@monogon.tech>
Tested-by: Jenkins CI
diff --git a/metropolis/test/e2e/suites/core/run_test.go b/metropolis/test/e2e/suites/core/run_test.go
index 692969d..dca9b7d 100644
--- a/metropolis/test/e2e/suites/core/run_test.go
+++ b/metropolis/test/e2e/suites/core/run_test.go
@@ -104,10 +104,10 @@
// Dial first node's curator.
creds := rpc.NewAuthenticatedCredentials(cluster.Owner, rpc.WantInsecure())
- remote := net.JoinHostPort(cluster.NodeIDs[0], common.CuratorServicePort.PortString())
- cl, err := grpc.Dial(remote, grpc.WithContextDialer(cluster.DialNode), grpc.WithTransportCredentials(creds))
+ remote := net.JoinHostPort(cluster.Nodes[cluster.NodeIDs[0]].ManagementAddress, common.CuratorServicePort.PortString())
+ cl, err := grpc.NewClient(remote, grpc.WithContextDialer(cluster.DialNode), grpc.WithTransportCredentials(creds))
if err != nil {
- t.Fatalf("failed to dial first node's curator: %v", err)
+ t.Fatalf("failed to create first node's curator client: %v", err)
}
defer cl.Close()
mgmt := apb.NewManagementClient(cl)
diff --git a/metropolis/test/launch/cluster.go b/metropolis/test/launch/cluster.go
index dab453b..a0075ed 100644
--- a/metropolis/test/launch/cluster.go
+++ b/metropolis/test/launch/cluster.go
@@ -206,20 +206,16 @@
r := resolver.New(c.ctxT, resolver.WithLogger(logging.NewFunctionBackend(func(severity logging.Severity, msg string) {
launch.Log("Cluster: client resolver: %s: %s", severity, msg)
})))
- for _, n := range c.NodeIDs {
- ep, err := resolver.NodeWithDefaultPort(n)
- if err != nil {
- return nil, fmt.Errorf("could not add node %q by DNS: %w", n, err)
- }
- r.AddEndpoint(ep)
+ for _, n := range c.Nodes {
+ r.AddEndpoint(resolver.NodeAtAddressWithDefaultPort(n.ManagementAddress))
}
- authClient, err := grpc.Dial(resolver.MetropolisControlAddress,
+ authClient, err := grpc.NewClient(resolver.MetropolisControlAddress,
grpc.WithTransportCredentials(authCreds),
grpc.WithResolvers(r),
grpc.WithContextDialer(c.DialNode),
)
if err != nil {
- return nil, fmt.Errorf("dialing with owner credentials failed: %w", err)
+ return nil, fmt.Errorf("creating client with owner credentials failed: %w", err)
}
c.authClient = authClient
}
@@ -651,12 +647,13 @@
// NodeInCluster represents information about a node that's part of a Cluster.
type NodeInCluster struct {
- // ID of the node, which can be used to dial this node's services via DialNode.
+ // ID of the node, which can be used to dial this node's services via
+ // NewNodeClient.
ID string
Pubkey []byte
- // Address of the node on the network ran by nanoswitch. Not reachable from the
- // host unless dialed via DialNode or via the nanoswitch SOCKS proxy (reachable
- // on Cluster.Ports[SOCKSPort]).
+ // Address of the node on the network ran by nanoswitch. Not reachable from
+ // the host unless dialed via NewNodeClient or via the nanoswitch SOCKS
+ // proxy (reachable on Cluster.Ports[SOCKSPort]).
ManagementAddress string
}
@@ -677,9 +674,9 @@
initDialer := func(_ context.Context, addr string) (net.Conn, error) {
return socksDialer.Dial("tcp", addr)
}
- initClient, err := grpc.Dial(remote, grpc.WithContextDialer(initDialer), grpc.WithTransportCredentials(initCreds))
+ initClient, err := grpc.NewClient(remote, grpc.WithContextDialer(initDialer), grpc.WithTransportCredentials(initCreds))
if err != nil {
- return nil, nil, fmt.Errorf("dialing with ephemeral credentials failed: %w", err)
+ return nil, nil, fmt.Errorf("creating client with ephemeral credentials failed: %w", err)
}
defer initClient.Close()
@@ -705,9 +702,9 @@
// Now connect authenticated and get the node ID.
creds := rpc.NewAuthenticatedCredentials(*cert, rpc.WantInsecure())
- authClient, err := grpc.Dial(remote, grpc.WithContextDialer(initDialer), grpc.WithTransportCredentials(creds))
+ authClient, err := grpc.NewClient(remote, grpc.WithContextDialer(initDialer), grpc.WithTransportCredentials(creds))
if err != nil {
- return nil, nil, fmt.Errorf("dialing with owner credentials failed: %w", err)
+ return nil, nil, fmt.Errorf("creating client with owner credentials failed: %w", err)
}
defer authClient.Close()
mgmt := apb.NewManagementClient(authClient)
@@ -1258,7 +1255,7 @@
//
// For example:
//
-// grpc.Dial("metropolis-deadbeef:1234", grpc.WithContextDialer(c.DialNode))
+// grpc.NewClient("passthrough:///metropolis-deadbeef:1234", grpc.WithContextDialer(c.DialNode))
func (c *Cluster) DialNode(_ context.Context, addr string) (net.Conn, error) {
host, port, err := net.SplitHostPort(addr)
if err != nil {
diff --git a/metropolis/test/util/curator.go b/metropolis/test/util/curator.go
index 35c0b97..a4b76ff 100644
--- a/metropolis/test/util/curator.go
+++ b/metropolis/test/util/curator.go
@@ -105,9 +105,9 @@
withLocalDialer := grpc.WithContextDialer(func(_ context.Context, _ string) (net.Conn, error) {
return externalLis.Dial()
})
- cl, err := grpc.Dial("local", withLocalDialer, grpc.WithTransportCredentials(insecure.NewCredentials()))
+ cl, err := grpc.NewClient("passthrough:///local", withLocalDialer, grpc.WithTransportCredentials(insecure.NewCredentials()))
if err != nil {
- t.Fatalf("Dialing GRPC failed: %v", err)
+ t.Fatalf("Creating GRPC Client failed: %v", err)
}
return cur, cl