fix comment

pull/1681/head
shedfreewu 2 weeks ago
parent aa4465e027
commit 58427e0498

@ -53,7 +53,6 @@ public class PolarisReactiveDiscoveryClient implements ReactiveDiscoveryClient {
@Override @Override
public Flux<ServiceInstance> getInstances(String serviceId) { public Flux<ServiceInstance> getInstances(String serviceId) {
// TODO: shedfree 服务发现单元化
return Mono.justOrEmpty(serviceId).flatMapMany(loadInstancesFromPolaris()) return Mono.justOrEmpty(serviceId).flatMapMany(loadInstancesFromPolaris())
.subscribeOn(Schedulers.boundedElastic()); .subscribeOn(Schedulers.boundedElastic());
} }

@ -30,6 +30,10 @@ import org.slf4j.LoggerFactory;
import org.springframework.cloud.client.ServiceInstance; import org.springframework.cloud.client.ServiceInstance;
/**
* Support unit discovery.
* TODO: support reactive discovery.
*/
public class UnitPolarisDiscoveryClient extends PolarisDiscoveryClient { public class UnitPolarisDiscoveryClient extends PolarisDiscoveryClient {
private static final Logger LOGGER = LoggerFactory.getLogger(UnitPolarisDiscoveryClient.class); private static final Logger LOGGER = LoggerFactory.getLogger(UnitPolarisDiscoveryClient.class);
@ -49,6 +53,7 @@ public class UnitPolarisDiscoveryClient extends PolarisDiscoveryClient {
@Override @Override
public List<ServiceInstance> getInstances(String service) { public List<ServiceInstance> getInstances(String service) {
if (TencentUnitManager.isEnable()) { 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("/"); String[] parts = service.split("/");
if (LOGGER.isDebugEnabled()) { if (LOGGER.isDebugEnabled()) {
LOGGER.debug("[getInstance] service:{}, unit context:{}", service, TencentUnitContext.getOriginCompositeContextMap()); LOGGER.debug("[getInstance] service:{}, unit context:{}", service, TencentUnitContext.getOriginCompositeContextMap());

@ -378,7 +378,7 @@ public final class TencentUnitManager {
.getOptions()); .getOptions());
break; break;
} }
// TODO: 2023/11/3 支持自定义算法
transformAction.setUnitTransformAlgorithm(unitTransformAlgorithm); transformAction.setUnitTransformAlgorithm(unitTransformAlgorithm);
tagTransform = unitRouteInfo.getTencent().getUnitRouteRule().getTagTransforms().get(0); tagTransform = unitRouteInfo.getTencent().getUnitRouteRule().getTagTransforms().get(0);

Loading…
Cancel
Save