diff options
author | Christian Pointner <equinox@spreadspace.org> | 2018-02-10 21:53:23 +0100 |
---|---|---|
committer | Christian Pointner <equinox@spreadspace.org> | 2018-02-10 21:53:23 +0100 |
commit | 433d8fbcc6628a1e331388ae0676d0735e46142c (patch) | |
tree | f4547433cfc51d13b9528d1d942e1463ec588c61 /src/flufigut.py | |
parent | recording works now (diff) |
generate flumotion worker services
Diffstat (limited to 'src/flufigut.py')
-rwxr-xr-x | src/flufigut.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/src/flufigut.py b/src/flufigut.py index d0de644..a20f014 100755 --- a/src/flufigut.py +++ b/src/flufigut.py @@ -415,11 +415,12 @@ class Planet: comp_name = '%s-%s%i-port-%s-%i' % (protocol, stream, idx + 1, interface, port) addr = '%s:%i' % (interface, port) + worker = self.__get_worker(comp_name) porter = Porter(comp_name, interface, port) self.atmosphere[porter.name] = { 'type': "porter", 'desc': "%s porter %s%i on %s" % (protocol, stream, idx + 1, addr), - 'worker': str(self.__get_worker(comp_name)), + 'worker': str(worker), 'properties': { 'port': port, 'socket-path': porter.socket_path, @@ -430,6 +431,7 @@ class Planet: if interface: self.atmosphere[porter.name]['properties']['interface'] = interface + self.__add_worker_flag(worker, "port", port) return porter def __generate_stream_mux_repeater(self, stream, mux, format, profile, feeder): @@ -651,6 +653,10 @@ class K8sDeployment: secret['data']['password'] = base64.b64encode(worker['password'].encode('utf-8')).decode('ascii') v1.create_namespaced_secret(self._namespace, secret) + if 'port' in worker['flags']: + svc = self.__generate_object(tmpl_env, 'flumotion-worker-svc.yml', worker) + v1.create_namespaced_service(self._namespace, svc) + deploy = self.__generate_object(tmpl_env, 'flumotion-worker-deploy.yml', worker) appsV1.create_namespaced_deployment(self._namespace, deploy) |