diff options
author | 2019-06-25 18:52:55 -0400 | |
---|---|---|
committer | 2019-07-01 11:07:30 -0400 | |
commit | 9c094d0581c46d3d107facdc55cb2cc7a1d9f765 (patch) | |
tree | 7bb29d659b23295d3a3f67f7e1be054a8eb51544 /k8s/tests/test_k8sclient.py | |
parent | a9e0e1c94d9b1fee783ce2db3df962b6fec5149b (diff) |
Add TLS support for client-only apps
Also enhance unit tests to do more robust checking of results.
Issue-ID: DCAEGEN2-1550
Change-Id: Icf6e5357d828e19db73bb58b98fd60e9f111d0dc
Signed-off-by: Jack Lucas <jflucas@research.att.com>
Diffstat (limited to 'k8s/tests/test_k8sclient.py')
-rw-r--r-- | k8s/tests/test_k8sclient.py | 100 |
1 files changed, 2 insertions, 98 deletions
diff --git a/k8s/tests/test_k8sclient.py b/k8s/tests/test_k8sclient.py index 70ebf05..079748c 100644 --- a/k8s/tests/test_k8sclient.py +++ b/k8s/tests/test_k8sclient.py @@ -16,6 +16,8 @@ # limitations under the License. # ============LICENSE_END========================================================= +# Basic sanity tests for k8sclient functions + import pytest def test_parse_interval(): @@ -174,101 +176,3 @@ def test_create_probe(): for hc in script_checks: probe = _create_probe(hc, 13131) assert probe._exec.command[0] == hc["script"] - -def test_deploy(monkeypatch): - import k8sclient.k8sclient - from kubernetes import client - - # We need to patch the kubernetes 'client' module - # Awkward because of the way it requires a function call - # to get an API object - core = client.CoreV1Api() - ext = client.ExtensionsV1beta1Api() - - def pseudo_deploy(namespace, dep): - return dep - - def pseudo_service(namespace, svc): - return svc - - # patched_core returns a CoreV1Api object with the - # create_namespaced_service method stubbed out so that there - # is no attempt to call the k8s API server - def patched_core(): - monkeypatch.setattr(core, "create_namespaced_service", pseudo_service) - return core - - # patched_ext returns an ExtensionsV1beta1Api object with the - # create_namespaced_deployment method stubbed out so that there - # is no attempt to call the k8s API server - def patched_ext(): - monkeypatch.setattr(ext,"create_namespaced_deployment", pseudo_deploy) - return ext - - def pseudo_configure(loc): - pass - - monkeypatch.setattr(k8sclient.k8sclient,"_configure_api", pseudo_configure) - monkeypatch.setattr(client, "CoreV1Api", patched_core) - monkeypatch.setattr(client,"ExtensionsV1beta1Api", patched_ext) - - k8s_test_config = { - "image_pull_secrets" : ["secret0", "secret1"], - "filebeat" : { - "log_path": "/var/log/onap", - "data_path": "/usr/share/filebeat/data", - "config_path": "/usr/share/filebeat/filebeat.yml", - "config_subpath": "filebeat.yml", - "image" : "filebeat-repo/filebeat:latest", - "config_map" : "dcae-filebeat-configmap" - }, - "tls" : { - "cert_path": "/opt/certs", - "image": "tlsrepo/tls-init-container:1.2.3" - } - } - - resources = { - "limits": { - "cpu" : 0.5, - "memory" : "2Gi" - }, - "requests": { - "cpu" : 0.5, - "memory" : "2Gi" - } - } - - kwargs = { - "volumes": [ - {"host":{"path": "/path/on/host"}, "container":{"bind":"/path/on/container","mode":"rw"}} - ], - "ports": ["80:0", "443:0"], - "env": {"name0": "value0", "name1": "value1"}, - "log_info": {"log_directory": "/path/to/container/log/directory"}, - "tls_info": {"use_tls": True, "cert_directory": "/path/to/container/cert/directory" }, - "readiness": {"type": "http", "endpoint" : "/ready"} - } - dep, deployment_description = k8sclient.k8sclient.deploy("k8stest","testcomponent","example.com/testcomponent:1.4.3",1,False, k8s_test_config, resources, **kwargs) - - assert deployment_description["deployment"] == "dep-testcomponent" - assert deployment_description["namespace"] == "k8stest" - assert deployment_description["services"][0] == "testcomponent" - - # For unit test purposes, we want to make sure that the deployment object - # we're passing to the k8s API is correct - app_container = dep.spec.template.spec.containers[0] - assert app_container.image == "example.com/testcomponent:1.4.3" - assert app_container.image_pull_policy == "IfNotPresent" - assert len(app_container.ports) == 2 - assert app_container.ports[0].container_port == 80 - assert app_container.ports[1].container_port == 443 - assert app_container.readiness_probe.http_get.path == "/ready" - assert app_container.readiness_probe.http_get.scheme == "HTTP" - assert len(app_container.volume_mounts) == 3 - assert app_container.volume_mounts[0].mount_path == "/path/on/container" - assert app_container.volume_mounts[1].mount_path == "/path/to/container/log/directory" - assert app_container.volume_mounts[2].mount_path == "/path/to/container/cert/directory" - - # Needs to be correctly labeled so that the Service can find it - assert dep.spec.template.metadata.labels["app"] == "testcomponent" |