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

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

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

Source:K3sContainer.java

...40            "/etc/rancher/k3s/k3s.yaml",41            is -> IOUtils.toString(is, StandardCharsets.UTF_8)42        );43        String serverUrl = "https://" + this.getHost() + ":" + this.getMappedPort(KUBE_SECURE_PORT);44        kubeConfigYaml = kubeConfigWithServerUrl(rawKubeConfig, serverUrl);45    }46    /**47     * Return the kubernetes client configuration to access k3s from the host machine.48     *49     * @return the kubeConfig yaml.50     */51    public String getKubeConfigYaml() {52        return kubeConfigYaml;53    }54    /**55     * Generate a kubernetes client configuration for use on a docker internal network. The kubeConfig can be used by56     * another docker container running in the same network as the k3s container. For access from the host, use57     * the {@link #getKubeConfigYaml()} method instead.58     *59     * @param networkAlias a valid network alias of the k3s container.60     * @return the kubeConfig yaml.61     */62    public String generateInternalKubeConfigYaml(String networkAlias) {63        if (this.getNetworkAliases().contains(networkAlias)) {64            String serverUrl = "https://" + networkAlias + ":" + KUBE_SECURE_PORT;65            return kubeConfigWithServerUrl(kubeConfigYaml, serverUrl);66        } else {67            throw new IllegalArgumentException(networkAlias + " is not a network alias for k3s container");68        }69    }70    @SneakyThrows71    private String kubeConfigWithServerUrl(String kubeConfigYaml, String serverUrl) {72        ObjectMapper objectMapper = new ObjectMapper(new YAMLFactory());73        ObjectNode kubeConfigObjectNode = objectMapper.readValue(kubeConfigYaml, ObjectNode.class);74        JsonNode clusterNode = kubeConfigObjectNode.at("/clusters/0/cluster");75        if (!clusterNode.isObject()) {76            throw new IllegalStateException("'/clusters/0/cluster' expected to be an object");77        }78        ObjectNode clusterConfig = (ObjectNode) clusterNode;79        clusterConfig.replace("server", new TextNode(serverUrl));80        kubeConfigObjectNode.set("current-context", new TextNode("default"));81        return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(kubeConfigObjectNode);82    }83}...

kubeConfigWithServerUrl

Using AI Code Generation

1import org.testcontainers.containers.BindMode;2import org.testcontainers.containers.Network;3import org.testcontainers.containers.wait.strategy.Wait;4import org.testcontainers.k3s.K3sContainer;5import org.testcontainers.utility.DockerImageName;6public class K3sContainerExample {7    public static void main(String[] args) {8        final Network network = Network.newNetwork();9        final K3sContainer k3s = new K3sContainer(DockerImageName.parse("rancher/k3s:v1.18.9-k3s1"))10                .withNetwork(network)11                .withNetworkAliases("k3s")12                .withExposedPorts(6443)13                .withCommand("server --disable=traefik")14                .waitingFor(Wait.forLogMessage(".*Running kube-apiserver.*", 1));15        k3s.start();16        final K3sContainer k3sWithKubeConfig = k3s.kubeConfigWithServerUrl(k3s.getContainerIpAddress() + ":" + k3s.getMappedPort(6443));17        k3sWithKubeConfig.withNetwork(network);18        k3sWithKubeConfig.start();19    }20}

kubeConfigWithServerUrl

Using AI Code Generation

1K3sContainer k3s = new K3sContainer()2    .withKubeconfig(kubeConfigWithServerUrl(k3s))3    .withLogConsumer(new Slf4jLogConsumer(log))4    .withNetworkMode("host")5    .withNetworkAliases("k3s")6k3s.start()7k3s.stop()82021-09-15T10:43:48.639Z [INFO]  Starting k3s v1.22.3+k3s1 (838a906a)

kubeConfigWithServerUrl

Using AI Code Generation

1    def k3s = new K3sContainer()2    def kubeConfig = k3s.kubeConfigWithServerUrl()3    def kubernetesClient = new DefaultKubernetesClient(kubeConfig)4    def k3s = new K3sContainer()5    def kubeConfig = k3s.kubeConfigWithServerUrl()6    def kubernetesClient = new DefaultKubernetesClient(kubeConfig)7    def k3s = new K3sContainer()8    def kubeConfig = k3s.kubeConfigWithServerUrl()9    def kubernetesClient = new DefaultKubernetesClient(kubeConfig)10    def k3s = new K3sContainer()11    def kubeConfig = k3s.kubeConfigWithServerUrl()12    def kubernetesClient = new DefaultKubernetesClient(kubeConfig)13    def k3s = new K3sContainer()14    def kubeConfig = k3s.kubeConfigWithServerUrl()15    def kubernetesClient = new DefaultKubernetesClient(kubeConfig)16    def k3s = new K3sContainer()17    def kubeConfig = k3s.kubeConfigWithServerUrl()18    def kubernetesClient = new DefaultKubernetesClient(kubeConfig)

kubeConfigWithServerUrl

Using AI Code Generation

1import org.testcontainers.k3s.K3sContainer2import org.testcontainers.kubernetes.client.KubernetesClientProvider3import org.testcontainers.kubernetes.client.KubernetesClientProviderStrategy4import org.testcontainers.utility.DockerImageName5import org.testcontainers.containers.GenericContainer6import org.testcontainers.containers.wait.strategy.Wait7def k3s = new K3sContainer(DockerImageName.parse("rancher/k3s:v1.21.3-k3s1"))8    .withWaitStrategy(Wait.forLogMessage(".*Running kube-apiserver.*", 1))9k3s.start()10def client = KubernetesClientProvider.getClient()11def pod = new GenericContainer(DockerImageName.parse("nginx:latest"))12    .withCommand("sleep", "infinity")13    .withEnv("KUBERNETES_SERVICE_HOST", "kubernetes.default.svc.cluster.local")14    .withEnv("KUBERNETES_SERVICE_PORT", "443")15    .withEnv("KUBERNETES_SERVICE_PORT_HTTPS", "443")16    .withExposedPorts(80)17    .withKubernetesDeployment(client)18    .withKubernetesService(client)19    .withKubernetesPodLabel("my-pod-label", "my-pod-value")20pod.start()21def podName = pod.getContainerInfo().getLabels().get("io.kubernetes.pod.name")22def podIp = client.pods().withName(podName).get().getStatus().getPodIP()23println("Pod name is ${podName}")24println("Pod IP is ${podIp}")25k3s.stop()

kubeConfigWithServerUrl

Using AI Code Generation

1K3sContainer k3s = new K3sContainer()2                .withK3sVersion("v1.18.2-k3s1")3                .withLogConsumer(new Slf4jLogConsumer(LoggerFactory.getLogger("k3s")))4                .withExposedPorts(8080);5k3s.start();6KubernetesClient client = new DefaultKubernetesClient(Config.fromKubeconfig(kubeConfig));7client.namespaces().create(new NamespaceBuilder().withNewMetadata().withName("test").endMetadata().build());8client.pods().inNamespace("test").create(new PodBuilder()9                .withNewMetadata()10                    .withName("test-pod")11                    .withLabels(Collections.singletonMap("app", "test-pod"))12                .endMetadata()13                .withNewSpec()14                    .addNewContainer()15                        .withName("test-pod")16                        .withImage("nginx")17                        .withImagePullPolicy("IfNotPresent")18                        .withPorts(new ContainerPortBuilder().withContainerPort(80).build())19                    .endContainer()20                .endSpec()21                .build());22client.namespaces().withName("test").delete();23k3s.stop();24kubeConfig.delete();25k3s.close();

kubeConfigWithServerUrl

Using AI Code Generation

1import org.testcontainers.containers.output.Slf4jLogConsumer2import org.testcontainers.k3s.K3sContainer3import org.testcontainers.utility.DockerImageName4import org.testcontainers.utility.MountableFile5import spock.lang.Specification6class K3sContainerSpec extends Specification {7    def "should run a test using the k3s client"() {8        def container = new K3sContainer(DockerImageName.parse("rancher/k3s:v1.21.3-k3s1"))9            .withK3sVersion("v1.21.3+k3s1")10            .withLogConsumer(new Slf4jLogConsumer(log))11            .withCopyFileToContainer(MountableFile.forClasspathResource("kubeconfig"), "/root/.kube/config")12            .withCopyFileToContainer(MountableFile.forClasspathResource("ca.crt"), "/root/.kube/ca.crt")13            .withCopyFileToContainer(MountableFile.forClasspathResource("client.crt"), "/root/.kube/client.crt")14            .withCopyFileToContainer(MountableFile.forClasspathResource("client.key"), "/root/.kube/client.key")15            .withExposedPorts(6443)16        container.start()17        def result = container.execInContainer("kubectl", "get", "pods", "--all-namespaces")18        result.getStdout().contains("NAMESPACE     NAME                             READY   STATUS    RESTARTS   AGE")19        container.stop()20    }21}22org.testcontainers.k3s.K3sContainerSpec > should run a test using the k3s client() STANDARD_OUT

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.