From 3857f092cd0e533ea2cae358dc1e909f32eced75 Mon Sep 17 00:00:00 2001 From: Zoltan Kiss Date: Tue, 8 Oct 2019 15:30:57 +0100 Subject: [PATCH] no private --- .idea/codeStyles/codeStyleConfig.xml | 1 - .../main/groovy/net/corda/testing/KubesTest.groovy | 12 ++++++------ 2 files changed, 6 insertions(+), 7 deletions(-) diff --git a/.idea/codeStyles/codeStyleConfig.xml b/.idea/codeStyles/codeStyleConfig.xml index 6e6eec1148..79ee123c2b 100644 --- a/.idea/codeStyles/codeStyleConfig.xml +++ b/.idea/codeStyles/codeStyleConfig.xml @@ -1,6 +1,5 @@ \ No newline at end of file diff --git a/buildSrc/src/main/groovy/net/corda/testing/KubesTest.groovy b/buildSrc/src/main/groovy/net/corda/testing/KubesTest.groovy index 0867813103..2b69f15fe0 100644 --- a/buildSrc/src/main/groovy/net/corda/testing/KubesTest.groovy +++ b/buildSrc/src/main/groovy/net/corda/testing/KubesTest.groovy @@ -89,19 +89,19 @@ class KubesTest extends DefaultTask { List> futures = IntStream.range(0, numberOfPods).mapToObj({ i -> String podName = "$taskToExecuteName-$stableRunId-$random-$i" - runBuild(client, namespace, numberOfPods, i, podName, printOutput, 3) + submitBuild(client, namespace, numberOfPods, i, podName, printOutput, 3) }).collect(Collectors.toList()) this.testOutput = Collections.synchronizedList(futures.collect { it -> it.get().binaryResults }.flatten()) this.containerResults = futures.collect { it -> it.get() } } - private static def rnd64Base36(Random rnd) { + static def rnd64Base36(Random rnd) { return new BigInteger(64, rnd) .toString(36) .toLowerCase() } - private Future runBuild( + Future submitBuild( KubernetesClient client, String namespace, int numberOfPods, @@ -119,7 +119,7 @@ class KubesTest extends DefaultTask { }) } - private def createPvc(KubernetesClient client, String name) { + def createPvc(KubernetesClient client, String name) { def pvc = client.persistentVolumeClaims() .inNamespace(namespace) .createNew() @@ -140,7 +140,7 @@ class KubesTest extends DefaultTask { return pvc } - private KubePodResult buildRunPodWithRetriesOrThrow( + KubePodResult buildRunPodWithRetriesOrThrow( KubernetesClient client, String namespace, PersistentVolumeClaim pvc, @@ -261,7 +261,7 @@ class KubesTest extends DefaultTask { } } - private Watch attachStatusListenerToPod(KubernetesClient client, Pod pod) { + Watch attachStatusListenerToPod(KubernetesClient client, Pod pod) { client.pods().inNamespace(pod.metadata.namespace).withName(pod.metadata.name).watch(new Watcher() { @Override void eventReceived(Watcher.Action action, Pod resource) {