in gremlin-client/src/main/java/software/amazon/neptune/cluster/CommonClusterEndpointsFetchStrategy.java [35:53]
public Map<? extends EndpointsSelector, EndpointCollection> getEndpoints(Collection<? extends EndpointsSelector> selectors, boolean refresh) {
if (refresh) {
return refreshEndpoints(selectors);
}
NeptuneClusterMetadata clusterMetadata = clusterMetadataSupplier().getClusterMetadata();
if (clusterMetadata == null) {
return refreshEndpoints(selectors);
}
Map<EndpointsSelector, EndpointCollection> results = new HashMap<>();
for (EndpointsSelector selector : selectors) {
results.put(selector, clusterMetadata.select(selector));
}
return results;
}