ExternalVendorCode/corda
1
0
Fork 0
mirror of https://github.com/corda/corda.git synced 2025-02-25 19:11:45 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

regcred

Browse Source
This commit is contained in:
Zoltan Kiss 2019-10-09 11:47:48 +01:00
parent f299a8ea4b
commit 1dc30ee1fa
1 changed files with 14 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
buildSrc/src/main/groovy/net/corda/testing/KubesTest.groovy
View File

@ -1,17 +1,7 @@
package net.corda.testing package net.corda.testing
import io.fabric8.kubernetes.api.model.LocalObjectReference import io.fabric8.kubernetes.api.model.*
import io.fabric8.kubernetes.api.model.PersistentVolumeClaim import io.fabric8.kubernetes.client.*
import io.fabric8.kubernetes.api.model.Pod
import io.fabric8.kubernetes.api.model.PodBuilder
import io.fabric8.kubernetes.api.model.Quantity
import io.fabric8.kubernetes.api.model.Status
import io.fabric8.kubernetes.client.ConfigBuilder
import io.fabric8.kubernetes.client.DefaultKubernetesClient
import io.fabric8.kubernetes.client.KubernetesClient
import io.fabric8.kubernetes.client.KubernetesClientException
import io.fabric8.kubernetes.client.Watch
import io.fabric8.kubernetes.client.Watcher
import io.fabric8.kubernetes.client.dsl.ExecListener import io.fabric8.kubernetes.client.dsl.ExecListener
import io.fabric8.kubernetes.client.utils.Serialization import io.fabric8.kubernetes.client.utils.Serialization
import net.corda.testing.retry.Retry import net.corda.testing.retry.Retry
@ -23,18 +13,17 @@ import org.gradle.api.tasks.TaskAction
import java.nio.file.Files import java.nio.file.Files
import java.nio.file.Path import java.nio.file.Path
import java.util.concurrent.Callable import java.util.concurrent.*
import java.util.concurrent.CompletableFuture
import java.util.concurrent.ExecutorService
import java.util.concurrent.Executors
import java.util.concurrent.Future
import java.util.concurrent.TimeUnit
import java.util.stream.Collectors import java.util.stream.Collectors
import java.util.stream.IntStream import java.util.stream.IntStream
class KubesTest extends DefaultTask { class KubesTest extends DefaultTask {
static final ExecutorService executorService = Executors.newCachedThreadPool() static final ExecutorService executorService = Executors.newCachedThreadPool()
/**
* Name of the k8s Secret object that holds the credentials to access the docker image registry
*/
static final String REGISTRY_CREDENTIALS_SECRET_NAME = "regcred"
String dockerTag String dockerTag
String fullTaskToExecutePath String fullTaskToExecutePath
@ -192,11 +181,11 @@ class KubesTest extends DefaultTask {
.usingListener(execListener) .usingListener(execListener)
.exec(getBuildCommand(numberOfPods, podIdx)) .exec(getBuildCommand(numberOfPods, podIdx))
File outputFile = startLogPumping(stdOutIs, podIdx, printOutput) File podOutput = startLogPumping(stdOutIs, podIdx, printOutput)
int resCode = waiter.join() int resCode = waiter.join()
project.logger.lifecycle("build has ended on on pod ${podName} (${podIdx}/${numberOfPods}), gathering results") project.logger.lifecycle("build has ended on on pod ${podName} (${podIdx}/${numberOfPods}), gathering results")
def binaryResults = downloadTestXmlFromPod(client, namespace, createdPod) def binaryResults = downloadTestXmlFromPod(client, namespace, createdPod)
return new KubePodResult(resCode, outputFile, binaryResults) return new KubePodResult(resCode, podOutput, binaryResults)
} }
} catch (RetryException e) { } catch (RetryException e) {
throw new RuntimeException("Failed to build in pod ${podName} (${podIdx}/${numberOfPods}) in $numberOfRetries attempts", e) throw new RuntimeException("Failed to build in pod ${podName} (${podIdx}/${numberOfPods}) in $numberOfRetries attempts", e)
@ -236,6 +225,7 @@ class KubesTest extends DefaultTask {
new ExecListener() { new ExecListener() {
final Long start = System.currentTimeMillis() final Long start = System.currentTimeMillis()
@Override @Override
void onOpen(Response response) { void onOpen(Response response) {
project.logger.lifecycle("Build started on pod $podName") project.logger.lifecycle("Build started on pod $podName")
@ -281,7 +271,9 @@ class KubesTest extends DefaultTask {
} }
Pod buildPodRequest(String podName, PersistentVolumeClaim pvc) { Pod buildPodRequest(String podName, PersistentVolumeClaim pvc) {
return new PodBuilder().withNewMetadata().withName(podName).endMetadata() return new PodBuilder()
.withNewMetadata().withName(podName).endMetadata()
.withNewSpec() .withNewSpec()
.addNewVolume() .addNewVolume()
@ -318,7 +310,7 @@ class KubesTest extends DefaultTask {
.addNewVolumeMount().withName("testruns").withMountPath("/test-runs").endVolumeMount() .addNewVolumeMount().withName("testruns").withMountPath("/test-runs").endVolumeMount()
.endContainer() .endContainer()
.withImagePullSecrets(new LocalObjectReference("regcred")) .addNewImagePullSecret(REGISTRY_CREDENTIALS_SECRET_NAME)
.withRestartPolicy("Never") .withRestartPolicy("Never")
.endSpec() .endSpec()