Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use checkState method of org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy class

Best Testcontainers-java code snippet using org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState

Source:Standard.java

...33import java.util.ArrayList;34import java.util.List;35import static com.google.common.base.MoreObjects.firstNonNull;36import static com.google.common.base.Preconditions.checkArgument;37import static com.google.common.base.Preconditions.checkState;38import static io.prestosql.tests.product.launcher.docker.DockerFiles.createTemporaryDirectoryForDocker;39import static io.prestosql.tests.product.launcher.testcontainers.TestcontainersUtil.exposePort;40import static java.nio.charset.StandardCharsets.UTF_8;41import static java.nio.file.Files.isRegularFile;42import static java.nio.file.Files.readAllLines;43import static java.nio.file.Files.write;44import static java.util.Objects.requireNonNull;45import static org.testcontainers.containers.BindMode.READ_ONLY;46public final class Standard47        implements EnvironmentExtender48{49    public static final String CONTAINER_PRESTO_ETC = "/docker/presto-product-tests/conf/presto/etc";50    public static final String CONTAINER_PRESTO_JVM_CONFIG = CONTAINER_PRESTO_ETC + "/jvm.config";51    public static final String CONTAINER_PRESTO_CONFIG_PROPERTIES = CONTAINER_PRESTO_ETC + "/config.properties";52    public static final String CONTAINER_TEMPTO_PROFILE_CONFIG = "/docker/presto-product-tests/conf/tempto/tempto-configuration-profile-config-file.yaml";53    private final PathResolver pathResolver;54    private final DockerFiles dockerFiles;55    private final String imagesVersion;56    private final File serverPackage;57    private final boolean debug;58    @Inject59    public Standard(60            PathResolver pathResolver,61            DockerFiles dockerFiles,62            EnvironmentOptions environmentOptions)63    {64        this.pathResolver = requireNonNull(pathResolver, "pathResolver is null");65        this.dockerFiles = requireNonNull(dockerFiles, "dockerFiles is null");66        requireNonNull(environmentOptions, "environmentOptions is null");67        imagesVersion = requireNonNull(environmentOptions.imagesVersion, "environmentOptions.imagesVersion is null");68        serverPackage = requireNonNull(environmentOptions.serverPackage, "environmentOptions.serverPackage is null");69        checkArgument(serverPackage.getName().endsWith(".tar.gz"), "Currently only server .tar.gz package is supported");70        debug = environmentOptions.debug;71    }72    @Override73    public void extendEnvironment(Environment.Builder builder)74    {75        builder.addContainer("presto-master", createPrestoMaster());76        builder.addContainer("tests", createTestsContainer());77    }78    @SuppressWarnings("resource")79    private DockerContainer createPrestoMaster()80    {81        DockerContainer container =82                createPrestoContainer(dockerFiles, pathResolver, serverPackage, "prestodev/centos7-oj11:" + imagesVersion)83                        .withFileSystemBind(dockerFiles.getDockerFilesHostPath("common/standard/config.properties"), CONTAINER_PRESTO_CONFIG_PROPERTIES, READ_ONLY);84        exposePort(container, 8080); // Presto default port85        if (debug) {86            container.withCreateContainerCmdModifier(this::enableDebuggerInJvmConfig);87            exposePort(container, 5005); // debug port88        }89        return container;90    }91    @SuppressWarnings("resource")92    private DockerContainer createTestsContainer()93    {94        DockerContainer container = new DockerContainer("prestodev/centos6-oj8:" + imagesVersion)95                .withFileSystemBind(dockerFiles.getDockerFilesHostPath(), "/docker/presto-product-tests", READ_ONLY)96                .withCommand("bash", "-xeuc", "echo 'No command provided' >&2; exit 69")97                .waitingFor(new WaitAllStrategy()) // don't wait98                .withStartupCheckStrategy(new IsRunningStartupCheckStrategy());99        return container;100    }101    @SuppressWarnings("resource")102    public static DockerContainer createPrestoContainer(DockerFiles dockerFiles, PathResolver pathResolver, File serverPackage, String dockerImageName)103    {104        return new DockerContainer(dockerImageName)105                .withFileSystemBind(dockerFiles.getDockerFilesHostPath(), "/docker/presto-product-tests", READ_ONLY)106                .withFileSystemBind(dockerFiles.getDockerFilesHostPath("conf/presto/etc/jvm.config"), CONTAINER_PRESTO_JVM_CONFIG, READ_ONLY)107                .withFileSystemBind(pathResolver.resolvePlaceholders(serverPackage).getPath(), "/docker/presto-server.tar.gz", READ_ONLY)108                .withCommand("/docker/presto-product-tests/run-presto.sh")109                .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())110                .waitingFor(Wait.forLogMessage(".*======== SERVER STARTED ========.*", 1))111                .withStartupTimeout(Duration.ofMinutes(5));112    }113    private void enableDebuggerInJvmConfig(CreateContainerCmd createContainerCmd)114    {115        try {116            Bind[] binds = firstNonNull(createContainerCmd.getBinds(), new Bind[0]);117            boolean found = false;118            // Last bind wins, so we can find the last one only119            for (int bindIndex = binds.length - 1; bindIndex >= 0; bindIndex--) {120                Bind bind = binds[bindIndex];121                if (!bind.getVolume().getPath().equals(CONTAINER_PRESTO_JVM_CONFIG)) {122                    continue;123                }124                Path hostJvmConfig = Paths.get(bind.getPath());125                checkState(isRegularFile(hostJvmConfig), "Bind for %s is not a file", CONTAINER_PRESTO_JVM_CONFIG);126                Path temporaryDirectory = createTemporaryDirectoryForDocker();127                Path newJvmConfig = temporaryDirectory.resolve("jvm.config");128                List<String> jvmOptions = new ArrayList<>(readAllLines(hostJvmConfig, UTF_8));129                jvmOptions.add("-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=0.0.0.0:5005");130                write(newJvmConfig, jvmOptions, UTF_8);131                binds[bindIndex] = new Bind(newJvmConfig.toString(), bind.getVolume(), AccessMode.ro, bind.getSecMode(), bind.getNoCopy(), bind.getPropagationMode());132                found = true;133                break;134            }135            checkState(found, "Could not find %s bind", CONTAINER_PRESTO_JVM_CONFIG);136            createContainerCmd.withBinds(binds);137        }138        catch (IOException e) {139            throw new UncheckedIOException(e);140        }141    }142}...

Source:IsRunningStartupCheckStrategy.java

...11    @SuppressWarnings("deprecation")12    @Override13    public boolean waitUntilStartupSuccessful(GenericContainer<?> container) {14        // Optimization: container already has the initial "after start" state, check it first15        if (checkState(container.getContainerInfo().getState()) == StartupStatus.SUCCESSFUL) {16            return true;17        }18        return super.waitUntilStartupSuccessful(container);19    }20    @Override21    public StartupStatus checkStartupState(DockerClient dockerClient, String containerId) {22        InspectContainerResponse.ContainerState state = getCurrentState(dockerClient, containerId);23        return checkState(state);24    }25    private StartupStatus checkState(InspectContainerResponse.ContainerState state) {26        if (Boolean.TRUE.equals(state.getRunning())) {27            return StartupStatus.SUCCESSFUL;28        } else if (!DockerStatus.isContainerExitCodeSuccess(state)) {29            return StartupStatus.FAILED;30        } else {31            return StartupStatus.NOT_YET_KNOWN;32        }33    }34}...

checkState

Using AI Code Generation

1import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;2import org.testcontainers.containers.startupcheck.StartupCheckStrategy;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.wait.strategy.Wait;5import org.testcontainers.containers.wait.strategy.WaitStrategy;6import org.testcontainers.containers.wait.strategy.WaitAllStrategy;7import org.testcontainers.containers.wait.strategy.WaitAllStrategy.WaitAllStrategyBuilder;8import org.testcontainers.containers.wait.strategy.WaitAllStrategy.WaitAllStrategyTarget;9import org.testcontainers.containers.wait.strategy.WaitAllStrategy.WaitAllStrategyTarget.WaitAllStrategyTargetBuilder;10import org.testcontainers.containers.wait.strategy.WaitAllStrategy.WaitAllStrategyTarget.WaitAllStrategyTargetBuilder.WaitAllStrategyTargetBuilderState;11import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;12public class 1 {13public static void main(String[] args) {14IsRunningStartupCheckStrategy isRunningStartupCheckStrategy = new IsRunningStartupCheckStrategy();15isRunningStartupCheckStrategy.checkState(null);16}17}18	at org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState(IsRunningStartupCheckStrategy.java:17)19	at 1.main(1.java:15)20Related posts: Java String isBlank() Method Example Java String strip() Method Example Java String stripLeading() Method Example Java String stripTrailing() Method Example Java String stripIndent() Method Example Java String lines() Method Example Java String repeat() Method Example Java String transform() Method Example Java String stripIndent() Method Example Java String transform() Method Example Java String stripTrailing() Method Example Java String stripLeading() Method Example Java String strip() Method Example Java String isBlank() Method Example Java String lines() Method Example Java String repeat() Method Example Java String join() Method Example Java String replaceAll() Method Example Java String replace() Method Example Java String split() Method Example Java String isBlank() Method Example Java String strip() Method Example Java String stripLeading() Method Example Java String stripTrailing() Method Example Java String stripIndent() Method Example Java String lines() Method Example Java String repeat() Method Example Java String transform() Method Example Java String stripIndent() Method Example Java String transform() Method Example Java String stripTrailing() Method Example Java String stripLeading()

checkState

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;3public class checkState {4    public static void main(String[] args) {5        GenericContainer container = new GenericContainer("alpine:latest")6            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy());7        container.start();8        System.out.println("Container state is: " + container.getState());9    }10}11import org.testcontainers.containers.GenericContainer;12import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;13public class IsRunningStartupCheckStrategy {14    public static void main(String[] args) {15        GenericContainer container = new GenericContainer("alpine:latest")16            .withStartupCheckStrategy(new org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy());17        container.start();18        System.out.println("Container state is: " + container.getState());19    }20}21import org.testcontainers.containers.GenericContainer;22import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;23public class IsRunningStartupCheckStrategy {24    public static void main(String[] args) {25        GenericContainer container = new GenericContainer("alpine:latest")26            .withStartupCheckStrategy(new org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy());27        container.start();28        System.out.println("Container state is: " + container.getState());29    }30}31Recommended Posts: Testcontainers | withStartupCheckStrategy() Method32Testcontainers | withStartupTimeout() Method33Testcontainers | withStartupAttempts() Method34Testcontainers | withExposedPorts() Method35Testcontainers | withFixedExposedPort() Method

checkState

Using AI Code Generation

1import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;2public class IsRunningStartupCheckStrategyExample {3    public static void main(String[] args) {4        IsRunningStartupCheckStrategy isRunningStartupCheckStrategy = new IsRunningStartupCheckStrategy();5        isRunningStartupCheckStrategy.checkState(null);6    }7}8	at org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState(IsRunningStartupCheckStrategy.java:23)9	at IsRunningStartupCheckStrategyExample.main(IsRunningStartupCheckStrategyExample.java:9)

checkState

Using AI Code Generation

1import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;2public class IsRunningStartupCheckStrategyExample {3    public static void main(String[] args) {4        IsRunningStartupCheckStrategy isRunningStartupCheckStrategy = new IsRunningStartupCheckStrategy();5        isRunningStartupCheckStrategy.checkState(null);6    }7}8	at org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState(IsRunningStartupCheckStrategy.java:16)9	at IsRunningStartupCheckStrategyExample.main(IsRunningStartupCheckStrategyExample.java:8)10import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;11public class IsRunningStartupCheckStrategyExample {12    public static void main(String[] args) {13        IsRunningStartupCheckStrategy isRunningStartupCheckStrategy = new IsRunningStartupCheckStrategy();14        isRunningStartupCheckStrategy.checkState(null);15    }16}17	at org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState(IsRunningStartupCheckStrategy.java:16)18	at IsRunningStartupCheckStrategyExample.main(IsRunningStartupCheckStrategyExample.java:8)19import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;20public class IsRunningStartupCheckStrategyExample {21    public static void main(String[] args) {22        IsRunningStartupCheckStrategy isRunningStartupCheckStrategy = new IsRunningStartupCheckStrategy();23        isRunningStartupCheckStrategy.checkState(null);24    }25}26	at org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState(IsRunningStartupCheckStrategy.java:16)27	at IsRunningStartupCheckStrategyExample.main(IsRunningStartupCheckStrategyExample.java:8)28import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;29public class IsRunningStartupCheckStrategyExample {30    public static void main(String[] args) {

checkState

Using AI Code Generation

1package org.testcontainers.containers.startupcheck;2import org.testcontainers.containers.GenericContainer;3import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;4public class IsRunningStartupCheckStrategyTest {5    public static void main(String[] args) {6        GenericContainer container = new GenericContainer("alpine:3.3");7        IsRunningStartupCheckStrategy isRunningStartupCheckStrategy = new IsRunningStartupCheckStrategy();8        isRunningStartupCheckStrategy.checkState(container);9    }10}11	at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:88)12	at org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState(IsRunningStartupCheckStrategy.java:17)13	at org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategyTest.main(IsRunningStartupCheckStrategyTest.java:12)14	at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:289)15	at org.testcontainers.containers.GenericContainer.lambda$doStart$0(GenericContainer.java:267)16	at org.rnorth.ducttape.unreliables.Unreliables.retryUntilSuccess(Unreliables.java:81)17Caused by: org.testcontainers.containers.ContainerLaunchException: Timed out waiting for container port to open (localhost ports: [32769] should be listening)18	at org.testcontainers.containers.wait.strategy.HostPortWaitStrategy.waitUntilReady(HostPortWaitStrategy.java:37)19	at org.testcontainers.containers.GenericContainer.waitUntilContainerStarted(GenericContainer.java:539)20	at org.testcontainers.containers.GenericContainer.tryStart(GenericContainer.java:282)

checkState

Using AI Code Generation

1import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;2import org.testcontainers.containers.startupcheck.StartupCheckStrategy;3public class IsRunningStartupCheckStrategyExample {4    public static void main(String[] args) {5        StartupCheckStrategy startupCheckStrategy = new IsRunningStartupCheckStrategy();6        startupCheckStrategy.checkState(null);7    }8}9	at org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState(IsRunningStartupCheckStrategy.java:19)10	at IsRunningStartupCheckStrategyExample.main(IsRunningStartupCheckStrategyExample.java:10)11org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy.checkState(ContainerState) Method12public void checkState(ContainerState state)

checkState

Using AI Code Generation

1package org.testcontainers.containers.startupcheck;2import java.util.concurrent.TimeUnit;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;5public class IsRunningStartupCheckStrategyExample {6    public static void main(String[] args) {7        try (final GenericContainer container = new GenericContainer("alpine:3.7")8            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())9            .withCommand("sleep", "1000")) {10            container.start();11            container.checkState();12            System.out.println("Container is running");13        } catch (IllegalStateException e) {14            System.out.println("Container is not running");15        }16    }17}18package org.testcontainers.containers.startupcheck;19import java.util.concurrent.TimeUnit;20import org.testcontainers.containers.GenericContainer;21import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;22public class IsRunningStartupCheckStrategyExample {23    public static void main(String[] args) {24        try (final GenericContainer container = new GenericContainer("alpine:3.7")25            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())26            .withCommand("sleep", "1000")) {27            container.start();28            container.stop();29            container.checkState();30            System.out.println("Container is running");31        } catch (IllegalStateException e) {32            System.out.println("Container is not running");33        }34    }35}

checkState

Using AI Code Generation

1package org.testcontainers;2import java.time.Duration;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;5public class IsRunningStartupCheckStrategyExample {6    public static void main(String[] args) {7        try (GenericContainer container = new GenericContainer("alpine:3.8")8            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())) {9            container.start();10            System.out.println("Container is running");

checkState

Using AI Code Generation

1package org.testcontainers.containers.startupcheck;2import java.time.Duration;3import java.util.concurrent.TimeUnit;4import org.testcontainers.containers.GenericContainer;5import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;6import org.testcontainers.utility.DockerImageName;7public class CheckState {8    public static void main(String[] args) {9        GenericContainer container = new GenericContainer(DockerImageName.parse("alpine:3.13.2"))10                .withCommand("sleep", "1000")11                .withStartupCheckStrategy(new IsRunningStartupCheckStrategy());12        container.start();13        boolean state = container.isRunning();14        System.out.println("Container is running: " + state);15        container.stop();16        state = container.isRunning();17        System.out.println("Container is running: " + state);18    }19}20import java.util.concurrent.TimeUnit;21import org.testcontainers.containers.GenericContainer;22import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;23public class IsRunningStartupCheckStrategyExample {24    public static void main(String[] args) {25        try (final GenericContainer container = new GenericContainer("alpine:3.7")26            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())27            .withCommand("sleep", "1000")) {28            container.start();29            container.stop();30            container.checkState();31            System.out.println("Container is running");32        } catch (IllegalStateException e) {33            System.out.println("Container is not running");34        }35    }36}

checkState

Using AI Code Generation

1package org.testcontainers;2import java.time.Duration;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;5public class IsRunningStartupCheckStrategyExample {6    public static void main(String[] args) {7        try (GenericContainer container = new GenericContainer("alpine:3.8")8            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())) {9            container.start();10            System.out.println("Container is running");

checkState

Using AI Code Generation

1package org.testcontainers.containers.startupcheck;2import java.time.Duration;3import java.util.concurrent.TimeUnit;4import org.testcontainers.containers.GenericContainer;5import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;6import org.testcontainers.utility.DockerImageName;7public class CheckState {8    public static void main(String[] args) {9        GenericContainer container = new GenericContainer(DockerImageName.parse("alpine:3.13.2"))10                .withCommand("sleep", "1000")11                .withStartupCheckStrategy(new IsRunningStartupCheckStrategy());12        container.start();13        boolean state = container.isRunning();14        System.out.println("Container is running: " + state);15        container.stop();16        state = container.isRunning();17        System.out.println("Container is running: " + state);18    }19}

checkState

Using AI Code Generation

1package org.testcontainers.containers.startupcheck;2import java.util.concurrent.TimeUnit;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;5public class IsRunningStartupCheckStrategyExample {6    public static void main(String[] args) {7        try (final GenericContainer container = new GenericContainer("alpine:3.7")8            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())9            .withCommand("sleep", "1000")) {10            container.start();11            container.checkState();12            System.out.println("Container is running");13        } catch (IllegalStateException e) {14            System.out.println("Container is not running");15        }16    }17}18package org.testcontainers.containers.startupcheck;19import java.util.concurrent.TimeUnit;20import org.testcontainers.containers.GenericContainer;21import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;22public class IsRunningStartupCheckStrategyExample {23    public static void main(String[] args) {24        try (final GenericContainer container = new GenericContainer("alpine:3.7")25            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())26            .withCommand("sleep", "1000")) {27            container.start();28            container.stop();29            container.checkState();30            System.out.println("Container is running");31        } catch (IllegalStateException e) {32            System.out.println("Container is not running");33        }34    }35}

checkState

Using AI Code Generation

1package org.testcontainers;2import java.time.Duration;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.startupcheck.IsRunningStartupCheckStrategy;5public class IsRunningStartupCheckStrategyExample {6    public static void main(String[] args) {7        try (GenericContainer container = new GenericContainer("alpine:3.8")8            .withStartupCheckStrategy(new IsRunningStartupCheckStrategy())) {9            container.start();10            System.out.println("Container is running");

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.