update

Author: wenfengwang

vsctl/command/eventbus.go

@@ -51,7 +51,7 @@ func createEventbusCommand() *cobra.Command {
 				cmdFailedf(cmd, "the --name flag MUST be set")
 			}
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()
@@ -92,7 +92,7 @@ func deleteEventbusCommand() *cobra.Command {
 				cmdFailedf(cmd, "the --name flag MUST be set")
 			}
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()
@@ -137,7 +137,7 @@ func getEventbusInfoCommand() *cobra.Command {
 				buses = strings.Split(eventbus, ",")
 			}
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()
@@ -306,7 +306,7 @@ func listEventbusInfoCommand() *cobra.Command {
 		Short: "list the eventbus",
 		Run: func(cmd *cobra.Command, args []string) {
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()

vsctl/command/grpc.go

@@ -27,7 +27,7 @@ import (
 	"google.golang.org/grpc/credentials/insecure"
 )
 
-func mustGatewayProxyGRPCConn(ctx context.Context, cmd *cobra.Command) *grpc.ClientConn {
+func mustGetControllerProxyConn(ctx context.Context, cmd *cobra.Command) *grpc.ClientConn {
 	splits := strings.Split(mustGetGatewayEndpoint(cmd), ":")
 	port, err := strconv.Atoi(splits[1])
 	if err != nil {

vsctl/command/meta.go

@@ -49,7 +49,7 @@ func getControllerTopology() *cobra.Command {
 		Short: "get topology",
 		Run: func(cmd *cobra.Command, args []string) {
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()

vsctl/command/subscription.go

@@ -52,7 +52,7 @@ func createSubscriptionCommand() *cobra.Command {
 				cmdFailedWithHelpNotice(cmd, "sink name can't be empty\n")
 			}
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()
@@ -126,7 +126,7 @@ func deleteSubscriptionCommand() *cobra.Command {
 				cmdFailedWithHelpNotice(cmd, "subscriptionID name can't be empty\n")
 			}
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()
@@ -168,7 +168,7 @@ func getSubscriptionCommand() *cobra.Command {
 				cmdFailedWithHelpNotice(cmd, "subscriptionID name can't be empty\n")
 			}
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()
@@ -212,7 +212,7 @@ func listSubscriptionCommand() *cobra.Command {
 		Short: "list the subscription ",
 		Run: func(cmd *cobra.Command, args []string) {
 			ctx := context.Background()
-			grpcConn := mustGatewayProxyGRPCConn(ctx, cmd)
+			grpcConn := mustGetControllerProxyConn(ctx, cmd)
 			defer func() {
 				_ = grpcConn.Close()
 			}()