public Set getKeys()

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