diff options
Diffstat (limited to 'src/flufigut.py')
| -rwxr-xr-x | src/flufigut.py | 19 |
1 files changed, 15 insertions, 4 deletions
diff --git a/src/flufigut.py b/src/flufigut.py index 0009c50..ad2bfc4 100755 --- a/src/flufigut.py +++ b/src/flufigut.py @@ -627,7 +627,7 @@ class K8sDeployment: object_yaml = tmpl.render(namespace=self._namespace, desc=self._desc, planet=self._planet, worker=worker) return yaml.load(object_yaml) - def _deploy_manager(self, template_dir, tmpl_env, v1, appsV1): + def _deploy_flumotion_manager(self, template_dir, tmpl_env, v1, appsV1): svc = self.__generate_object(tmpl_env, 'flumotion-manager-svc.yml') v1.create_namespaced_service(self._namespace, svc) @@ -642,7 +642,7 @@ class K8sDeployment: deploy = self.__generate_object(tmpl_env, 'flumotion-manager-deploy.yml') appsV1.create_namespaced_deployment(self._namespace, deploy) - def _deploy_worker(self, template_dir, tmpl_env, v1, appsV1, worker): + def _deploy_flumotion_worker(self, template_dir, tmpl_env, v1, appsV1, worker): if not len(worker['subs']): worker['subs']['worker'] = { 'fullname': worker['name'], @@ -660,6 +660,16 @@ class K8sDeployment: deploy = self.__generate_object(tmpl_env, 'flumotion-worker-deploy.yml', worker) appsV1.create_namespaced_deployment(self._namespace, deploy) + def _deploy_nginx_worker(self, template_dir, tmpl_env, v1, appsV1, worker): + cm = self.__generate_object(tmpl_env, 'nginx-streamer-cm.yml', worker) + v1.create_namespaced_config_map(self._namespace, cm) + + svc = self.__generate_object(tmpl_env, 'nginx-streamer-svc.yml', worker) + v1.create_namespaced_service(self._namespace, svc) + + deploy = self.__generate_object(tmpl_env, 'nginx-streamer-deploy.yml', worker) + appsV1.create_namespaced_deployment(self._namespace, deploy) + def deploy(self, template_dir): v1 = kubernetes.client.CoreV1Api() appsV1 = kubernetes.client.AppsV1Api() @@ -668,9 +678,10 @@ class K8sDeployment: loader = jinja2.FileSystemLoader(os.path.join(template_dir, self._desc.globals['templates'], 'kubernetes')) tmpl_env = jinja2.Environment(loader=loader, line_statement_prefix='%%') - self._deploy_manager(template_dir, tmpl_env, v1, appsV1) + self._deploy_flumotion_manager(template_dir, tmpl_env, v1, appsV1) for _, worker in self._planet.workers.items(): - self._deploy_worker(template_dir, tmpl_env, v1, appsV1, worker) + self._deploy_flumotion_worker(template_dir, tmpl_env, v1, appsV1, worker) + self._deploy_nginx_worker(template_dir, tmpl_env, v1, appsV1, worker) def wipe(self): v1 = kubernetes.client.CoreV1Api() |