K8s deployment updates

.gitignore

@@ -1,3 +1,5 @@
 target/
 .idea/
 server/*.iml
+k8s.secret.yml
+/consumer.properties

Jenkinsfile

@@ -1,3 +1,3 @@
 library('jenkins-pipeline')
 
-demoServerUiPipeline("sim-stocks", "maven")
+demoServerUiPipeline("stocks-simulated", "maven")

README.md

@@ -29,3 +29,13 @@ npm run dev
 ```
 
 Then head to `localhost:5173` to see it in action.
+
+# Deploying to kubernetes
+
+Edit the consumer.properties file to match the settings needed to connect to confluent cloud.
+
+```bash
+# If the secret already exists
+kubectl delete secret -n demo-stocks-simulated consumer-properties
+kubectl update secret generic -n demo-stocks-simulated consumer-properties --from-file=consumer.properties
+```

k8s.yml

@@ -2,32 +2,39 @@
 apiVersion: apps/v1
 kind: StatefulSet
 metadata:
-  name: demo-sim-stocks
-  namespace: demo-sim-stocks
+  name: demo-stocks-simulated
+  namespace: demo-stocks-simulated
 spec:
   replicas: 1
   selector:
     matchLabels:
-      demo: sim-stocks
+      demo: stocks-simulated
   serviceName: demo
   template:
     metadata:
       labels:
-        demo: sim-stocks
+        demo: stocks-simulated
     spec:
+      volumes:
+        - name: consumer-properties
+          secret:
+            secretName: consumer-properties
       containers:
         - image: DOCKER_IMAGE
           imagePullPolicy: Always
           name: demo
+          args:
+            - "-Dswim.config=/config/server.k8s.recon"
+          volumeMounts:
+            - mountPath: /secret/confluent
+              name: consumer-properties
           ports:
             - containerPort: 9001
               protocol: TCP
           resources:
             limits:
               cpu: 500m
-              memory: 1Gi
+              memory: 512Mi
             requests:
               cpu: 250m
-              memory: 512Mi
-
-
+              memory: 256Mi

server/src/main/resources/server.k8s.recon

@@ -0,0 +1,40 @@
+@kernel(class: "swim.meta.MetaKernel")
+@kernel(class: "swim.service.web.UiRouter")
+
+provisions: {
+  @provision("consumer") {
+    class: "nstream.adapter.common.provision.PropertiesProvision",
+    config: "/secret/confluent/consumer.properties"
+  }
+}
+
+stock: @fabric {
+    @plane(class: "io.nstream.demos.stocks.StockPlane")
+
+    uri: "/consumer"
+    @agent(class: "nstream.adapter.confluent.ConfluentIngestingPatch") {
+      confluentIngressConf: @kafkaIngressSettings {
+        consumerPropertiesProvisionName: "consumer"
+         laneUri: "status"
+      }
+    }
+
+    @node {
+        pattern: "/stock/:symbol"
+        @agent(class: "io.nstream.demos.stocks.agents.StockAgent")
+    }
+
+    @node {
+        pattern: "/symbols"
+        @agent(class: "io.nstream.demos.stocks.agents.SymbolsAgent")
+    }
+
+}
+
+@web(port: 9001) {
+    space: "stock"
+    @websocket {
+        serverCompressionLevel: 0# -1 = default; 0 = off; 1-9 = deflate level
+        clientCompressionLevel: 0# -1 = default; 0 = off; 1-9 = deflate level
+    }
+}