How to use K3sContainer method of org.testcontainers.k3s.K3sContainer class

Best Testcontainers-java code snippet using org.testcontainers.k3s.K3sContainer.K3sContainer

Source:K8sClusterTestResource.java

...9import java.util.Collections;10import java.util.Map;11@Log12public class K8sClusterTestResource implements QuarkusTestResourceLifecycleManager {13    private K3sContainer k3sContainer;14    private ToStringConsumer logger;15    public KindContainer kindContainer;16    public static boolean k3s = true;17    public Map<String, String> startK3s() {18        try {19            k3sContainer.start();20            Thread.sleep(10000);21            return null;22        } catch (Exception ex) {23            System.out.println(logger.toUtf8String());24            return null;25        }26    }27    public Map<String, String> startKind() {28        kindContainer.start();29        return null;30    }31    @Override32    public Map<String, String> start() {33        return (k3s) ? startK3s() : startKind();34    }35    @Override36    public void stop() {37        if (k3s) {38            kindContainer.stop();39        } else k3sContainer.stop();40    }41    @Override42    public void inject(TestInjector testInjector) {43        if (!k3s) {44            testInjector.injectIntoFields(kindContainer.client(), (f) -> f.getType().isAssignableFrom(DefaultKubernetesClient.class));45        } else {46            Config config = Config.fromKubeconfig(k3sContainer.getKubeConfigYaml());47            // workaround for undiagnosed issue; fabric8 seems to not identify48            // the client key algorithm correctly, so fails to work with K3s49            // ECDSA keys unless configured explicitly50            config.setClientKeyAlgo("EC");51            DefaultKubernetesClient k8sclient = new DefaultKubernetesClient(config);52            testInjector.injectIntoFields(k8sclient, (f) -> f.getType().isAssignableFrom(DefaultKubernetesClient.class));53        }54    }55    @Override56    public void init(Map<String, String> initArgs) {57        QuarkusTestResourceLifecycleManager.super.init(initArgs);58        if (k3s) {59            logger = new ToStringConsumer();60            k3sContainer = new K3sContainer(DockerImageName.parse("rancher/k3s:v1.23.1-rc1-k3s1")).withLogConsumer(new CustomLogConsumer(log).withPrefix("KIND"));61        } else {62            kindContainer = new KindContainer().withLogConsumer(new CustomLogConsumer(log).withPrefix("KIND"));63        }64    }65}...

Source:LocalImageDeploymentIT.java

...4import org.junit.jupiter.api.Timeout;5import org.testcontainers.containers.BindMode;6import org.testcontainers.junit.jupiter.Container;7import org.testcontainers.junit.jupiter.Testcontainers;8import org.testcontainers.k3s.K3sContainer;9import org.testcontainers.utility.DockerImageName;10import java.util.concurrent.TimeUnit;11import static org.junit.jupiter.api.Assertions.assertEquals;12import static org.junit.jupiter.api.Assertions.assertTrue;13/**14 * Test capability that allow us to import images properly15 */16@Testcontainers17public class LocalImageDeploymentIT {18    @Container19    private final @NotNull K3sContainer container = new K3sContainer(DockerImageName20            .parse("rancher/k3s:v1.21.3-k3s1"))21            .withFileSystemBind("./build/containers", "/build", BindMode.READ_ONLY);22    @Timeout(value = 2, unit = TimeUnit.MINUTES)23    @Test24    public void withLocalImages_mqttMessagePublishedReceived() throws Exception {25        var outLoadImage = container.execInContainer("/bin/ctr",26                "images",27                "import",28                "/build/" + "hivemq-k8s-image.tar");29        assertEquals(0, outLoadImage.getExitCode());30        final var outListImages = container.execInContainer("/bin/ctr", "images", "ls");31        assertTrue(outListImages.getStdout().contains("hivemq/hivemq4-test"));32    }33}...

Source:K3sContainer.java

...4import org.testcontainers.containers.GenericContainer;5import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy;6import org.testcontainers.utility.DockerImageName;7import java.nio.charset.StandardCharsets;8public class K3sContainer extends GenericContainer<K3sContainer> {9    private Config kubeConfig;10    public K3sContainer(DockerImageName dockerImageName) {11        super(dockerImageName);12        addExposedPorts(6443, 8443);13        setPrivilegedMode(true);14        setCommand("server", "--no-deploy=traefik", "--token=abc123", "--tls-san=127.0.0.1");15        setWaitStrategy(new LogMessageWaitStrategy().withRegEx(".*Node controller sync successful.*"));16    }17    @Override18    protected void containerIsStarted(InspectContainerResponse containerInfo) {19        String rawKubeConfig = copyFileFromContainer(20                "/etc/rancher/k3s/k3s.yaml",21                is -> new String(is.readAllBytes(), StandardCharsets.UTF_8)22        );23        kubeConfig = Config.fromKubeconfig("default", rawKubeConfig, null);24        kubeConfig.setClientKeyAlgo("EC");...

K3sContainer

Using AI Code Generation

1import org.testcontainers.containers.output.Slf4jLogConsumer;2import org.testcontainers.k3s.K3sContainer;3import org.testcontainers.utility.DockerImageName;4import org.testcontainers.utility.MountableFile;5import org.slf4j.Logger;6import org.slf4j.LoggerFactory;7public class K3sContainerTest {8    private static final Logger logger = LoggerFactory.getLogger(K3sContainerTest.class);9    public static void main(String[] args) {10        DockerImageName imageName = DockerImageName.parse("rancher/k3s:v1.21.0-k3s1");11        K3sContainer k3sContainer = new K3sContainer(imageName);12        k3sContainer.withLogConsumer(new Slf4jLogConsumer(logger)).start();13        logger.info("k3sContainer is running: {}", k3sContainer.isRunning());14        logger.info("k3sContainer is healthy: {}", k3sContainer.isHealthy());15        logger.info("k3sContainer is started: {}", k3sContainer.isStarted());16        logger.info("k3sContainer is stopped: {}", k3sContainer.isStopped());17        logger.info("k3sContainer is created: {}", k3sContainer.isCreated());18        logger.info("k3sContainer is waiting: {}", k3sContainer.isWaiting());19        logger.info("k3sContainer is paused: {}", k3sContainer.isPaused());20        logger.info("k3sContainer is exited: {}", k3sContainer.isExited());21        logger.info("k3sContainer is dead: {}", k3sContainer.isDead());22        logger.info("k3sContainer is removed: {}", k3sContainer.isRemoved());23        logger.info("k3sContainer is restarting: {}", k3sContainer.isRestarting());24        logger.info("k3sContainer is running: {}", k3sContainer.isRunning());25        logger.info("k3sContainer is healthy: {}", k3sContainer.isHealthy());26        logger.info("k3sContainer is started: {}", k3sContainer.isStarted());27        logger.info("k3sContainer is stopped: {}", k3sContainer.isStopped());28        logger.info("k3sContainer is created: {}", k3sContainer.isCreated());29        logger.info("k3sContainer is waiting: {}", k3sContainer.isWaiting());30        logger.info("k3sContainer is paused: {}", k3sContainer

K3sContainer

Using AI Code Generation

1import org.testcontainers.k3s.K3sContainer;2public class K3sContainerDemo {3    public static void main(String[] args) {4        try (K3sContainer k3s = new K3sContainer()) {5            k3s.start();6            System.out.println("k3s is running");7            System.out.println("K3s URL : " + k3s.getK3sUrl());8            System.out.println("Kubeconfig : " + k3s.getKubeConfig());9        }10    }11}

K3sContainer

Using AI Code Generation

1import org.testcontainers.containers.K3sContainer;2import org.testcontainers.junit.jupiter.Container;3import org.testcontainers.junit.jupiter.Testcontainers;4public class K3sContainerTest {5    public static K3sContainer k3s = new K3sContainer();6    public void test() {7        System.out.println("K3s IP: " + k3s.getContainerIpAddress());8        System.out.println("K3s Port: " + k3s.getMappedPort(6443));9    }10}11import org.testcontainers.containers.K3sContainer;12import org.testcontainers.junit.jupiter.Container;13import org.testcontainers.junit.jupiter.Testcontainers;14public class K3sContainerTest {15    public static K3sContainer k3s = new K3sContainer();16    public void test() {17        System.out.println("K3s IP: " + k3s.getContainerIpAddress());18        System.out.println("K3s Port: " + k3s.getMappedPort(6443));19    }20}21import org.testcontainers.containers.K3sContainer;22import org.testcontainers.junit.jupiter.Container;23import org.testcontainers.junit.jupiter.Testcontainers;24public class K3sContainerTest {25    public static K3sContainer k3s = new K3sContainer();26    public void test() {27        System.out.println("K3s IP: " + k3s.getContainerIpAddress());28        System.out.println("K3s Port: " + k3s.getMappedPort(6443));29    }30}31import org.testcontainers.containers.K3sContainer;32import org.testcontainers.junit.jupiter.Container;33import org.testcontainers.junit.jupiter.Testcontainers;34public class K3sContainerTest {35    public static K3sContainer k3s = new K3sContainer();36    public void test()

K3sContainer

Using AI Code Generation

1import org.testcontainers.k3s.K3sContainer;2import org.testcontainers.utility.DockerImageName;3import org.testcontainers.containers.GenericContainer;4import org.testcontainers.containers.Network;5import org.testcontainers.containers.wait.strategy.Wait;6import org.testcontainers.containers.wait.strategy.WaitAllStrategy;7import org.testcontainers.containers.wait.strategy.WaitStrategy;8public class K3sContainerTest {9    public static void main(String[] args) {10        K3sContainer k3s = new K3sContainer(DockerImageName.parse("rancher/k3s:v1.20.4-k3s1"));11        Network network = Network.newNetwork();12        GenericContainer genericContainer = new GenericContainer("alpine")13                .withNetwork(network)14                .withNetworkAliases("test")15                .withCommand("tail -f /dev/null")16                .waitingFor(Wait.forLogMessage(".*", 1));17        k3s.start();18        genericContainer.start();19        String k3sContainerIp = k3s.getContainerIpAddress();20        Integer k3sContainerPort = k3s.getMappedPort(6443);21        String genericContainerIp = genericContainer.getContainerIpAddress();22        Integer genericContainerPort = genericContainer.getMappedPort(80);23        System.out.println("K3s Container IP: " + k3sContainerIp);24        System.out.println("K3s Container Port: " + k3sContainerPort);25        System.out.println("Generic Container IP: " + genericContainerIp);26        System.out.println("Generic Container Port: " + genericContainerPort);27    }28}

K3sContainer

Using AI Code Generation

1import org.testcontainers.containers.K3sContainer;2import org.testcontainers.containers.output.Slf4jLogConsumer;3import org.testcontainers.utility.DockerImageName;4import org.slf4j.Logger;5import org.slf4j.LoggerFactory;6public class K3sContainerTest {7    private static final Logger logger = LoggerFactory.getLogger(K3sContainerTest.class);8    public static void main(String[] args) {9        try (K3sContainer k3s = new K3sContainer(DockerImageName.parse("rancher/k3s:v1.21.2-k3s1"))) {10            k3s.withLogConsumer(new Slf4jLogConsumer(logger));11            k3s.start();12            logger.info("K3s container started");13        }14    }15}16import org.testcontainers.containers.K3sContainer;17import org.testcontainers.containers.output.Slf4jLogConsumer;18import org.testcontainers.utility.DockerImageName;19import org.slf4j.Logger;20import org.slf4j.LoggerFactory;21public class K3sContainerTest {22    private static final Logger logger = LoggerFactory.getLogger(K3sContainerTest.class);23    public static void main(String[] args) {24        try (K3sContainer k3s = new K3sContainer(DockerImageName.parse("rancher/k3s:v1.21.2-k3s1"))25            .withK3sCluster(new K3sCluster())) {26            k3s.withLogConsumer(new Slf4jLogConsumer(logger));27            k3s.start();28            logger.info("K3s container started");29        }30    }31}32import org.testcontainers.containers.K3sContainer;33import org.testcontainers.containers.output.Slf4jLogConsumer;34import org.testcontainers.utility.DockerImageName;35import org.slf4j.Logger;36import org.slf4j.LoggerFactory;37public class K3sContainerTest {38    private static final Logger logger = LoggerFactory.getLogger(K3sContainerTest.class);39    public static void main(String[] args) {

K3sContainer

Using AI Code Generation

1import org.testcontainers.containers.GenericContainer;2import org.testcontainers.k3s.K3sContainer;3public class K3sContainerMain {4    public static void main(String[] args) {5        try (K3sContainer k3s = new K3sContainer()) {6            k3s.start();7            System.out.println("K3s cluster created!");8            System.out.println("K3s container IP address: " + k3s.getContainerIpAddress());9            System.out.println("K3s container port: " + k3s.getMappedPort(6443));10            System.out.println("K3s container ID: " + k3s.getContainerId());11            System.out.println("K3s container logs: " + k3s.getLogs());12        } catch (Exception e) {13            System.out.println("Error occurred while creating K3s cluster: " + e.getMessage());14        }15    }16}

K3sContainer

Using AI Code Generation

1import org.testcontainers.containers.BindMode;2import org.testcontainers.containers.GenericContainer;3import org.testcontainers.containers.wait.strategy.Wait;4import org.testcontainers.k3s.K3sContainer;5import org.testcontainers.utility.MountableFile;6import java.io.File;7import java.io.IOException;8import java.nio.file.Files;9import java.nio.file.Path;10import java.nio.file.Paths;11public class K3sContainerTest {12    public static void main(String[] args) throws IOException {13        K3sContainer k3sContainer = new K3sContainer();14        GenericContainer genericContainer = new GenericContainer("alpine:latest")15                .withCommand("tail", "-f", "/dev/null")16                .withWorkingDirectory("/tmp")17                .withFileSystemBind("/tmp", "/tmp", BindMode.READ_WRITE);18        File file = new File("test.txt");19        Path path = Paths.get(file.getAbsolutePath());20        Files.write(path, "test".getBytes());21        genericContainer.copyFileToContainer(MountableFile.forHostPath(file.getAbsolutePath()), "/tmp");22        genericContainer.start();23        File file1 = new File("test1.txt");24        Path path1 = Paths.get(file1.getAbsolutePath());25        Files.write(path1, "test1".getBytes());26        k3sContainer.copyFileToContainer(MountableFile.forHostPath(file1.getAbsolutePath()), "/tmp");27        k3sContainer.start();28        k3sContainer.waitingFor(Wait.forLogMessage(".*K3s is up and running.*", 1));29        System.out.println(k3sContainer.getLogs());30        System.out.println(genericContainer.getLogs());31    }32}

K3sContainer

Using AI Code Generation

1import org.testcontainers.k3s.K3sContainer;2import org.testcontainers.containers.GenericContainer;3import org.testcontainers.containers.Network;4import org.testcontainers.containers.output.Slf4jLogConsumer;5import org.testcontainers.containers.wait.strategy.Wait;6import org.testcontainers.utility.DockerImageName;7import static org.testcontainers.containers.BindMode.READ_ONLY;8import org.slf4j.Logger;9import org.slf4j.LoggerFactory;10import java.util.List;11import java.util.ArrayList;12public class 1 {13    private static final Logger logger = LoggerFactory.getLogger(1.class);14    public static void main(String[] args) {15        try (K3sContainer k3s = new K3sContainer(DockerImageName.parse("rancher/k3s:v1.21.2-k3s1"))16            .withNetwork(Network.SHARED)17            .withNetworkAliases("k3s")18            .withK3sCommand("server --no-deploy traefik")19            .withLogConsumer(new Slf4jLogConsumer(logger).withPrefix("k3s"))20            .withWorkerNodes(2)21            .withService("web", "nginx", 80, "type=NodePort")22            .withPod("web", "nginx", 80, "type=NodePort")23            .withService("web", "nginx", 80, "type=NodePort")24            .withPod("web", "nginx", 80, "type=NodePort")25            .withService("web", "nginx", 80, "type=NodePort")26            .withPod("web", "nginx", 80, "type=NodePort")27            .withService("web", "nginx", 80, "type=NodePort")28            .withPod("web", "nginx", 80, "type=NodePort")29            .withService("web", "nginx", 80, "type=NodePort")30            .withPod("web", "nginx", 80, "type=NodePort")31            .withService("web", "nginx", 80, "type=

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.