sijie commented on a change in pull request #2036: Add testcontainer based
standalone test
URL: https://github.com/apache/incubator-pulsar/pull/2036#discussion_r198350288
##########
File path:
tests/integration-tc/src/main/java/org/apache/pulsar/tests/integration/PulsarStandAloneCluster.java
##########
@@ -0,0 +1,121 @@
+package org.apache.pulsar.tests.integration;
+
+import com.github.dockerjava.api.command.CreateContainerCmd;
+import com.github.dockerjava.api.command.LogContainerCmd;
+import com.github.dockerjava.api.model.Frame;
+import com.github.dockerjava.core.command.LogContainerResultCallback;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy;
+
+import java.time.Duration;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.function.Consumer;
+
+import static java.time.temporal.ChronoUnit.SECONDS;
+
+public class PulsarStandAloneCluster extends
GenericContainer<PulsarStandAloneCluster> {
+
+ private static final Logger LOG =
LoggerFactory.getLogger(PulsarStandAloneCluster.class);
+
+ private static final int PULSAR_BROKER_PORT = 6650;
+ private static final int PULSAR_ADMIN_PORT = 8080;
+
+ private static final String PULSAR_HOST_NAME = "broker";
+
+ private static final String NAME = "apachepulsar";
+ private static final String IMG = "pulsar-test-latest-version";
+
+ private static final String CONTAINER_NAME_BASE = "pulsar-test";
+ private FUNC_MODE func_mode;
+ private String containerNameAddition;
+
+ public PulsarStandAloneCluster(String containerName){
+ this(containerName, FUNC_MODE.STANDALONE);
+ }
+
+ public PulsarStandAloneCluster(String containerName, FUNC_MODE mode){
+ this(containerName, mode, NAME + "/" + IMG + ":" + "latest");
+ }
+
+ private PulsarStandAloneCluster(final String containerName, final
FUNC_MODE mode, final String imageName) {
+ super(imageName);
+ this.func_mode = mode;
+ this.containerNameAddition = containerName;
+ }
+
+ @Override
+ protected void configure() {
+ addExposedPort(PULSAR_BROKER_PORT);
+ addExposedPort(PULSAR_ADMIN_PORT);
+ addEnv("FUNCTION_MODE", func_mode.toString());
Review comment:
do you need this? who is using the environment variable?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
