KaneAI - World’s First E2E Software Testing Agent.Signup for Private Beta Join TestMu Conference

How to use init method of org.testcontainers.utility.ResourceReaper class

Best Testcontainers-java code snippet using org.testcontainers.utility.ResourceReaper.init

Source:DockerClientFactory.java

...39import java.util.UUID;40import java.util.function.BiFunction;41import java.util.function.Consumer;42/**43 * Singleton class that provides initialized Docker clients.44 * <p>45 * The correct client configuration to use will be determined on first use, and cached thereafter.46 */47@Slf4j48public class DockerClientFactory {49    public static final ThreadGroup TESTCONTAINERS_THREAD_GROUP = new ThreadGroup("testcontainers");50    public static final String TESTCONTAINERS_LABEL = DockerClientFactory.class.getPackage().getName();51    public static final String TESTCONTAINERS_SESSION_ID_LABEL = TESTCONTAINERS_LABEL + ".sessionId";52    public static final String SESSION_ID = UUID.randomUUID().toString();53    public static final Map<String, String> DEFAULT_LABELS = ImmutableMap.of(TESTCONTAINERS_LABEL, "true");54    private static final DockerImageName TINY_IMAGE = DockerImageName.parse("alpine:3.16");55    private static DockerClientFactory instance;56    // Cached client configuration57    @VisibleForTesting58    DockerClientProviderStrategy strategy;59    @VisibleForTesting60    DockerClient client;61    @VisibleForTesting62    RuntimeException cachedClientFailure;63    private String activeApiVersion;64    @Getter(lazy = true)65    private final boolean fileMountingSupported = checkMountableFile();66    @VisibleForTesting67    DockerClientFactory() {}68    public static DockerClient lazyClient() {69        return new DockerClientDelegate() {70            @Override71            protected DockerClient getDockerClient() {72                return instance().client();73            }74            @Override75            public String toString() {76                return "LazyDockerClient";77            }78        };79    }80    /**81     * Obtain an instance of the DockerClientFactory.82     *83     * @return the singleton instance of DockerClientFactory84     */85    public static synchronized DockerClientFactory instance() {86        if (instance == null) {87            instance = new DockerClientFactory();88        }89        return instance;90    }91    /**92     * Checks whether Docker is accessible and {@link #client()} is able to produce a client.93     *94     * @return true if Docker is available, false if not.95     */96    public synchronized boolean isDockerAvailable() {97        try {98            client();99            return true;100        } catch (IllegalStateException ex) {101            return false;102        }103    }104    @Synchronized105    private DockerClientProviderStrategy getOrInitializeStrategy() {106        if (strategy != null) {107            return strategy;108        }109        List<DockerClientProviderStrategy> configurationStrategies = new ArrayList<>();110        ServiceLoader.load(DockerClientProviderStrategy.class).forEach(configurationStrategies::add);111        strategy = DockerClientProviderStrategy.getFirstValidStrategy(configurationStrategies);112        return strategy;113    }114    @UnstableAPI115    public TransportConfig getTransportConfig() {116        return getOrInitializeStrategy().getTransportConfig();117    }118    @UnstableAPI119    public String getRemoteDockerUnixSocketPath() {120        String dockerSocketOverride = System.getenv("TESTCONTAINERS_DOCKER_SOCKET_OVERRIDE");121        if (!StringUtils.isBlank(dockerSocketOverride)) {122            return dockerSocketOverride;123        }124        URI dockerHost = getTransportConfig().getDockerHost();125        String path = "unix".equals(dockerHost.getScheme()) ? dockerHost.getRawPath() : "/var/run/docker.sock";126        return SystemUtils.IS_OS_WINDOWS ? "/" + path : path;127    }128    /**129     * @return a new initialized Docker client130     */131    @Synchronized132    public DockerClient client() {133        // fail-fast if checks have failed previously134        if (cachedClientFailure != null) {135            log.debug("There is a cached checks failure - throwing", cachedClientFailure);136            throw cachedClientFailure;137        }138        if (client != null) {139            return client;140        }141        final DockerClientProviderStrategy strategy = getOrInitializeStrategy();142        client =143            new DockerClientDelegate() {144                @Getter145                final DockerClient dockerClient = strategy.getDockerClient();146                @Override147                public void close() {148                    throw new IllegalStateException("You should never close the global DockerClient!");149                }150            };151        log.info("Docker host IP address is {}", strategy.getDockerHostIpAddress());152        Info dockerInfo = strategy.getInfo();153        log.debug("Docker info: {}", dockerInfo.getRawValues());154        Version version = client.versionCmd().exec();155        log.debug("Docker version: {}", version.getRawValues());156        activeApiVersion = version.getApiVersion();157        log.info(158            "Connected to docker: \n" +159            "  Server Version: " +160            dockerInfo.getServerVersion() +161            "\n" +162            "  API Version: " +163            activeApiVersion +164            "\n" +165            "  Operating System: " +166            dockerInfo.getOperatingSystem() +167            "\n" +168            "  Total Memory: " +169            dockerInfo.getMemTotal() /170            (1024 * 1024) +171            " MB"172        );173        try {174            //noinspection deprecation175            ResourceReaper.instance().init();176        } catch (RuntimeException e) {177            cachedClientFailure = e;178            throw e;179        }180        boolean checksEnabled = !TestcontainersConfiguration.getInstance().isDisableChecks();181        if (checksEnabled) {182            log.debug("Checks are enabled");183            try {184                log.info("Checking the system...");185                checkDockerVersion(version.getVersion());186            } catch (RuntimeException e) {187                cachedClientFailure = e;188                throw e;189            }...

Source:RyukResourceReaper.java

...28        .build();29    private final AtomicBoolean started = new AtomicBoolean(false);30    private final RyukContainer ryukContainer = new RyukContainer();31    @Override32    public void init() {33        if (!TestcontainersConfiguration.getInstance().environmentSupportsReuse()) {34            log.debug("Ryuk is enabled");35            maybeStart();36            log.info("Ryuk started - will monitor and terminate Testcontainers containers on JVM exit");37        } else {38            log.debug("Ryuk is enabled but will be started on demand");39        }40    }41    @Override42    public void registerLabelsFilterForCleanup(Map<String, String> labels) {43        maybeStart();44        super.registerLabelsFilterForCleanup(labels);45    }46    @Override...

Source:JVMHookResourceReaper.java

...9 * to cleanup containers.10 */11class JVMHookResourceReaper extends ResourceReaper {12    @Override13    public void init() {14        setHook();15    }16    @Override17    public synchronized void performCleanup() {18        super.performCleanup();19        synchronized (DEATH_NOTE) {20            DEATH_NOTE.forEach(filters -> prune(PruneType.CONTAINERS, filters));21            DEATH_NOTE.forEach(filters -> prune(PruneType.NETWORKS, filters));22            DEATH_NOTE.forEach(filters -> prune(PruneType.VOLUMES, filters));23            DEATH_NOTE.forEach(filters -> prune(PruneType.IMAGES, filters));24        }25    }26    private void prune(PruneType pruneType, List<Map.Entry<String, String>> filters) {27        String[] labels = filters...

init

Using AI Code Generation

1package org.testcontainers.utility;2import org.testcontainers.DockerClientFactory;3import org.testcontainers.DockerClientFactory;4import org.testcontainers.containers.GenericContainer;5import org.testcontainers.containers.startupcheck.StartupCheckStrategy;6import org.testcontainers.containers.wait.strategy.Wait;7import org.testcontainers.images.builder.ImageFromDockerfile;8import org.testcontainers.utility.ResourceReaper;9import java.io.File;10import java.io.IOException;11import java.net.URISyntaxException;12import java.net.URL;13import java.nio.file.Files;14import java.nio.file.Paths;15import java.util.ArrayList;16import java.util.List;17import java.util.concurrent.TimeUnit;18public class Main {19    public static void main(String[] args) throws IOException, URISyntaxException, InterruptedException {20        System.out.println("Hello World!");21        ResourceReaper.init(DockerClientFactory.instance().client());22        System.out.println("Hello World!");23    }24}25package org.testcontainers.utility;26import org.testcontainers.DockerClientFactory;27import org.testcontainers.DockerClientFactory;28import org.testcontainers.containers.GenericContainer;29import org.testcontainers.containers.startupcheck.StartupCheckStrategy;30import org.testcontainers.containers.wait.strategy.Wait;31import org.testcontainers.images.builder.ImageFromDockerfile;32import org.testcontainers.utility.ResourceReaper;33import java.io.File;34import java.io.IOException;35import java.net.URISyntaxException;36import java.net.URL;37import java.nio.file.Files;38import java.nio.file.Paths;39import java.util.ArrayList;40import java.util.List;41import java.util.concurrent.TimeUnit;42public class Main {43    public static void main(String[] args) throws IOException, URISyntaxException, InterruptedException {44        System.out.println("Hello World!");45        ResourceReaper.init(DockerClientFactory.instance().client());46        System.out.println("Hello World!");47    }48}49package org.testcontainers.utility;50import org.testcontainers.DockerClientFactory;51import org.testcontainers.DockerClientFactory;52import org.testcontainers.containers.GenericContainer;53import org.testcontainers.containers.startupcheck.StartupCheckStrategy;54import org.testcontainers.containers.wait.strategy.Wait;55import org.testcontainers.images.builder.ImageFromDockerfile;56import org.testcontainers.utility.ResourceReaper;57import java.io.File;58import java.io.IOException;59import java.net.URISyntaxException;60import

init

Using AI Code Generation

1import org.testcontainers.utility.ResourceReaper;2public class 1 {3    public static void main(String[] args) {4        ResourceReaper.init();5    }6}72018-05-04 10:03:48.015  INFO 1 --- [           main] o.t.utility.ResourceReaper               : Starting ResourceReaper on 5a6a0f6f8b7d with PID 1 (/usr/local/lib/testcontainers/resource-reaper.jar started by root in /)82018-05-04 10:03:48.051  INFO 1 --- [           main] o.t.utility.ResourceReaper               : Started ResourceReaper in 0.026 seconds (JVM running for 0.045)

init

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.containers.output.Slf4jLogConsumer;3import org.testcontainers.containers.output.WaitingConsumer;4import org.testcontainers.utility.ResourceReaper;5public class 1 {6    public static void main(String[] args) throws Exception {7        ResourceReaper.init(null);8        GenericContainer container = new GenericContainer("alpine:3.8")9                .withCommand("sh", "-c", "while true; do sleep 1; done")10                .withExposedPorts(80)11                .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("testcontainers")))12                .withStartupTimeout(Duration.ofSeconds(5));13        container.start();14        String containerId = container.getContainerId();15        System.out.println("Container ID: " + containerId);16        Thread.sleep(5000);17        container.stop();18        System.out.println("Container stopped");

init

Using AI Code Generation

1import org.testcontainers.utility.ResourceReaper;2public class 1 {3  public static void main(String[] args) {4    ResourceReaper resourceReaper = new ResourceReaper();5    resourceReaper.init();6  }7}

init

Using AI Code Generation

1import org.testcontainers.utility.ResourceReaper;2public class 1 {3    public static void main(String[] args) {4        ResourceReaper.killAll();5    }6}7import org.testcontainers.containers.GenericContainer;8public class 2 {9    public static void main(String[] args) {10        GenericContainer.killAll();11    }12}13import org.testcontainers.containers.DockerComposeContainer;14public class 3 {15    public static void main(String[] args) {16        DockerComposeContainer.killAll();17    }18}19import org.testcontainers.containers.JdbcDatabaseContainer;20public class 4 {21    public static void main(String[] args) {22        JdbcDatabaseContainer.killAll();23    }24}25import org.testcontainers.containers.output.OutputFrame;26public class 5 {27    public static void main(String[] args) {28        OutputFrame.killAll();29    }30}31import org.testcontainers.containers.output.OutputFrame;32public class 6 {33    public static void main(String[] args) {34        OutputFrame.killAll();35    }36}37import org.testcontainers.containers.output.OutputFrame;38public class 7 {39    public static void main(String[] args) {40        OutputFrame.killAll();41    }42}43import org.testcontainers.containers.output.OutputFrame;44public class 8 {45    public static void main(String[] args) {46        OutputFrame.killAll();47    }48}

init

Using AI Code Generation

1public class TestContainer {2    public static void main(String[] args) {3        ResourceReaper.init(null);4    }5}6        at TestContainer.main(1.java:5)7        at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:582)8        at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:190)9        at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:499)

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.