ingress 3

deployment/deploy-yml.tmpl

@@ -29,4 +29,40 @@ spec:
           ports:
             - containerPort: 8080
               protocol: TCP
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: locative
+spec:
+  type: ClusterIP
+  selector:
+    app: locsrv
+  ports:
+    - name: http
+      targetPort: 8080
+      port: 80
+---
+apiVersion: networking.k8s.io/v1
+kind: Ingress
+metadata:
+  name: locative
+  annotations:
+    cert-manager.io/cluster-issuer: letsencrypt-production-http
+spec:
+  tls:
+    - hosts:
+        - locative.hottis.de
+      secretName: locative-cert
+  rules:
+    - host: locative.hottis.de
+      http:
+        paths:
+          - path: /
+            pathType: Prefix
+            backend:
+              service:
+                name: locative
+                port:
+                  number: 80
 

src/locsrv/main.go

@@ -2,6 +2,7 @@ package main
 
 import (
   "log"
+  "time"
   "github.com/gin-gonic/gin"
   "net/http"
   "encoding/json"
@@ -30,6 +31,7 @@ type locativeEvent struct {
   Latitude string `json:"latitude"`
   Longitude string `json:"longitude"`
   Person string `json:"person"`
+  Timestamp string `json:"timestamp"`
 }
 
 
@@ -46,6 +48,7 @@ func main() {
         person, err := dbh.GetPersonById(event.Device)
         event.Person = person
         event.Location = event.Id
+        event.Timestamp = time.Now().Format("2006-01-02 15:04:05 MST")
         event.Id = ""
         if err != nil {
           log.Printf("Person unknown: %v", err)

src/locsrv/mqtt/mqtt.go

@@ -45,7 +45,7 @@ func (self *MqttHandle) Publish(topicPost string, message string) error {
   }
 
   topic := fmt.Sprintf("%s/%s", self.pubTopic, topicPost)
-  token := self.client.Publish(topic, 0, false, message) 
+  token := self.client.Publish(topic, 0, true, message) 
   token.Wait()
   if token.Error() != nil {
     return fmt.Errorf("MQTT publish failed: %v", token.Error())