Add support for TLS init container

Change-Id: I118af2c8a0294ffc89e045f8cdae24dfb7e57ab6
Issue-ID: DCAEGEN2-591
Signed-off-by: Jack Lucas <jflucas@research.att.com>

1 files changed, 10 insertions, 0 deletions

diff --git a/k8s/k8splugin/tasks.py b/k8s/k8splugin/tasks.py
index d32ce30..ba71bd9 100644
--- a/k8s/k8splugin/tasks.py
+++ b/k8s/k8splugin/tasks.py
@@ -296,6 +296,7 @@ def _create_and_start_container(container_name, image, **kwargs):
                      volumes=kwargs.get("volumes",[]),
                      ports=kwargs.get("ports",[]),
                      msb_list=kwargs.get("msb_list"),
+                     tls_info=kwargs.get("tls_info"),
                      env = env,
                      labels = kwargs.get("labels", {}),
                      log_info=kwargs.get("log_info"),
@@ -324,6 +325,10 @@ def _parse_cloudify_context(**kwargs):
     if "log_info" in ctx.node.properties and "log_directory" in ctx.node.properties["log_info"]:
         kwargs["log_info"] = ctx.node.properties["log_info"]
 
+    # Pick up TLS info if present
+    if "tls_info" in ctx.node.properties:
+        kwargs["tls_info"] = ctx.node.properties["tls_info"]
+
     # Pick up replica count and always_pull_image flag
     if "replicas" in ctx.node.properties:
         kwargs["replicas"] = ctx.node.properties["replicas"]
@@ -380,6 +385,7 @@ def _create_and_start_component(**kwargs):
         "ports": kwargs.get("ports", None),
         "envs": kwargs.get("envs", {}),
         "log_info": kwargs.get("log_info", {}),
+        "tls_info": kwargs.get("tls_info", {}),
         "labels": kwargs.get("labels", {}),
         "readiness": kwargs.get("readiness",{})}
     _create_and_start_container(service_component_name, image, **sub_kwargs)
@@ -524,6 +530,10 @@ def create_and_start_container_for_platforms(**kwargs):
     if "log_info" in ctx.node.properties and "log_directory" in ctx.node.properties["log_info"]:
         kwargs["log_info"] = ctx.node.properties["log_info"]
 
+    # Pick up TLS info if present
+    if "tls_info" in ctx.node.properties:
+        kwargs["tls_info"] = ctx.node.properties["tls_info"]
+
     # Pick up replica count and always_pull_image flag
     if "replicas" in ctx.node.properties:
         kwargs["replicas"] = ctx.node.properties["replicas"]