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

Confirms daemons restart and do sane things in an e2e test

Browse Source
This commit is contained in:
Prashanth Balasubramanian
2015-06-23 16:20:04 -07:00
parent 5ea41906d4
commit 83f1212e0b
5 changed files with 287 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
test/e2e/examples.go
View File

@@ -194,7 +194,7 @@ var _ = Describe("Examples e2e", func() {
By("starting workers")
runKubectl("create", "-f", workerControllerJson, nsFlag)
ScaleRC(c, ns, "spark-worker-controller", 2)
ScaleRC(c, ns, "spark-worker-controller", 2, true)
forEachPod(c, ns, "name", "spark-worker", func(pod api.Pod) {
_, err := lookForStringInLog(ns, pod.Name, "spark-worker", "Successfully registered with master", serverStartTimeout)
Expect(err).NotTo(HaveOccurred())
@@ -223,7 +223,7 @@ var _ = Describe("Examples e2e", func() {
By("create and scale rc")
runKubectl("create", "-f", controllerYaml, nsFlag)
err = ScaleRC(c, ns, "cassandra", 2)
err = ScaleRC(c, ns, "cassandra", 2, true)
Expect(err).NotTo(HaveOccurred())
forEachPod(c, ns, "name", "cassandra", func(pod api.Pod) {
_, err = lookForStringInLog(ns, pod.Name, "cassandra", "Listening for thrift clients", serverStartTimeout)
@@ -384,7 +384,7 @@ var _ = Describe("Examples e2e", func() {
checkDbInstances()
By("scaling rethinkdb")
ScaleRC(c, ns, "rethinkdb-rc", 2)
ScaleRC(c, ns, "rethinkdb-rc", 2, true)
checkDbInstances()
By("starting admin")
@@ -421,7 +421,7 @@ var _ = Describe("Examples e2e", func() {
})
By("scaling hazelcast")
ScaleRC(c, ns, "hazelcast", 2)
ScaleRC(c, ns, "hazelcast", 2, true)
forEachPod(c, ns, "name", "hazelcast", func(pod api.Pod) {
_, err := lookForStringInLog(ns, pod.Name, "hazelcast", "Members [2]", serverStartTimeout)
Expect(err).NotTo(HaveOccurred())