in mode/cluster/repository/nacos/src/main/java/org/apache/shardingsphere/mode/repository/cluster/nacos/listener/NamingEventListener.java [111:121]
public void setPreInstances(final Collection<Instance> instances) {
preInstances = instances.stream().filter(instance -> {
for (String each : prefixListenerMap.keySet()) {
if (NacosMetaDataUtils.getKey(instance).startsWith(each)) {
return true;
}
}
return false;
}).collect(Collectors.toMap(NacosMetaDataUtils::getKey, Function.identity(),
(oldValue, currentValue) -> NacosMetaDataUtils.getTimestamp(oldValue) > NacosMetaDataUtils.getTimestamp(currentValue) ? oldValue : currentValue));
}