Add service

stack_orchestrator/deploy/k8s/cluster_info.py

@@ -102,6 +102,21 @@ class ClusterInfo:
             )
         return ingress
 
+    def get_service(self):
+        service = client.V1Service(
+            metadata=client.V1ObjectMeta(name=f"{self.app_name}-service"),
+            spec=client.V1ServiceSpec(
+                type="ClusterIP",
+                ports=[client.V1ServicePort(
+                    port=80,
+                    target_port=80
+                )],
+                selector={"matchLabels":
+                          {"app": self.app_name}}
+            )
+        )
+        return service
+
     def get_pvcs(self):
         result = []
         volumes = named_volumes_from_pod_files(self.parsed_pod_yaml_map)

stack_orchestrator/deploy/k8s/deploy_k8s.py

@@ -105,6 +105,15 @@ class K8sDeployer(Deployer):
             print(f"{deployment_resp.metadata.namespace} {deployment_resp.metadata.name} \
                   {deployment_resp.metadata.generation} {deployment_resp.spec.template.spec.containers[0].image}")
 
+        service: client.V1Service = self.cluster_info.get_service()
+        service_resp = self.core_api.create_namespaced_service(
+            namespace=self.k8s_namespace,
+            body=service
+        )
+        if opts.o.debug:
+            print("Service created:")
+            print(f"{service_resp}")
+
         # TODO: disable ingress for kind
         ingress: client.V1Ingress = self.cluster_info.get_ingress()
 
@@ -145,6 +154,14 @@ class K8sDeployer(Deployer):
             name=deployment.metadata.name, namespace=self.k8s_namespace
         )
 
+        service: client.V1Service = self.cluster_info.get_service()
+        if opts.o.debug:
+            print(f"Deleting service: {service}")
+        self.core_api.delete_namespaced_service(
+            namespace=self.k8s_namespace,
+            body=service
+        )
+
         # TODO: disable ingress for kind
         ingress: client.V1Ingress = self.cluster_info.get_ingress()
         if opts.o.debug: