diff --git a/control_plane.go b/control_plane.go index 692fa9e..be0a9b6 100644 --- a/control_plane.go +++ b/control_plane.go @@ -59,7 +59,7 @@ func NewControlPlane() (*ControlPlane, error) { } cp.server = transport.NewServer(uint32(10246), []model.SubscribeRequestHandler{cp.handleSubscribeRequest}) - cp.xdsServer = transport.NewDiscoveryServer(uint32(8002), []model.SubscribeXDsRequestHandler{cp.handleXDSSubscribeRequest}) + cp.xdsServer = transport.NewDiscoveryServer(uint32(10248), []model.SubscribeXDsRequestHandler{cp.handleXDSSubscribeRequest}) cp.operator = operator hostname, herr := os.Hostname() diff --git a/pkg/test/xDSClient_test.go b/pkg/test/xDSClient_test.go index f512745..8c6a500 100644 --- a/pkg/test/xDSClient_test.go +++ b/pkg/test/xDSClient_test.go @@ -10,7 +10,7 @@ import ( func TestXDSClient(t *testing.T) { // Define the address of the server - serverAddr := ":8002" // Replace with the actual address + serverAddr := ":10248" // Replace with the actual address // Create a new XDSClient instance client := grpc.NewxDSClient(serverAddr, "testNode", []string{controller.FaultToleranceRuleKind, controller.ThrottlingStrategyKind})