in src/main/java/com/epam/digital/data/platform/integration/ceph/service/impl/CephServiceS3Impl.java [214:225]
public List<CephObjectMetadata> getMetadata(String cephBucketName, String keyPrefix) {
log.info("Getting file metadata by key prefix {} from ceph bucket {}", keyPrefix,
cephBucketName);
assertBucketExists(cephAmazonS3, cephBucketName);
var keys = execute(
() -> cephAmazonS3.listObjects(cephBucketName, keyPrefix).getObjectSummaries().stream()
.map(S3ObjectSummary::getKey).collect(Collectors.toSet()));
var result = execute(() -> keys.stream()
.map(k -> cephAmazonS3.getObjectMetadata(cephBucketName, k)).collect(Collectors.toList()));
log.info("Files metadata {} was found in ceph bucket {}", keys, cephBucketName);
return toCephObjectMetadataList(result);
}