in neptune-endpoints-info-lambda/src/main/java/software/amazon/lambda/NeptuneEndpointsInfoLambda.java [115:136]
private void returnEndpointListForLegacyClient(EndpointsType endpointsType,
LambdaLogger logger,
OutputStream output) throws IOException {
logger.log("Returning list of endpoints for EndpointsType: " + endpointsType);
NeptuneClusterMetadata clusterMetadata = addAnnotations(neptuneClusterMetadata.get());
EndpointCollection endpoints = endpointsType.getEndpoints(clusterMetadata);
Collection<String> addresses = new ArrayList<>();
for (Endpoint endpoint : endpoints) {
addresses.add(endpoint.getAddress());
}
String results = String.join(",", addresses);
logger.log("Results: " + results);
try (Writer writer = new BufferedWriter(new OutputStreamWriter(output, UTF_8))) {
writer.write(results);
writer.flush();
}
}