Added template code, removed gitlab-ci.yml file

.gitlab-ci.yml

-services:
-  - docker:19.03.12-dind
-
-variables:
-  DOCKER_HOST: "tcp://docker:2375"
-  DOCKER_DRIVER: overlay2
-  DOCKER_TLS_CERTDIR: ""
-
-test:
-  stage: test
-  image: openjdk:11
-  script: ./mvnw -ntp test
\ No newline at end of file

pom.xml

@@ -45,6 +45,11 @@
             <groupId>org.springframework.kafka</groupId>
             <artifactId>spring-kafka</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.kubernetes</groupId>
+            <artifactId>client-java</artifactId>
+            <version>10.0.0</version>
+        </dependency>
 
         <!-- Test Dependencies -->
         <dependency>

src/main/java/org/opengroup/osdu/streaming/service/DeploymentAdminServiceImpl.java

 package org.opengroup.osdu.streaming.service;
 
+import io.kubernetes.client.openapi.ApiClient;
+import io.kubernetes.client.openapi.ApiException;
+import io.kubernetes.client.openapi.Configuration;
+import io.kubernetes.client.openapi.apis.AppsV1Api;
+import io.kubernetes.client.openapi.apis.CoreV1Api;
+import io.kubernetes.client.openapi.models.V1Deployment;
+import io.kubernetes.client.openapi.models.V1DeploymentBuilder;
+import io.kubernetes.client.util.Config;
 import org.opengroup.osdu.streaming.model.StreamRecord;
 import org.springframework.stereotype.Service;
 import org.springframework.web.context.annotation.RequestScope;
 
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+
 @Service
 @RequestScope
 public class DeploymentAdminServiceImpl implements DeploymentAdminService {
 
+    CoreV1Api coreV1Api;
+    AppsV1Api appsV1Api;
+
+    public DeploymentAdminServiceImpl() throws IOException {
+        ApiClient client = Config.defaultClient();
+        Configuration.setDefaultApiClient(client);
+        coreV1Api = new CoreV1Api();
+        appsV1Api = new AppsV1Api();
+    }
+
     @Override
     public StreamRecord createStream(StreamRecord streamRecord) {
+        Map<Object, Object> map = parseForNeededFields(streamRecord);
+        V1Deployment deployment = new V1DeploymentBuilder()
+                .withNewMetadata()
+                .withName("TODO")
+                .endMetadata()
+                .withNewSpec()
+                .endSpec()
+                .build();
+
+        try {
+            appsV1Api.createNamespacedDeployment("default", deployment, null, null, null);
+        } catch (ApiException e) {
+            e.printStackTrace();
+        }
         return null;
     }
 
+    private Map<Object, Object> parseForNeededFields(StreamRecord streamRecord) {
+        return new HashMap<>();
+    }
+
     @Override
     public StreamRecord getStreamInfo(String id) {
         return null;
@@ -20,7 +60,8 @@ public class DeploymentAdminServiceImpl implements DeploymentAdminService {
 
     @Override
     public void startStream(StreamRecord streamRecord) {
-
+        //TODO Check if it's deployed
+        //TODO
     }
 
     @Override

src/main/resources/manifests/consumer-template.yaml

+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: streams-${stream.deploymentName}-deployment
+  namespace: osdu-streams
+spec:
+  replicas: 1
+  selector:
+    matchLabels:
+      run: ${stream.deploymentName}
+  template:
+    metadata:
+      labels:
+        run: ${stream.deploymentName}
+    spec:
+      containers:
+        - image: ${stream.image}
+          ports:
+            - containerPort: ${stream.containerPort}
+
+---
+
+apiVersion: v1
+kind: Service
+metadata:
+  name: ${stream.deploymentName}-service
+  labels:
+    run: ${stream.deploymentName}
+spec:
+  ports:
+    - port: ${stream.servicePort}
+      protocol: TCP
+  selector:
+    run: ${stream.deploymentName}
\ No newline at end of file

stream-admin-service.drawio

+<mxfile host="Electron" modified="2021-10-25T19:22:24.468Z" agent="5.0 (Macintosh; Intel Mac OS X 11_6_0) AppleWebKit/537.36 (KHTML, like Gecko) draw.io/14.9.6 Chrome/89.0.4389.128 Electron/12.0.16 Safari/537.36" etag="2-ATRw-x48F2hRZM0smG" version="14.9.6" type="device"><diagram id="oPQlikl0BSEGqThpAdY3" name="Page-1">7Vvfc9o4EP5reGzH2BjIY4Ck12mvx4XMXO/pRtgC1MiWR5YTyF9/Kyz/kgwYigmdNA+JvZZW0vetVrtrp+OMg/UnjqLVn8zHtGNb/rrjTDq2PejZ8FsKNqnA7VmpYMmJn4q6hWBGXrESZs0S4uO40lAwRgWJqkKPhSH2REWGOGcv1WYLRqujRmiJDcHMQ9SU/kN8sVLSrmUVD/7AZLlSQw9d9SBAWWMliFfIZy8lkXPXccacMZFeBesxphK7DJe03/2Op/nEOA5Fkw6L6XSxGX+Zfvoy+LH++/X5v401/6C0PCOaqAVjEX3wKJFK02mLTYYFZ0noY6nO6jijlxUReBYhTz59AfJBthIBhbsuXCrFmAu83jnjbo4D2A9mARZ8A01Uh8xUNtXblxIPGbirEgVZO6SoX+aKC3TgQgF0BFiuAZYBEfbBetQt42LFlixE9K6QjqogFm2+MhYp6H5gITZqK6BEsDpg5UD7YYV5sYR7eM+C1PwF4kss9rTr1dPEMUWCPFfncXbU+28BMl4T8V11l9f/yuuPrrqbrEuPJpvsJoTlfs8UyJtSL3lbdNveZf3egNAd++4yhNq1PifGHJzFm/ucq3M6PQOtJ7R4Qm8OVO/agLo57J3hCI7kZRLQr2SBKQmls4A1C+KRCG0XDs9uPcG4fIA5gbmBVToTqtpPC9khkCEkEQi68PyeUhTFZL6djmSJYy/hMWy4BxynnkhKJS0EIpBbSpYhyIT0WaMYxiHh8nHrwJy+dGuJkDMa55GPdSZmq8TmLJaYrSM2F56d2SwWLFE7ExyjAPC49eE3QCA4oIv55yCiTWl/G3bbYi2naQ9t3cFleTOjyypvM/D5BPB9l4Q53QaE9S5LmGMQBv6GeL/J6jsNyLqwVzTTkQmOKNsEsKbfjA0GDRjrX5axweEQpYRoxEgotnNwRx13olFUJDVlks4AnG1pwA1qgKvBreu2htvQwG361+yxY/cpjD2aQ9bQX8qr9HR5wB7j/j5k9QhrzoRgwTYx829l0UjKKPOejsrODmddg3rgS8AOFYaNMzGlbSptpeDQrVKYU5ppSBNJ1alcM9L0dJ0DitI1G4q2NOcr/AnmzaD+8wyCc1mje8/OrdfEuV02drDNYO8KnZvruFWD7jZzbu3BZoZcVwibM6jC1vhMaC3bt826iAfOX+Bv+CU9Bq7wAEjJvsQBYGe5l27nx54AjuZpDEUtnwC2GeUmUQz0vdUpf7gG6zS1hh177vzW4Az7VRJ1d9bUGlw9sNAV7bAGgBttSs2UG9s54d5N/TiFcaUaz2tq/V/BFfeH2glWV3i96An2S2Q1w54GW8MTrD3YzKQmPcC2FZdrPLz6l3NXGld6ZtnYXenRnq6oLXflXsJdmblRakBp+FPUgq7RlnZkwgpP62PXGg6M/dmWeQ1PNC/DFeuK2jKv4R7zKnpn6tliEeNWgjPnuJyvibGxCMOjkY/i1fZlZvouPfswaHiZgszPGpiWLTmnll/smwOKWg6+Hfuq+T0YimcF14OGcNOKHdiWRt+pSZgWdTc1g2P9TF4O1+bb6jHm1BVAVGE3q+vePU6hRflEs8YsXJBlwoEfFmYdYAJ5H7M6nEkSqksoySQkkN8DFuqKJyWhqcAcpEZSXc1Mfe+ir8T6hrH8juNsS8IiAq0f5Ejqsz7rM0zgPoJYe+9K61SgRKxe4S9EGj7oIoiCPfVRIOul4TyOqkDt0/kl/Yplq3XOmIgFR1EKSnyCCpFGzVaIAnxK/2xhUTKnJF4ZSzxW3xOWO2+JQ5wT62OByEnKIrShDPnS5XkrHKBjDFRz15BBiWpte0EoHTMqv3iZhGxbLUfKgVO8EDV+Pf0gpa5kXv0ICShlTzjT3ZF+S/6cqQRe9VVu38znnNoXsnqQdraMzjFLksbeT2Pz6tvZAx7A3O11PmGfB2CxnyhLitOXJ/IqH/7nDP0Mezfbe0jCctqEhjNN18PodrxVlfjlxd77pUPknoRLjuP9g7zP7eQ03U55zHDEdoLb4rP3NI4o/nfAufsf</diagram></mxfile>
\ No newline at end of file