DeploymentsDao.java 文件源码

public List<Deployment> getDeployments(String clusterId) {
    List<Deployment> deployments = new ArrayList<>();
    Block<Document> printBlock = new Block<Document>() {
        @Override
        public void apply(final Document document) {
            Deployment deployment = new Deployment();
            deployment.setUuid(document.getString("uuid"));
            deployment.setStatus(document.getString("status"));
            deployment.setHostCount(document.getInteger("hostCount"));
            deployment.setCompletedCount(document.getInteger("completedCount"));
            TarFile tarFile = new TarFile();
            tarFile.setUrl(document.getString("sourceTar"));
            deployment.setSourceTar(tarFile);
            deployment.setTimestamp(document.getDate("timestamp"));
            deployments.add(deployment);
        }
    };

    connection.getCollection(DEPLOYMENTS_COLLECTION_NAME).find(eq("clusterId", clusterId)).forEach(printBlock);
    return deployments;
}