mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-24 20:24:09 +00:00
Removing the test that validates celery+rabbitmq
Signed-off-by: Vishnu kannan <vishnuk@google.com>
This commit is contained in:
parent
33654d61fb
commit
d4e07f917d
@ -261,13 +261,6 @@ func TestExampleObjectSchemas(t *testing.T) {
|
|||||||
"cassandra-controller": &api.ReplicationController{},
|
"cassandra-controller": &api.ReplicationController{},
|
||||||
"cassandra-service": &api.Service{},
|
"cassandra-service": &api.Service{},
|
||||||
},
|
},
|
||||||
"../examples/celery-rabbitmq": {
|
|
||||||
"celery-controller": &api.ReplicationController{},
|
|
||||||
"flower-controller": &api.ReplicationController{},
|
|
||||||
"flower-service": &api.Service{},
|
|
||||||
"rabbitmq-controller": &api.ReplicationController{},
|
|
||||||
"rabbitmq-service": &api.Service{},
|
|
||||||
},
|
|
||||||
"../examples/cluster-dns": {
|
"../examples/cluster-dns": {
|
||||||
"dns-backend-rc": &api.ReplicationController{},
|
"dns-backend-rc": &api.ReplicationController{},
|
||||||
"dns-backend-service": &api.Service{},
|
"dns-backend-service": &api.Service{},
|
||||||
|
@ -138,57 +138,6 @@ var _ = framework.KubeDescribe("[Feature:Example]", func() {
|
|||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
framework.KubeDescribe("Celery-RabbitMQ", func() {
|
|
||||||
It("should create and stop celery+rabbitmq servers", func() {
|
|
||||||
mkpath := func(file string) string {
|
|
||||||
return filepath.Join(framework.TestContext.RepoRoot, "examples/celery-rabbitmq", file)
|
|
||||||
}
|
|
||||||
rabbitmqServiceYaml := mkpath("rabbitmq-service.yaml")
|
|
||||||
rabbitmqControllerYaml := mkpath("rabbitmq-controller.yaml")
|
|
||||||
celeryControllerYaml := mkpath("celery-controller.yaml")
|
|
||||||
flowerControllerYaml := mkpath("flower-controller.yaml")
|
|
||||||
flowerServiceYaml := mkpath("flower-service.yaml")
|
|
||||||
nsFlag := fmt.Sprintf("--namespace=%v", ns)
|
|
||||||
|
|
||||||
By("starting rabbitmq")
|
|
||||||
framework.RunKubectlOrDie("create", "-f", rabbitmqServiceYaml, nsFlag)
|
|
||||||
framework.RunKubectlOrDie("create", "-f", rabbitmqControllerYaml, nsFlag)
|
|
||||||
label := labels.SelectorFromSet(labels.Set(map[string]string{"component": "rabbitmq"}))
|
|
||||||
err := framework.WaitForPodsWithLabelRunning(c, ns, label)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
forEachPod("component", "rabbitmq", func(pod api.Pod) {
|
|
||||||
_, err := framework.LookForStringInLog(ns, pod.Name, "rabbitmq", "Server startup complete", serverStartTimeout)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
})
|
|
||||||
err = framework.WaitForEndpoint(c, ns, "rabbitmq-service")
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
|
|
||||||
By("starting celery")
|
|
||||||
framework.RunKubectlOrDie("create", "-f", celeryControllerYaml, nsFlag)
|
|
||||||
label = labels.SelectorFromSet(labels.Set(map[string]string{"component": "celery"}))
|
|
||||||
err = framework.WaitForPodsWithLabelRunning(c, ns, label)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
forEachPod("component", "celery", func(pod api.Pod) {
|
|
||||||
_, err := framework.LookForStringInFile(ns, pod.Name, "celery", "/data/celery.log", " ready.", serverStartTimeout)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
})
|
|
||||||
|
|
||||||
By("starting flower")
|
|
||||||
framework.RunKubectlOrDie("create", "-f", flowerServiceYaml, nsFlag)
|
|
||||||
framework.RunKubectlOrDie("create", "-f", flowerControllerYaml, nsFlag)
|
|
||||||
label = labels.SelectorFromSet(labels.Set(map[string]string{"component": "flower"}))
|
|
||||||
err = framework.WaitForPodsWithLabelRunning(c, ns, label)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
forEachPod("component", "flower", func(pod api.Pod) {
|
|
||||||
content, err := makeHttpRequestToService(c, ns, "flower-service", "/", framework.EndpointRegisterTimeout)
|
|
||||||
Expect(err).NotTo(HaveOccurred())
|
|
||||||
if !strings.Contains(content, "<title>Celery Flower</title>") {
|
|
||||||
framework.Failf("Flower HTTP request failed")
|
|
||||||
}
|
|
||||||
})
|
|
||||||
})
|
|
||||||
})
|
|
||||||
|
|
||||||
framework.KubeDescribe("Spark", func() {
|
framework.KubeDescribe("Spark", func() {
|
||||||
It("should start spark master, driver and workers", func() {
|
It("should start spark master, driver and workers", func() {
|
||||||
mkpath := func(file string) string {
|
mkpath := func(file string) string {
|
||||||
|
Loading…
Reference in New Issue
Block a user