class CassandraBucketDAO {

    public Flux<Pair<BucketName, BlobId>> listAll() {
        return cassandraAsyncExecutor.executeRows(listAll.bind())
            .map(row -> Pair.of(BucketName.of(row.getString(BUCKET)), blobIdFactory.from(row.getString(ID))));
    }

    @Inject @VisibleForTesting public  CassandraBucketDAO(BlobId.Factory blobIdFactory, Session session);

}