public List getMetadata()

in src/main/java/com/epam/digital/data/platform/integration/ceph/service/impl/CephServiceS3Impl.java [196:211]


  public List<CephObjectMetadata> getMetadata(String cephBucketName, Set<String> keys) {
    log.info("Getting file metadata for keys {} from ceph bucket {}", keys, cephBucketName);
    assertBucketExists(cephAmazonS3, cephBucketName);
    var existingKeys = execute(
        () -> keys.stream().filter(k -> cephAmazonS3.doesObjectExist(cephBucketName, k)).collect(
            Collectors.toList()));
    if (existingKeys.isEmpty()) {
      log.info("Files {} wasn't found in ceph bucket {}", keys, cephBucketName);
      return Collections.emptyList();
    }
    var result = execute(() -> existingKeys.stream()
        .map(k -> cephAmazonS3.getObjectMetadata(cephBucketName, k)).collect(Collectors.toList()));

    log.info("Files metadata {} was found in ceph bucket {}", existingKeys, cephBucketName);
    return toCephObjectMetadataList(result);
  }