From 58427e04981784709f89dcc9c2e31834798c29a7 Mon Sep 17 00:00:00 2001 From: shedfreewu Date: Tue, 19 Aug 2025 16:35:41 +0800 Subject: [PATCH] fix comment --- .../discovery/reactive/PolarisReactiveDiscoveryClient.java | 1 - .../plugin/unit/discovery/UnitPolarisDiscoveryClient.java | 5 +++++ .../java/com/tencent/tsf/unit/core/TencentUnitManager.java | 2 +- 3 files changed, 6 insertions(+), 2 deletions(-) diff --git a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/discovery/reactive/PolarisReactiveDiscoveryClient.java b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/discovery/reactive/PolarisReactiveDiscoveryClient.java index 07e5d53cf..25607a34c 100644 --- a/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/discovery/reactive/PolarisReactiveDiscoveryClient.java +++ b/spring-cloud-starter-tencent-polaris-discovery/src/main/java/com/tencent/cloud/polaris/discovery/reactive/PolarisReactiveDiscoveryClient.java @@ -53,7 +53,6 @@ public class PolarisReactiveDiscoveryClient implements ReactiveDiscoveryClient { @Override public Flux getInstances(String serviceId) { - // TODO: shedfree 服务发现单元化 return Mono.justOrEmpty(serviceId).flatMapMany(loadInstancesFromPolaris()) .subscribeOn(Schedulers.boundedElastic()); } diff --git a/spring-cloud-tencent-plugin-starters/spring-cloud-tencent-unit-plugin/src/main/java/com/tencent/cloud/plugin/unit/discovery/UnitPolarisDiscoveryClient.java b/spring-cloud-tencent-plugin-starters/spring-cloud-tencent-unit-plugin/src/main/java/com/tencent/cloud/plugin/unit/discovery/UnitPolarisDiscoveryClient.java index 4864ac0bc..507680da9 100644 --- a/spring-cloud-tencent-plugin-starters/spring-cloud-tencent-unit-plugin/src/main/java/com/tencent/cloud/plugin/unit/discovery/UnitPolarisDiscoveryClient.java +++ b/spring-cloud-tencent-plugin-starters/spring-cloud-tencent-unit-plugin/src/main/java/com/tencent/cloud/plugin/unit/discovery/UnitPolarisDiscoveryClient.java @@ -30,6 +30,10 @@ import org.slf4j.LoggerFactory; import org.springframework.cloud.client.ServiceInstance; +/** + * Support unit discovery. + * TODO: support reactive discovery. + */ public class UnitPolarisDiscoveryClient extends PolarisDiscoveryClient { private static final Logger LOGGER = LoggerFactory.getLogger(UnitPolarisDiscoveryClient.class); @@ -49,6 +53,7 @@ public class UnitPolarisDiscoveryClient extends PolarisDiscoveryClient { @Override public List getInstances(String service) { if (TencentUnitManager.isEnable()) { + // if service is not in the format of namespace/service, we will use the namespace in unit context String[] parts = service.split("/"); if (LOGGER.isDebugEnabled()) { LOGGER.debug("[getInstance] service:{}, unit context:{}", service, TencentUnitContext.getOriginCompositeContextMap()); diff --git a/spring-cloud-tencent-plugin-starters/spring-cloud-tencent-unit-plugin/src/main/java/com/tencent/tsf/unit/core/TencentUnitManager.java b/spring-cloud-tencent-plugin-starters/spring-cloud-tencent-unit-plugin/src/main/java/com/tencent/tsf/unit/core/TencentUnitManager.java index d87ed2f30..69625664a 100644 --- a/spring-cloud-tencent-plugin-starters/spring-cloud-tencent-unit-plugin/src/main/java/com/tencent/tsf/unit/core/TencentUnitManager.java +++ b/spring-cloud-tencent-plugin-starters/spring-cloud-tencent-unit-plugin/src/main/java/com/tencent/tsf/unit/core/TencentUnitManager.java @@ -378,7 +378,7 @@ public final class TencentUnitManager { .getOptions()); break; } - // TODO: 2023/11/3 支持自定义算法 + transformAction.setUnitTransformAlgorithm(unitTransformAlgorithm); tagTransform = unitRouteInfo.getTencent().getUnitRouteRule().getTagTransforms().get(0);