github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-20 17:38:50 +00:00
Code Issues Projects Releases Wiki Activity

Wait for at least 1 endpoint in E2E test for examples

Browse Source
This commit is contained in:
Marcin Wielgus
2015-10-02 17:22:31 +02:00
parent b840357d6f
commit d5c40479f1
2 changed files with 30 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
test/e2e/examples.go
View File

@@ -34,10 +34,9 @@ import (
)
const (
podListTimeout = time.Minute
serverStartTimeout = podStartTimeout + 3*time.Minute
dnsReadyTimeout = time.Minute
endpointRegisterTimeout = time.Minute
podListTimeout = time.Minute
serverStartTimeout = podStartTimeout + 3*time.Minute
dnsReadyTimeout = time.Minute
)
const queryDnsPythonTemplate string = `
@@ -149,6 +148,8 @@ var _ = Describe("Examples e2e", func() {
_, err := lookForStringInLog(ns, pod.Name, "rabbitmq", "Server startup complete", serverStartTimeout)
Expect(err).NotTo(HaveOccurred())
})
waitForEndpoint(c, ns, "rabbitmq-service")
By("starting celery")
runKubectl("create", "-f", celeryControllerYaml, nsFlag)
forEachPod(c, ns, "component", "celery", func(pod api.Pod) {
@@ -192,6 +193,9 @@ var _ = Describe("Examples e2e", func() {
_, err = lookForStringInLog(ns, "spark-driver", "spark-driver", "Use kubectl exec", serverStartTimeout)
Expect(err).NotTo(HaveOccurred())
By("waiting for master endpoint")
waitForEndpoint(c, ns, "spark-master")
By("starting workers")
runKubectl("create", "-f", workerControllerJson, nsFlag)
ScaleRC(c, ns, "spark-worker-controller", 2, true)
@@ -221,6 +225,8 @@ var _ = Describe("Examples e2e", func() {
_, err = lookForStringInLog(ns, "cassandra", "cassandra", "Listening for thrift clients", serverStartTimeout)
Expect(err).NotTo(HaveOccurred())
waitForEndpoint(c, ns, "cassandra")
By("create and scale rc")
runKubectl("create", "-f", controllerYaml, nsFlag)
err = ScaleRC(c, ns, "cassandra", 2, true)
@@ -263,12 +269,14 @@ var _ = Describe("Examples e2e", func() {
By("checking if zookeeper is up and running")
_, err = lookForStringInLog(ns, zookeeperPod, "zookeeper", "binding to port", serverStartTimeout)
Expect(err).NotTo(HaveOccurred())
waitForEndpoint(c, ns, "zookeeper")
By("starting Nimbus")
runKubectl("create", "-f", nimbusPodJson, nsFlag)
runKubectl("create", "-f", nimbusServiceJson, nsFlag)
err = waitForPodRunningInNamespace(c, "nimbus", ns)
Expect(err).NotTo(HaveOccurred())
waitForEndpoint(c, ns, "nimbus")
By("starting workers")
runKubectl("create", "-f", workerControllerJson, nsFlag)
@@ -382,6 +390,7 @@ var _ = Describe("Examples e2e", func() {
})
}
checkDbInstances()
waitForEndpoint(c, ns, "rethinkdb-driver")
By("scaling rethinkdb")
ScaleRC(c, ns, "rethinkdb-rc", 2, true)
@@ -420,6 +429,8 @@ var _ = Describe("Examples e2e", func() {
Expect(err).NotTo(HaveOccurred())
})
waitForEndpoint(c, ns, "hazelcast")
By("scaling hazelcast")
ScaleRC(c, ns, "hazelcast", 2, true)
forEachPod(c, ns, "name", "hazelcast", func(pod api.Pod) {