kubernetes-client/python
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

configmap-e2e: use labels

Browse Source
This commit is contained in:
Haowei Cai 2021-01-05 09:58:42 -08:00
parent 5be9c893b3
commit 3b95adc8f3
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
kubernetes/e2e_test/test_client.py
View File

@ -443,6 +443,7 @@ class TestClient(unittest.TestCase):
"apiVersion": "v1",
"metadata": {
"name": name,
"labels": {"e2e-tests": "true"},
},
"data": {
"config.json": "{\"command\":\"/usr/bin/mysqld_safe\"}",
@ -466,7 +467,7 @@ class TestClient(unittest.TestCase):
resp = api.delete_namespaced_config_map(
name=name, body={}, namespace='default')
resp = api.list_namespaced_config_map('default', pretty=True)
resp = api.list_namespaced_config_map('default', pretty=True, label_selector="e2e-tests=true")
self.assertEqual([], resp.items)
def test_node_apis(self):

8
kubernetes/e2e_test/test_watch.py
View File

@ -32,6 +32,7 @@ def config_map_with_value(name, value):
"kind": "ConfigMap",
"metadata": {
"name": name,
"labels": {"e2e-tests": "true"},
},
"data": {
"key": value,
@ -57,7 +58,7 @@ class TestClient(unittest.TestCase):
body=configmap_a, namespace='default')
# list all configmaps and extract the resource version
resp = api.list_namespaced_config_map('default')
resp = api.list_namespaced_config_map('default', label_selector="e2e-tests=true")
rv = resp.metadata.resource_version
# create another configmap
@ -73,7 +74,7 @@ class TestClient(unittest.TestCase):
# delete all configmaps
api.delete_collection_namespaced_config_map(
namespace='default')
namespace='default', label_selector="e2e-tests=true")
w = watch.Watch()
# expect to observe all events happened after the initial LIST
@ -83,7 +84,8 @@ class TestClient(unittest.TestCase):
for event in w.stream(api.list_namespaced_config_map,
namespace='default',
resource_version=rv,
timeout_seconds=5):
timeout_seconds=5,
label_selector="e2e-tests=true"):
self.assertEqual(event['type'], expect[i])
# Kubernetes doesn't guarantee the order of the two objects
# being deleted