public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

create with kubectl

This commit is contained in:
Sergey Dudoladov 2019-05-23 18:16:16 +02:00
parent 0580916ba0
commit 2984872dfb
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
e2e/tests/test_smoke.py
View File

@ -33,11 +33,10 @@ class SmokeTestCase(unittest.TestCase):
# set a single k8s wrapper for all tests # set a single k8s wrapper for all tests
k8s = cls.k8s = K8s() k8s = cls.k8s = K8s()
# k8s python client fails with multiple resources in a single file; we resort to kubectl for filename in ["operator-service-account-rbac.yaml",
subprocess.run(["kubectl", "create", "-f", "manifests/operator-service-account-rbac.yaml"]) "configmap.yaml",
"postgres-operator.yaml"]:
for filename in ["configmap.yaml", "postgres-operator.yaml"]: k8s.create_with_kubectl("manifests/" + filename)
utils.create_from_yaml(k8s.api.k8s_client, "manifests/" + filename)
# submit the most recent operator image built on the Docker host # submit the most recent operator image built on the Docker host
body = { body = {
@ -63,12 +62,12 @@ class SmokeTestCase(unittest.TestCase):
actual_operator_image = k8s.api.core_v1.list_namespaced_pod('default', label_selector='name=postgres-operator').items[0].spec.containers[0].image actual_operator_image = k8s.api.core_v1.list_namespaced_pod('default', label_selector='name=postgres-operator').items[0].spec.containers[0].image
print("Tested operator image: {}".format(actual_operator_image)) # shows up after tests finish print("Tested operator image: {}".format(actual_operator_image)) # shows up after tests finish
subprocess.run(["kubectl", "create", "-f", "manifests/minimal-postgres-manifest.yaml"]) k8s.create_with_kubectl("manifests/minimal-postgres-manifest.yaml")
k8s.wait_for_pod_start('spilo-role=master') k8s.wait_for_pod_start('spilo-role=master')
@timeout_decorator.timeout(TEST_TIMEOUT_SEC) @timeout_decorator.timeout(TEST_TIMEOUT_SEC)
def master_is_unique(self): def test_master_is_unique(self):
""" """
Check that there is a single pod in the k8s cluster with the label "spilo-role=master". Check that there is a single pod in the k8s cluster with the label "spilo-role=master".
""" """
@ -80,7 +79,7 @@ class SmokeTestCase(unittest.TestCase):
self.assertEqual(num_of_master_pods, 1, "Expected 1 master pod, found {}".format(num_of_master_pods)) self.assertEqual(num_of_master_pods, 1, "Expected 1 master pod, found {}".format(num_of_master_pods))
@timeout_decorator.timeout(TEST_TIMEOUT_SEC) @timeout_decorator.timeout(TEST_TIMEOUT_SEC)
def scaling(self): def test_scaling(self):
""" """
Scale up from 2 to 3 pods and back to 2 by updating the Postgres manifest at runtime. Scale up from 2 to 3 pods and back to 2 by updating the Postgres manifest at runtime.
""" """