本文整理了Java中com.palantir.docker.compose.DockerComposeRule.docker()方法的一些代码示例，展示了DockerComposeRule.docker()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。DockerComposeRule.docker()方法的具体详情如下：
包路径：com.palantir.docker.compose.DockerComposeRule
类名称：DockerComposeRule
方法名：docker

DockerComposeRule.docker介绍

暂无

代码示例

代码示例来源：origin: com.palantir.docker.compose/docker-compose-rule

private void removeContainers(DockerComposeRule rule, List<ContainerName> running) throws IOException, InterruptedException {
  List<String> rawContainerNames = running.stream()
      .map(ContainerName::rawName)
      .collect(toList());
  rule.docker().rm(rawContainerNames);
  log.debug("Finished shutdown");
}

代码示例来源：origin: palantir/docker-compose-rule

@Override
public void after() {
  try {
    shutdownStrategy().shutdown(this.dockerCompose(), this.docker());
    logCollector().stopCollecting();
  } catch (IOException | InterruptedException e) {
    throw new RuntimeException("Error cleaning up docker compose cluster", e);
  }
}

代码示例来源：origin: com.palantir.docker.compose/docker-compose-rule-junit4

@Override
public void after() {
  try {
    shutdownStrategy().shutdown(this.dockerCompose(), this.docker());
    logCollector().stopCollecting();
  } catch (IOException | InterruptedException e) {
    throw new RuntimeException("Error cleaning up docker compose cluster", e);
  }
}

代码示例来源：origin: com.palantir.docker.compose/docker-compose-rule

private void removeContainers(DockerComposeRule rule, List<ContainerName> running) throws IOException, InterruptedException {
  List<String> rawContainerNames = running.stream()
      .map(ContainerName::rawName)
      .collect(toList());
  rule.docker().rm(rawContainerNames);
  log.debug("Finished shutdown");
}

代码示例来源：origin: com.palantir.docker.compose/docker-compose-rule-junit4

@Override
public void before() throws IOException, InterruptedException {
  log.debug("Starting docker-compose cluster");
  dockerCompose().build();
  DockerCompose upDockerCompose = dockerCompose();
  if (removeConflictingContainersOnStartup()) {
    upDockerCompose = new ConflictingContainerRemovingDockerCompose(upDockerCompose, docker());
  }
  upDockerCompose.up();
  logCollector().startCollecting(dockerCompose());
  log.debug("Waiting for services");
  clusterWaits().forEach(clusterWait -> clusterWait.waitUntilReady(containers()));
  log.debug("docker-compose cluster started");
}

代码示例来源：origin: palantir/docker-compose-rule

@Test
public void clean_up_created_networks_when_shutting_down() throws Exception {
  Set<String> networksBeforeRun = parseLinesFromOutputString(rule.docker().listNetworks());
  rule.before();
  assertThat(parseLinesFromOutputString(rule.docker().listNetworks()), is(not(networksBeforeRun)));
  rule.after();
  assertThat(parseLinesFromOutputString(rule.docker().listNetworks()), is(networksBeforeRun));
}

代码示例来源：origin: com.palantir.docker.compose/docker-compose-rule

@Override
public void before() throws IOException, InterruptedException {
  log.debug("Starting docker-compose cluster");
  dockerCompose().build();
  DockerCompose upDockerCompose = dockerCompose();
  if (removeConflictingContainersOnStartup()) {
    upDockerCompose = new ConflictingContainerRemovingDockerCompose(upDockerCompose, docker());
  }
  upDockerCompose.up();
  logCollector().startCollecting(dockerCompose());
  log.debug("Waiting for services");
  clusterWaits().forEach(clusterWait -> clusterWait.waitUntilReady(containers()));
  log.debug("docker-compose cluster started");
}

代码示例来源：origin: palantir/docker-compose-rule

@Override
public void before() throws IOException, InterruptedException {
  log.debug("Starting docker-compose cluster");
  if (pullOnStartup()) {
    dockerCompose().pull();
  }
  dockerCompose().build();
  DockerCompose upDockerCompose = dockerCompose();
  if (removeConflictingContainersOnStartup()) {
    upDockerCompose = new ConflictingContainerRemovingDockerCompose(upDockerCompose, docker());
  }
  upDockerCompose.up();
  logCollector().startCollecting(dockerCompose());
  log.debug("Waiting for services");
  new ClusterWait(ClusterHealthCheck.nativeHealthChecks(), nativeServiceHealthCheckTimeout())
      .waitUntilReady(containers());
  clusterWaits().forEach(clusterWait -> clusterWait.waitUntilReady(containers()));
  log.debug("docker-compose cluster started");
}

代码示例来源：origin: palantir/docker-compose-rule

@Value.Default
public Cluster containers() {
  return ImmutableCluster.builder()
      .ip(machine().getIp())
      .containerCache(new ContainerCache(docker(), dockerCompose()))
      .build();
}