hotfix

cloud-native-dojo · Aug 16, 2022 · 3e6625d · 3e6625d
1 parent d9a2d2d
commit 3e6625d
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/__pycache__/k8s.cpython-38.pyc b/__pycache__/k8s.cpython-38.pyc
diff --git a/__pycache__/main.cpython-38.pyc b/__pycache__/main.cpython-38.pyc
diff --git a/k8s.py b/k8s.py
@@ -30,6 +30,6 @@ def get_used_port():
     print(unusedport)
     return unusedport
 
-def update_port(name):
-    cp = subprocess.run(['kubectl' 'patch' 'service' name '--type=\'json\'' '-p=\'[{"op": "replace", "path": "/spec/ports/0/nodePort", "value": 31600}]\''], encoding='utf-8', stdout=subprocess.PIPE)
+def update_port(name, port):
+    cp = subprocess.run(['kubectl', 'patch', 'service', name, '--type=\'json\'', '-p=\'[{"op": "replace", "path": "/spec/ports/0/nodePort", "value": {}}]\''.format(port)], encoding='utf-8', stdout=subprocess.PIPE)
     return cp.stdout
diff --git a/main.py b/main.py
@@ -31,11 +31,11 @@ def create_pod(pod: Pod):
 
 @app.get("/pods/")
 def get_pod():
-    return {"output": k8s.get_pod()}
+    return {"pods": k8s.get_pod()}
 
 @app.post("/services/")
 def create_service(service: Service):
-    callback = k8s.change_port(name)
+    callback = k8s.change_port(service.name,service.port)
     return {"result": callback}
 
 @app.get("/ports_suggest/")