in src/main/java/com/epam/digital/data/platform/integration/ceph/service/impl/CephServiceS3Impl.java [172:182]
public Set<String> getKeys(String cephBucketName, String prefix) {
log.info("Getting all ceph keys with prefix {} from ceph bucket {}", prefix, cephBucketName);
assertBucketExists(cephAmazonS3, cephBucketName);
var result = execute(
() -> cephAmazonS3.listObjects(cephBucketName, prefix).getObjectSummaries().stream()
.map(S3ObjectSummary::getKey).collect(Collectors.toSet())
);
log.info("Found {} keys for prefix {} in ceph bucket {}", result.size(), prefix,
cephBucketName);
return result;
}