Replace grpc.Dial with grpc.NewClient

nttcom · Apr 10, 2024 · a253002 · a253002
1 parent 1688e63
commit a253002
Show file tree

Hide file tree

Showing 8 changed files with 32 additions and 8 deletions.
diff --git a/cmd/pola/root.go b/cmd/pola/root.go
@@ -36,7 +36,10 @@ func newRootCmd() *cobra.Command {
 }
 
 func persistentPreRunE(cmd *cobra.Command, args []string) error {
-	conn, err := grpc.Dial(net.JoinHostPort(cmd.Flag("host").Value.String(), cmd.Flag("port").Value.String()), grpc.WithTransportCredentials(insecure.NewCredentials()))
+	conn, err := grpc.NewClient(
+		net.JoinHostPort(cmd.Flag("host").Value.String(), cmd.Flag("port").Value.String()),
+		grpc.WithTransportCredentials(insecure.NewCredentials()),
+	)
 	if err != nil {
 		return fmt.Errorf("failed to dial polad connection: %v", err)
 	}

diff --git a/internal/pkg/gobgp/interface.go b/internal/pkg/gobgp/interface.go
@@ -30,7 +30,10 @@ func GetBgplsNlris(serverAddr string, serverPort string) ([]table.TedElem, error
 	gobgpAddress := serverAddr + ":" + serverPort
 
 	// Get connection
-	cc, err := grpc.Dial(gobgpAddress, grpc.WithTransportCredentials(insecure.NewCredentials()))
+	cc, err := grpc.NewClient(
+		gobgpAddress,
+		grpc.WithTransportCredentials(insecure.NewCredentials()),
+	)
 	if err != nil {
 		return nil, err
 	}

diff --git a/tools/grpc/go/add_sr-policy/add_sr-policy.go b/tools/grpc/go/add_sr-policy/add_sr-policy.go
@@ -20,7 +20,10 @@ import (
 
 func main() {
 	flag.Parse()
-	conn, err := grpc.Dial("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
+	conn, err := grpc.NewClient(
+		"localhost:50051",
+		grpc.WithTransportCredentials(insecure.NewCredentials()),
+	)
 	if err != nil {
 		log.Fatalf("Can't connect: %v", err)
 	}

diff --git a/tools/grpc/go/add_sr-policy_no_ls/add_sr-policy_no_ls.go b/tools/grpc/go/add_sr-policy_no_ls/add_sr-policy_no_ls.go
@@ -20,7 +20,10 @@ import (
 
 func main() {
 	flag.Parse()
-	conn, err := grpc.Dial("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
+	conn, err := grpc.NewClient(
+		"localhost:50051",
+		grpc.WithTransportCredentials(insecure.NewCredentials()),
+	)
 	if err != nil {
 		log.Fatalf("Can't connect: %v", err)
 	}

diff --git a/tools/grpc/go/del_session/del_session.go b/tools/grpc/go/del_session/del_session.go
@@ -20,7 +20,10 @@ import (
 
 func main() {
 	flag.Parse()
-	conn, err := grpc.Dial("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
+	conn, err := grpc.NewClient(
+		"localhost:50051",
+		grpc.WithTransportCredentials(insecure.NewCredentials()),
+	)
 	if err != nil {
 		log.Fatalf("did not connect: %v", err)
 	}

diff --git a/tools/grpc/go/show_session/show_session.go b/tools/grpc/go/show_session/show_session.go
@@ -22,7 +22,10 @@ import (
 
 func main() {
 	flag.Parse()
-	conn, err := grpc.Dial("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
+	conn, err := grpc.NewClient(
+		"localhost:50051",
+		grpc.WithTransportCredentials(insecure.NewCredentials()),
+	)
 	if err != nil {
 		log.Fatalf("did not connect: %v", err)
 	}

diff --git a/tools/grpc/go/show_sr-policy/show_sr-policy_list.go b/tools/grpc/go/show_sr-policy/show_sr-policy_list.go
@@ -22,7 +22,10 @@ import (
 
 func main() {
 	flag.Parse()
-	conn, err := grpc.Dial("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
+	conn, err := grpc.NewClient(
+		"localhost:50051",
+		grpc.WithTransportCredentials(insecure.NewCredentials()),
+	)
 	if err != nil {
 		log.Fatalf("did not connect: %v", err)
 	}

diff --git a/tools/grpc/go/show_ted/show_ted.go b/tools/grpc/go/show_ted/show_ted.go
@@ -21,7 +21,10 @@ import (
 
 func main() {
 	flag.Parse()
-	conn, err := grpc.Dial("localhost:50051", grpc.WithTransportCredentials(insecure.NewCredentials()))
+	conn, err := grpc.NewClient(
+		"localhost:50051",
+		grpc.WithTransportCredentials(insecure.NewCredentials()),
+	)
 	if err != nil {
 		log.Fatalf("did not connect: %v", err)
 	}