fix(cluster): Fix lint error

ab180 · Dec 13, 2022 · 0d8bb70 · 0d8bb70
1 parent ab69c60
commit 0d8bb70
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/cluster/cluster.go b/cluster/cluster.go
@@ -15,6 +15,7 @@ import (
 	"google.golang.org/grpc/codes"
 	"google.golang.org/grpc/connectivity"
 	"google.golang.org/grpc/credentials"
+	"google.golang.org/grpc/credentials/insecure"
 	"google.golang.org/grpc/status"
 )
 
@@ -79,7 +80,7 @@ func OpenRemote(clusterState coordinator.Coordinator, opt Options) (Cluster, err
 		grpcOpts = append(grpcOpts, grpc.WithTransportCredentials(cert))
 	} else {
 		// log.Warn("inter-node RPC is in insecure mode. we recommend configuring TLS credentials.")
-		grpcOpts = append(grpcOpts, grpc.WithInsecure())
+		grpcOpts = append(grpcOpts, grpc.WithTransportCredentials(insecure.NewCredentials()))
 	}
 
 	ctx, cancel := context.WithCancel(context.Background())

diff --git a/cluster/cluster_test.go b/cluster/cluster_test.go
@@ -21,6 +21,7 @@ import (
 	"golang.org/x/net/nettest"
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/connectivity"
+	"google.golang.org/grpc/credentials/insecure"
 )
 
 const (
@@ -194,7 +195,8 @@ func WithTestNodes(t *testing.T, cluster cluster.Cluster, fn func(nodes []node.R
 			}(i)
 
 			// Wait until the grpc server starts
-			conn, err := grpc.Dial(lis.Addr().String(), grpc.WithInsecure(), grpc.WithBlock())
+			conn, err := grpc.Dial(
+				lis.Addr().String(), grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithBlock())
 			require.Nil(t, err)
 			conn.Close()