diff options
Diffstat (limited to 'k8s/k8splugin/tasks.py')
| -rw-r--r-- | k8s/k8splugin/tasks.py | 10 |
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"] |