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

DockerComposeRule.after介绍

暂无

代码示例

代码示例来源：origin: palantir/atlasdb

public void close() {
    if (docker != null) {
      docker.after();
    }
  }
}

代码示例来源：origin: palantir/atlasdb

@VisibleForTesting
  static void onShutdown() {
    synchronized (Containers.class) {
      if (dockerProxyRuleStarted) {
        DOCKER_PROXY_RULE.after();
      }
      if (dockerComposeRule != null) {
        dockerComposeRule.after();
      }
      dockerProxyRuleStarted = false;
      dockerComposeRule = null;
      currentLogCollector = null;
      containersStarted.clear();
    }
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
protected void after() {
  dockerProxyRule.after();
  dockerComposeRule.after();
}

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

@Override
public void after() {
  rule.after();
}

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

@After
public void shutdownPool() {
  pool.shutdown();
  if (rule != null) {
    rule.after();
  }
}

代码示例来源：origin: com.github.jcustenborder.kafka.connect/kafka-connect-cdc-test

@Override
public void afterAll(ExtensionContext containerExtensionContext) throws Exception {
 ExtensionContext.Namespace namespace = namespace(containerExtensionContext);
 ExtensionContext.Store store = containerExtensionContext.getStore(namespace);
 DockerComposeRule dockerComposeRule = store.get(STORE_SLOT_RULE, DockerComposeRule.class);
 dockerComposeRule.after();
}

代码示例来源：origin: apache/nifi-minifi

@AfterClass
public static void cleanup() {
  docker.after();
}

代码示例来源：origin: apache/nifi-minifi

@AfterClass
public static void cleanup() {
  docker.after();
}

代码示例来源：origin: apache/nifi-minifi

@AfterClass
public static void cleanup() {
  docker.after();
}

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

@Test
public void logs_can_be_saved_to_a_directory() throws IOException, InterruptedException {
  try {
    dockerComposeRule.before();
  } finally {
    dockerComposeRule.after();
  }
  assertThat(new File(logFolder.getRoot(), "db.log"), is(fileWithConents(matchingPattern(
      ".*Attaching to \\w+_db_1.*server started.*"))));
  assertThat(new File(logFolder.getRoot(), "db2.log"), is(fileWithConents(matchingPattern(
      ".*Attaching to \\w+_db2_1.*server started.*"))));
}

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

@Test
public void shut_down_multiple_containers_immediately() throws Exception {
  assertThat(rule.dockerCompose().ps(), is(TestContainerNames.of()));
  rule.before();
  assertThat(rule.dockerCompose().ps().size(), is(2));
  rule.after();
  assertThat(rule.dockerCompose().ps(), is(TestContainerNames.of()));
}

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

@SuppressWarnings("unchecked")
@Test
public void be_able_to_save_logs_to_a_directory_while_containers_are_running()
    throws IOException, InterruptedException {
  File logLocation = logFolder.newFolder();
  DockerComposeRule loggingComposition = DockerComposeRule.builder()
      .docker(mockDocker)
      .dockerCompose(dockerCompose)
      .files(mockFiles)
      .machine(machine)
      .saveLogsTo(logLocation.getAbsolutePath())
      .build();
  when(dockerCompose.services()).thenReturn(ImmutableList.of("db"));
  when(dockerCompose.id(any())).thenReturn(Optional.of("abcde"));
  when(mockDocker.state("abcde")).thenReturn(State.HEALTHY);
  CountDownLatch latch = new CountDownLatch(1);
  when(dockerCompose.writeLogs(eq("db"), any(OutputStream.class))).thenAnswer(args -> {
    OutputStream outputStream = (OutputStream) args.getArguments()[1];
    IOUtils.write("db log", outputStream);
    latch.countDown();
    return true;
  });
  loggingComposition.before();
  assertThat(latch.await(1, TimeUnit.SECONDS), is(true));
  loggingComposition.after();
  assertThat(logLocation.listFiles(), arrayContaining(fileWithName("db.log")));
  assertThat(new File(logLocation, "db.log"), is(fileContainingString("db log")));
}

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

@Test
public void after_test_is_executed_the_launched_postgres_container_is_no_longer_listening() {
  docker.after();
  forEachContainer(container -> {
    assertThat(docker.containers().container(container).port(5432).isListeningNow(), is(false));
  });
}

代码示例来源：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: palantir/docker-compose-rule

@Test
public void shut_down_multiple_containers_immediately() throws Exception {
  DockerComposeRule rule = DockerComposeRule.builder()
      .file("src/test/resources/shutdown-strategy.yaml")
      .logCollector(new DoNothingLogCollector())
      .retryAttempts(0)
      .shutdownStrategy(ShutdownStrategy.AGGRESSIVE)
      .build();
  assertThat(rule.dockerCompose().ps(), is(TestContainerNames.of()));
  rule.before();
  assertThat(rule.dockerCompose().ps().size(), is(2));
  rule.after();
  assertThat(rule.dockerCompose().ps(), is(TestContainerNames.of()));
}

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

@Test public void
  can_access_host_networked_ports() throws Exception {
    // On linux the docker host is running on localhost, so host ports are accessible through localhost.
    // On Windows and Mac however, docker is being run in a linux VM. As such the docker host is the running
    // VM, not localhost, and the ports are inaccessible from outside the VM.
    // As such, this test will only run on linux.
    assumeTrue("Host ports are only accessible on linux", SystemUtils.IS_OS_LINUX);

    DockerComposeRule docker = DockerComposeRule.builder()
        .file("src/test/resources/host-networked-docker-compose.yaml")
        .waitingForHostNetworkedPort(5432, toBeOpen())
        .build();
    try {
      docker.before();
      assertThat(docker.hostNetworkedPort(5432).getInternalPort(), is(5432));
      assertThat(docker.hostNetworkedPort(5432).getExternalPort(), is(5432));
    } finally {
      docker.after();
    }
  }
}

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

@Test
  public void docker_compose_gets_environment_variables_from_docker_machine_and_passes_it_into_a_test_container() throws Exception {
    DockerMachine dockerMachine = DockerMachine.localMachine()
                          .withAdditionalEnvironmentVariable("SOME_VARIABLE", "SOME_VALUE")
                          .build();

    DockerComposeRule dockerComposition = DockerComposeRule.builder()
        .file("src/test/resources/environment/docker-compose.yaml")
        .machine(dockerMachine)
        .waitingForService("env-test", toHaveAllPortsOpen())
        .saveLogsTo(temporaryFolder.getRoot().getAbsolutePath())
        .build();

    try {
      dockerComposition.before();
    } finally {
      dockerComposition.after();
    }

    Path logLocation = temporaryFolder.getRoot()
                     .toPath()
                     .resolve("env-test.log");

    assertThat(logLocation.toFile(), is(fileContainingString("SOME_VARIABLE=SOME_VALUE")));
  }
}

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

@Test
public void by_default_existing_containers_should_be_removed_silently() throws IOException, InterruptedException {
  DockerComposeRule composition = DockerComposeRule.builder()
      .file(DOCKER_COMPOSE_YAML_PATH)
      .retryAttempts(0)
      .shutdownStrategy(AGGRESSIVE)
      .build();
  composition.before();
  composition.before();
  composition.after();
}

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

@Test
public void removeConflictingContainersOnStartup_off_should_fail_fast_if_containers_exist() throws IOException, InterruptedException {
  DockerComposeRule composition = DockerComposeRule.builder()
      .file(DOCKER_COMPOSE_YAML_PATH)
      .retryAttempts(0)
      .build();
  DockerComposeRule conflictingComposition = DockerComposeRule.builder()
      .file(DOCKER_COMPOSE_YAML_PATH)
      .retryAttempts(0)
      .removeConflictingContainersOnStartup(false)
      .build();
  try {
    composition.before();
    exception.expect(DockerExecutionException.class);
    exception.expectMessage("'docker-compose up -d' returned exit code");
    conflictingComposition.before();
  } finally {
    composition.after();
    conflictingComposition.after();
  }
}