|
45 | 45 | import com.tencent.polaris.plugins.connector.common.ServiceUpdateTask; |
46 | 46 | import com.tencent.polaris.specification.api.v1.model.ModelProto.Location; |
47 | 47 | import com.tencent.polaris.specification.api.v1.service.manage.ResponseProto; |
| 48 | +import com.tencent.polaris.specification.api.v1.service.manage.ResponseProto.DiscoverResponse.DiscoverResponseType; |
48 | 49 | import com.tencent.polaris.specification.api.v1.service.manage.ServiceProto; |
49 | 50 | import java.nio.charset.StandardCharsets; |
50 | 51 | import java.security.NoSuchAlgorithmException; |
@@ -171,6 +172,7 @@ public void onEvent(Event event) { |
171 | 172 | ResponseProto.DiscoverResponse.Builder newDiscoverResponseBuilder = ResponseProto.DiscoverResponse.newBuilder(); |
172 | 173 | newDiscoverResponseBuilder.setService(service); |
173 | 174 | newDiscoverResponseBuilder.addAllInstances(polarisInstanceList); |
| 175 | + newDiscoverResponseBuilder.setType(DiscoverResponseType.INSTANCE); |
174 | 176 | int code = ServerCodes.EXECUTE_SUCCESS; |
175 | 177 | newDiscoverResponseBuilder.setCode(UInt32Value.of(code)); |
176 | 178 | // notify to polaris-java |
@@ -267,7 +269,7 @@ private void syncGetService(ServiceUpdateTask serviceUpdateTask) { |
267 | 269 | ResponseProto.DiscoverResponse.Builder newDiscoverResponseBuilder = ResponseProto.DiscoverResponse.newBuilder(); |
268 | 270 | newDiscoverResponseBuilder.setService(newService); |
269 | 271 | newDiscoverResponseBuilder.addAllServices(newServiceList); |
270 | | - |
| 272 | + newDiscoverResponseBuilder.setType(DiscoverResponseType.SERVICES); |
271 | 273 | int code = ServerCodes.EXECUTE_SUCCESS; |
272 | 274 | newDiscoverResponseBuilder.setCode(UInt32Value.of(code)); |
273 | 275 | LOG.debug("nacos client get service {} success. ", |
|
0 commit comments