You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by as...@apache.org on 2021/03/30 17:20:59 UTC
[camel-k] 17/20: test: Add readiness probe to Nexus deployment
This is an automated email from the ASF dual-hosted git repository.
astefanutti pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k.git
commit 0705bf9757288cc82c25bcd4fc6baea90e4cc38c
Author: Antonin Stefanutti <an...@stefanutti.fr>
AuthorDate: Mon Mar 29 19:21:25 2021 +0200
test: Add readiness probe to Nexus deployment
---
e2e/common/build/maven_ca_secret_test.go | 25 ++++++++++++++++++++-----
1 file changed, 20 insertions(+), 5 deletions(-)
diff --git a/e2e/common/build/maven_ca_secret_test.go b/e2e/common/build/maven_ca_secret_test.go
index 8466a38..4151a23 100644
--- a/e2e/common/build/maven_ca_secret_test.go
+++ b/e2e/common/build/maven_ca_secret_test.go
@@ -42,6 +42,7 @@ import (
"k8s.io/apimachinery/pkg/util/intstr"
. "github.com/apache/camel-k/e2e/support"
+ v1 "github.com/apache/camel-k/pkg/apis/camel/v1"
)
func TestMavenCASecret(t *testing.T) {
@@ -235,6 +236,16 @@ ProxyPreserveHost On
MountPath: "/nexus-data",
},
},
+ ReadinessProbe: &corev1.Probe{
+ InitialDelaySeconds: 30,
+ FailureThreshold: 3,
+ Handler: corev1.Handler{
+ HTTPGet: &corev1.HTTPGetAction{
+ Port: intstr.FromString("nexus"),
+ Path: "/repository/maven-public/",
+ },
+ },
+ },
},
},
Volumes: []corev1.Volume{
@@ -298,7 +309,7 @@ ProxyPreserveHost On
Expect(TestClient().Create(TestContext, service)).To(Succeed())
// Wait for the Deployment to become ready
- Eventually(Deployment(ns, deployment.Name)).Should(PointTo(MatchFields(IgnoreExtras,
+ Eventually(Deployment(ns, deployment.Name), TestTimeoutMedium).Should(PointTo(MatchFields(IgnoreExtras,
Fields{
"Status": MatchFields(IgnoreExtras,
Fields{
@@ -307,17 +318,21 @@ ProxyPreserveHost On
}),
))
- // Install Camel K with the Maven CA secret
+ // Install Camel K with the Maven Central Nexus proxy and the corresponding Maven CA secret
Expect(Kamel("install", "-n", ns,
"--maven-repository", fmt.Sprintf(`https://%s/repository/maven-public/@id=central@snapshots`, hostname),
"--maven-ca-secret", secret.Name+"/"+corev1.TLSCertKey,
).Execute()).To(Succeed())
+ Eventually(PlatformPhase(ns), TestTimeoutMedium).Should(Equal(v1.IntegrationPlatformPhaseReady))
+
// Run the Integration
name := "java"
- Expect(Kamel("run", "-n", ns, "files/Java.java",
- "--name", name,
- ).Execute()).To(Succeed())
+ Expect(Kamel("run", "-n", ns, "files/Java.java", "--name", name).Execute()).To(Succeed())
+
+ Eventually(IntegrationPodPhase(ns, name), TestTimeoutMedium).Should(Equal(corev1.PodRunning))
+ Eventually(IntegrationCondition(ns, name, v1.IntegrationConditionReady), TestTimeoutShort).Should(Equal(corev1.ConditionTrue))
+ Eventually(IntegrationLogs(ns, name), TestTimeoutShort).Should(ContainSubstring("Magicstring!"))
// Clean up
Expect(Kamel("delete", "--all", "-n", ns).Execute()).To(Succeed())