IntenseFinance/nosqlbench
3
0
Fork 0
mirror of https://github.com/nosqlbench/nosqlbench.git synced 2025-02-25 18:55:28 -06:00
Code Issues Packages Projects Releases Wiki Activity

Attempt to set Network mode

Browse Source
This commit is contained in:
Mike Yaacoub
2023-02-02 17:32:36 -05:00
parent d33d7fe515
commit 528c79f5d6
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
nb5-proof/src/test/java/io/nosqlbench/nb5/proof/ExampleContainersIntegrationTest.java
View File

@@ -23,6 +23,7 @@ import org.junit.jupiter.api.Test;
import org.testcontainers.containers.CassandraContainer; import org.testcontainers.containers.CassandraContainer;
import org.testcontainers.containers.GenericContainer; import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.wait.CassandraQueryWaitStrategy; import org.testcontainers.containers.wait.CassandraQueryWaitStrategy;
import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerImageName; import org.testcontainers.utility.DockerImageName;
import java.util.Optional; import java.util.Optional;
@@ -38,16 +39,17 @@ public class ExampleContainersIntegrationTest {
// private static GenericContainer cass= new CassandraContainer("cassandra").withExposedPorts(9042); // private static GenericContainer cass= new CassandraContainer("cassandra").withExposedPorts(9042);
private static String hostIP = "127.0.0.1"; private static String hostIP = "127.0.0.1";
private static String datacenter = "datacenter1";
private static final Integer EXPOSED_PORT = 9042; private static final Integer EXPOSED_PORT = 9042;
public static GenericContainer<?> cass = new CassandraContainer<>(DockerImageName.parse("cassandra:latest")) public static CassandraContainer<?> cass = new CassandraContainer<>(DockerImageName.parse("cassandra:latest")).withCreateContainerCmdModifier(cmd -> cmd.withNetworkMode("host")).withAccessToHost(true)
.withExposedPorts(EXPOSED_PORT).withAccessToHost(true).waitingFor(new CassandraQueryWaitStrategy()); .withExposedPorts(EXPOSED_PORT).waitingFor(Wait.forLogMessage(".*cassandra:latest started.*", 1));
@BeforeAll @BeforeAll
public static void initContainer() { public static void initContainer() {
//STEP0:Start the test container and expose the 9042 port on the local host. //STEP0:Start the test container and expose the 9042 port on the local host.
//So that the docker bridge controller exposes the port to our process invoker that will run nb5 //So that the docker bridge controller exposes the port to our process invoker that will run nb5
//and target cassandra on that docker container //and target cassandra on that docker container
cass.start(); cass.start();
datacenter = cass.getLocalDatacenter();
//When running with a local Docker daemon, exposed ports will usually be reachable on localhost. //When running with a local Docker daemon, exposed ports will usually be reachable on localhost.
// However, in some CI environments they may instead be reachable on a different host. // However, in some CI environments they may instead be reachable on a different host.
hostIP = cass.getHost(); hostIP = cass.getHost();
@@ -72,7 +74,7 @@ public class ExampleContainersIntegrationTest {
//STEP2: Run the example cassandra workload using the default params ( //STEP2: Run the example cassandra workload using the default params (
ProcessResult runResult = invoker.run("run-workload", 30, "java", "-jar", JARNAME, "run", ProcessResult runResult = invoker.run("run-workload", 30, "java", "-jar", JARNAME, "run",
"driver=cql", "workload=cql-keyvalue", "host="+hostIP, "localdc=datacenter1" "driver=cql", "workload=cql-keyvalue", "host="+hostIP, "localdc="+datacenter
); );
assertThat(runResult.exception).isNull(); assertThat(runResult.exception).isNull();
String runOut = String.join("\n", runResult.getStdoutData()); String runOut = String.join("\n", runResult.getStdoutData());