update

Author: wenfengwang

deploy/yaml/controller.yaml

@@ -21,7 +21,6 @@ data:
     name: ${POD_NAME}
     ip: ${POD_IP}
     port: 2048
-    gateway_endpoint: http://192.168.49.2:30001
     etcd:
       - vanus-controller-0.vanus-controller.vanus.svc:2379
       - vanus-controller-1.vanus-controller.vanus.svc:2379

internal/controller/config.go

@@ -34,7 +34,6 @@ type Config struct {
 	EtcdConfig           embedetcd.Config  `yaml:"embed_etcd"`
 	Topology             map[string]string `yaml:"topology"`
 	Replicas             uint              `yaml:"replicas"`
-	GatewayEndpoint      string            `yaml:"gateway_endpoint"`
 }
 
 func (c *Config) GetEtcdConfig() embedetcd.Config {
@@ -51,7 +50,6 @@ func (c *Config) GetEventbusCtrlConfig() eventbus.Config {
 		KVKeyPrefix:      c.MetadataConfig.KeyPrefix,
 		Replicas:         c.Replicas,
 		Topology:         c.Topology,
-		GatewayEndpoint:  c.GatewayEndpoint,
 	}
 }
 

internal/controller/eventbus/config.go

@@ -24,5 +24,4 @@ type Config struct {
 	EtcdConfig       embedetcd.Config  `yaml:"etcd"`
 	Replicas         uint              `yaml:"replicas"`
 	Topology         map[string]string `yaml:"topology"`
-	GatewayEndpoint  string            `yaml:"gateway_endpoint"`
 }

internal/controller/eventbus/controller.go

@@ -424,8 +424,7 @@ func (ctrl *controller) ReportSegmentBlockIsFull(ctx context.Context,
 
 func (ctrl *controller) Ping(_ context.Context, _ *emptypb.Empty) (*ctrlpb.PingResponse, error) {
 	return &ctrlpb.PingResponse{
-		LeaderAddr:  ctrl.member.GetLeaderAddr(),
-		GatewayAddr: ctrl.cfg.GatewayEndpoint,
+		LeaderAddr: ctrl.member.GetLeaderAddr(),
 	}, nil
 }
 

internal/gateway/grpc_proxy_test.go

@@ -33,7 +33,7 @@ import (
 	"google.golang.org/grpc"
 )
 
-func Test_A(t *testing.T) {
+func Test_ControllerProxy(t *testing.T) {
 	Convey("test grpc reverse proxy", t, func() {
 		listen1, err := net.Listen("tcp", fmt.Sprintf(":%d", 20001))
 		So(err, ShouldBeNil)