in mode/cluster/repository/nacos/src/main/java/org/apache/shardingsphere/mode/repository/cluster/nacos/NacosRepository.java [162:174]
public String query(final String key) {
try {
for (ServiceMetaData each : serviceController.getAllServices()) {
Optional<Instance> instance = findExistedInstance(key, each.isEphemeral()).stream().max(Comparator.comparing(NacosMetaDataUtils::getTimestamp));
if (instance.isPresent()) {
return NacosMetaDataUtils.getValue(instance.get());
}
}
return null;
} catch (final NacosException ex) {
throw new ClusterRepositoryPersistException(ex);
}
}