public List getMetadata()

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);
  }